douxu
4d5fcbc376
Refactor async task system with unified task interfaces and add test task type
...
- Create task/types_v2.go with unified task type definitions and interfaces
* Add UnifiedTaskType and UnifiedTaskStatus constants
* Define Task:Params interface for parameter validation and serialization
* Define UnifiedTask interface as base for all task implementations
* Add BaseTask for common task functionality
2026-04-14 17:00:30 +08:00
douxu
9e4c35794c
implemented task queue publishing using RabbitMQ
...
Added configuration middleware integration
Added retry logic for queue publishing
Added task worker initialization (main.go):
Created initTaskWorker function for task worker configuration
Added worker startup and shutdown logic
Added CORS middleware configuration
Registered config middleware
2026-04-01 17:15:33 +08:00
douxu
de5f976c31
add route of async task system
2026-03-17 16:08:46 +08:00
douxu
898beaeec4
optimize struct of rabbitmq event
2026-03-02 17:00:09 +08:00
douxu
2ececc38d9
optimzie code organization structure of rabbitmq event
2026-02-25 17:14:25 +08:00
douxu
9be984899c
optimize code of push event alarm func
2026-02-03 17:05:32 +08:00
douxu
3ff29cc072
optimize code of real time data pull api
2026-01-28 14:03:25 +08:00
douxu
617d21500e
optimize code of redis connenct func and real time data calculate
2026-01-27 17:41:17 +08:00
douxu
1a1727adab
optimize reponse code and business code of measurement sub api
2026-01-26 16:29:50 +08:00
douxu
fd2b202037
optimize code of websocket close handler
2026-01-22 16:19:00 +08:00
douxu
e1886bc347
optimize code of judge wether success or failed return content
2026-01-19 16:39:35 +08:00
douxu
ba5e5b3d1c
optimzie code of constants package
2026-01-16 17:08:28 +08:00
douxu
d3b1f0afbe
add code of send all target removed system signal in real time data pull api and fix bug of component attribute query api
2026-01-14 17:32:01 +08:00
douxu
cf880279e4
optimize real time data query api
2026-01-13 17:23:47 +08:00
douxu
d75b9a624c
optimize handler of compoent attribute query api
2026-01-13 11:39:00 +08:00
douxu
cceffa8219
add handler of compoent attribute query api
2026-01-12 17:21:04 +08:00
douxu
d1495b7ab8
optimize code of component attribute update api
2026-01-09 17:26:45 +08:00
douxu
60eab0675e
optimize code of component attrbute update api
2026-01-08 17:34:44 +08:00
douxu
f47e278f85
fix bug of first subscription different interval measurement data
2026-01-07 17:28:09 +08:00
douxu
a31bd6f395
add component attribute group update api and optimzie diagram hash set params
2026-01-05 17:20:41 +08:00
douxu
51f65500f3
add func of init component measurement recommend
2025-12-24 16:55:55 +08:00
douxu
9499e579b3
optimize code of sql struct and measurement node recommend api
2025-12-19 17:33:12 +08:00
douxu
0add3cf6db
feat:implement search support for abbreviated token ranges (e.g., token4-token7)
2025-12-15 16:49:38 +08:00
douxu
c92cee9575
optimzie logic of real time data pull api
2025-12-12 17:22:20 +08:00
douxu
2a3852a246
add diagram node link process api
2025-12-10 16:12:13 +08:00
douxu
f48807e5e5
optimize measurement link api
2025-12-08 17:01:24 +08:00
douxu
3f70be0d1c
fix bug of new version of measurement recommend api
2025-12-06 18:32:00 +08:00
douxu
46e72ce588
optimize redis test data lua shell
2025-12-04 17:26:35 +08:00
douxu
b99c03296a
optimize measurement recommend api
2025-12-03 16:55:14 +08:00
douxu
8a4116879b
add real time data measurement target update func
2025-12-02 17:26:15 +08:00
douxu
fca6905d74
optimize real time data pulling and subscription api
2025-11-27 16:59:03 +08:00
douxu
6f3134b5e9
optimize struct of real time data subscription api and fix bug of real time data pull api
2025-11-26 17:49:24 +08:00
douxu
b6e47177fb
debugging API using single measurement point subscription case
2025-11-25 16:13:55 +08:00
douxu
d434a7737d
optimize variable naming and init real time data compute func
2025-11-13 17:29:49 +08:00
douxu
984ee3003d
optimize variable naming and api swagger comment
2025-11-13 11:48:26 +08:00
douxu
041d7e5788
optimize variable naming and optimize real time data computing api
2025-11-12 17:34:18 +08:00
douxu
b43adf9b67
optimize logger info of real time data subscription api
2025-11-11 17:45:36 +08:00
douxu
a82e02126d
extracting duplicate code snippets to form a common function
2025-11-11 17:37:06 +08:00
douxu
93d1eea61f
optimize sendRealTimeDataStream of real time data pull api
2025-11-11 11:50:25 +08:00
douxu
8d6efe8bb1
optimize real time data pull api
2025-11-10 17:32:18 +08:00
douxu
6de3c5955b
optimize real time data pull api
2025-11-08 17:11:45 +08:00
douxu
8090751914
optimize update monitor config func of real time data query api
2025-11-06 17:22:14 +08:00
douxu
b75358e676
optimize first create monitor config func of real time data query api
2025-11-05 18:20:54 +08:00
douxu
f5ea909120
optimize real time data query api
2025-11-04 17:12:15 +08:00
douxu
594dc68ab1
create api of real time data monitor
2025-11-03 17:35:03 +08:00
douxu
2584f6dacb
optimize real time data query api
2025-10-28 16:59:16 +08:00
douxu
09700a86ee
optimize real time data receive api
2025-10-27 16:47:04 +08:00
douxu
954203b84d
optimize real time data query api
2025-10-24 16:52:14 +08:00
douxu
458f7afdbf
optimize doc of measurement recommend api
2025-10-20 17:30:55 +08:00
douxu
54128bedac
fix bug of measurement recommend api
2025-10-20 15:06:23 +08:00
douxu