douxu
0 Followers · 0 Following
  • Joined on 2024-07-15
Repositories Projects Packages Public Activity Starred Repositories
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-05-11 17:34:45 +08:00
cccd4becdc feat: add Loki logging, fix MQ shutdown order, improve realtime tracing
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-05-08 16:20:06 +08:00
1dd8491440 refactor: replace EventStatusPersisted with IsPersisted field on EventRecord - add IsPersisted bool to EventRecord for explicit persistence tracking by eventRT consumer - remove EventStatusPersisted constant, decoupling DB persistence from event lifecycle status - update event status comments for accuracy and CIM-agnostic language
douxu pushed to feature-joinDebuggingDemo at CL-Softwares/eventRT 2026-05-08 15:45:57 +08:00
2f7cd5a8fc feat: add event lifecycle API and UI fanout publishing - extract event status, MQ exchange/queue, and DB name constants to constants/event.go - add bson tags and IsPersisted flag to EventRecord for proper MongoDB serialization
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-05-07 16:45:48 +08:00
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
douxu pushed to feature-joinDebuggingDemo at CL-Softwares/eventRT 2026-05-07 16:34:03 +08:00
44ded93411 feat: add OpenTelemetry distributed tracing to eventRT - add OtelConfig to EventRTConfig and configs/config.yaml - add middleware/trace.go with InitTracerProvider (W3C TraceContext) and StartTrace gin middleware
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-28 17:42:57 +08:00
9661278935 refactor: rename TaskParams to Params and remove debug prints
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-27 17:55:46 +08:00
33f7d758e5 refactor: overhaul async task handler routing and fix data consistency
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-24 17:14:58 +08:00
1b1f43db7f feat: implement topology analysis async task with BFS connectivity check
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-23 16:49:03 +08:00
03bd058558 feat: implement end-to-end distributed tracing for HTTP and async tasks
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-22 17:20:37 +08:00
809e1cd87d Refactor: extract task constants to dedicated constants package
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-17 15:12:54 +08:00
4a3f7a65bc Refactor async task handlers into specialized handlers
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-14 17:01:09 +08:00
4d5fcbc376 Refactor async task system with unified task interfaces and add test task type
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-03 10:08:01 +08:00
f8c0951a13 Extend async task system with database integration and retry management
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-04-01 17:16:24 +08:00
9e4c35794c implemented task queue publishing using RabbitMQ
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-03-20 15:00:09 +08:00
7ea66e48af add code of async task system
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-03-17 16:08:50 +08:00
de5f976c31 add route of async task system
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-03-13 11:45:26 +08:00
adcc8c6c91 add code of async task system
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-03-12 16:37:11 +08:00
6e0d2186d8 optimize code of async task system
douxu pushed to feature/bay-realtime-data-calc at CL-Softwares/modelRT 2026-03-05 17:15:55 +08:00
a94abdb479 initialize the asynchronous task system's initial structure
douxu pushed to feature-joinDebuggingDemo at CL-Softwares/eventRT 2026-03-03 17:09:35 +08:00
e0863eb04a add code of rabbitmq message ack action