35 Commits

Author SHA1 Message Date
fengzero c639b8c508 ekuiper: filters no tags write 2026-07-22 06:15:29 +00:00
fengzero 88ed1af382 fix double free 2026-07-01 09:06:07 +00:00
fengzero b3e0e4d623 replace strcpy with snprintf 2026-07-01 03:56:13 +00:00
fengzero 0e2c8dbdb5 refactor: replace strcpy with strncpy 2026-06-02 08:39:50 +00:00
xiang.zhou bd65073a35 ekuiper:add warn log 2025-11-19 16:37:42 +08:00
xiang.zhou 67ed390737 ekuiper:add log 2025-11-19 10:49:00 +08:00
xiang.zhou fb0bcbf116 refactor the array type 2025-05-21 14:19:03 +08:00
xiang.zhou 193b4b96e1 otel:span optimization 2025-05-08 12:39:36 +08:00
xiang.zhou d21131f584 ekuiper:check encode json str 2024-11-29 13:22:30 +08:00
fengzero 8d90cb7d08 support array type 2024-11-06 10:44:21 +00:00
xiang.zhou 51333961d6 otel:support ns and add span status 2024-10-16 10:18:25 +08:00
xiang.zhou a4f2671867 otel:add api and use new api 2024-10-16 10:18:18 +08:00
xiang.zhou 6fa636f45d feat(otel):add sample support 2024-09-23 15:15:42 +08:00
xiang.zhou 9095e3bd32 feat(otel):comm rest api,mqtt,ekuiper 2024-09-10 14:54:29 +08:00
eeff 0b67a088c1 feat(ekuiper): support write multiple tags 2024-04-12 09:44:08 +08:00
eeff f831e71ad3 fix(ekuiper): check received aio data race 2024-03-26 10:29:47 +08:00
eeff f197f574a0 feat(ekuiper): add rolling metrics 2024-02-04 16:49:00 +08:00
eeff 297b9b151d refactor: reduce write tag messages size 2023-11-15 18:20:43 +08:00
fengzero 88a96c63fd core/modbus: support bytes 2023-08-25 09:15:58 +00:00
eeff 82664aaf74 chore: enlarge ekuiper plugin send/recv queue length 2022-11-03 18:00:47 +08:00
eeff b0e290ea86 feat: adapter callback update_metric add group name param 2022-10-27 15:30:44 +08:00
eeff 27d7b2d4d5 refactor: node metrics data structures 2022-10-20 17:15:58 +08:00
eeff ea16f54691 feat(ekuiper): update node send/receive bytes and messages statistics 2022-09-08 14:51:21 +08:00
eeff 7b842956bb chore(ekuiper): uniform logging using plog macros 2022-06-20 13:15:19 +08:00
eeff 26a5d7b922 chore(ekuiper): make log message more clear 2022-06-17 14:27:45 +08:00
eeff 3a8cc645ed chore: update ekuiper plugin to use new log interface 2022-06-14 15:25:46 +08:00
eeff 9c7e0329b1 fix(ekuiper): only send data when connected 2022-06-10 18:12:43 +08:00
eeff 5e312674c3 refactor: plugin ekuiper write data using new interface 2022-06-10 13:04:09 +08:00
eeff 336391014b refactor: ekuiper plugin send data using new interface 2022-06-10 13:04:09 +08:00
fengzero dc65873e93 async process op msg 2022-06-10 04:43:06 +00:00
fengzero c8234633e0 add/del/get group 2022-06-10 04:43:05 +00:00
fengzero a7781b63ce log: replace log with zlog 2022-05-28 09:27:52 +00:00
eeff 307cf84041 feat: update ekuiper plugin to handle write request 2022-04-15 18:03:20 +08:00
eeff 809a22d449 fix: ekuiper plugin send json data without terminating null byte 2022-04-15 18:03:20 +08:00
eeff fe80d9c6b4 feat: update ekuiper plugin to forward trans data 2022-04-13 17:07:51 +08:00