modelRT/constants
douxu 42956d1793 feat: add dedicated message-exchange for task lifecycle notifications
- add constants/message.go with MessageTask* categories and message-exchange /
    message-queue / dead-letter routing constants
  - add mq/publish_message.go with PushMessageToRabbitMQ (confirm mode,
    dead-letter queue) separate from the existing event-exchange publisher
  - add mq/emit.go with TryEmitMessage for non-blocking, OTel-traced dispatch
  - add mq/event/task_event_gen.go with NewTaskSubmitted/Running/Completed/
    Failed/CancelledMessage constructors
  - wire TryEmitMessage into task worker and create/cancel handlers so all 5
    lifecycle transitions are published (previously task.* routed to
    event-exchange with no matching binding, causing silent drops)
  - harden Dockerfile: scratch final image, pinned alpine:3.21 certs stage,
    apk upgrade in builder, add -trimpath -mod=readonly go build flags
  - add full K8s manifests under deploy/k8s/ for Redis, RabbitMQ (mTLS),
    ModelRT (Downward API, scratch image, readOnlyRootFilesystem), Jaeger,
    Loki, Promtail, Grafana
  - expand deploy.md with async_task SQL schema, TLS cert generation steps,
    K8s deployment procedures, and SSH tunnel configuration
2026-05-13 16:58:36 +08:00
..
alert.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
attrs_key.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
buffer.go optimzie logic of real time data pull api 2025-12-12 17:22:20 +08:00
busbar_section.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
business_code.go optimize reponse code and business code of measurement sub api 2026-01-26 16:29:50 +08:00
context.go implement real time data computing api 2025-11-14 16:34:34 +08:00
deploy_mode.go optimize code of redis init 2026-01-28 16:49:12 +08:00
electrical_components.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
event.go feat: add dedicated message-exchange for task lifecycle notifications 2026-05-13 16:58:36 +08:00
log_mode.go fix bug of server deploy 2025-12-11 16:42:25 +08:00
measurement.go feat:implement search support for abbreviated token ranges (e.g., token4-token7) 2025-12-15 16:49:38 +08:00
message.go feat: add dedicated message-exchange for task lifecycle notifications 2026-05-13 16:58:36 +08:00
recommend_keys.go optimize the logic for loading the cache of measurement nodes for traversing components 2025-12-25 17:17:20 +08:00
redis.go optimize code of measurement recommend and logger output 2025-10-15 17:08:32 +08:00
response_code.go optimzie code of constants package 2026-01-16 17:08:28 +08:00
rtdata_subscription.go optimize code of redis connenct func and real time data calculate 2026-01-27 17:41:17 +08:00
task.go Refactor: extract task constants to dedicated constants package 2026-04-22 17:20:26 +08:00
telemetry_imit.go add constants varibale of power system events 2026-02-12 17:09:08 +08:00
time.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
togologic.go feat(token-parse): 1. add func of parse token 2.add func of query grid、zone、station、component 3.modify package of constant 2025-08-05 15:20:07 +08:00
trace.go refactor: migrate trace propagation from B3 to W3C TraceContext - switch OTel propagator from b3.New() to propagation.TraceContext{} - rename B3 header constants to generic internal context keys 2026-05-07 16:43:34 +08:00