20 Commits

Author SHA1 Message Date
eeff 59f1252ebb fix(ekuiper): check received aio data race 2024-03-26 21:50:45 +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