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 |
|