4 Commits

Author	SHA1	Message	Date
douxu	cccd4becdc	feat: add Loki logging, fix MQ shutdown order, improve realtime tracing ... - add LokiConfig and batching lokiSyncer for dev-mode direct log push - refactor zap logger to support mode-aware encoding and K8s pod fields - fix RabbitMQ shutdown race: move CloseRabbitProxy to defer so channel closes before connection (prevents 504 error on Ctrl+C) - wrap MsgChan with EventMessage to carry per-cycle trace carrier - create new root OTel span per computation cycle linked to startup span, giving each cycle an independent traceID with startup as reference	2026-05-11 17:34:27 +08:00
douxu	1ee722dd58	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 ... - remove go.opentelemetry.io/contrib/propagators/b3 dependency - add amqpHeaderCarrier to inject W3C traceparent into AMQP message headers	2026-05-07 16:43:34 +08:00
douxu	898beaeec4	optimize struct of rabbitmq event	2026-03-02 17:00:09 +08:00
douxu	4b52e5f3c6	optimize code of event record and push rabbitmq func	2026-02-28 17:38:33 +08:00