 eeff
|
88d1de415a
|
chore: enlarge ekuiper plugin send/recv queue length
|
2022-11-03 18:09:17 +08:00 |
|
|
fengzero
|
49636caebb
|
fix(ekuiper): float/double precision
|
2022-10-28 05:42:45 +00:00 |
|
|
fengzero
|
23be6a9e1f
|
chore(manager): remove notify app sub/unsub
|
2022-08-24 05:53:22 +00:00 |
|
|
fengzero
|
fa46c6b493
|
feat(plugin): plugin adds a single field
single: indicating that the plugin can only be instantiated once.
|
2022-08-19 07:31:12 +00:00 |
|
|
eeff
|
a793b8ed8b
|
fix: ekuiper start error code
|
2022-07-07 11:00:47 +08:00 |
|
|
eeff
|
282ca37050
|
ci: remove cppcheck errors
|
2022-07-04 22:49:58 +08:00 |
|
|
eeff
|
48b6913e18
|
refactor(ekuiper): use plugin common timestamp
|
2022-06-23 16:11:44 +08:00 |
|
|
eeff
|
5264a42546
|
fix(ekuiper): read signed number
|
2022-06-22 14:05:45 +08:00 |
|
|
fengzero
|
566487d1f8
|
add NEU_RESP_APP_SUBSCRIBE_GROUP msg nofity app subscribe group
|
2022-06-20 09:57:26 +00:00 |
|
|
eeff
|
7b842956bb
|
chore(ekuiper): uniform logging using plog macros
|
2022-06-20 13:15:19 +08:00 |
|
|
fengzero
|
1e29e4cb1c
|
remove plugin_info.h & adapter_msg.h
|
2022-06-17 07:02:32 +00:00 |
|
|
eeff
|
26a5d7b922
|
chore(ekuiper): make log message more clear
|
2022-06-17 14:27:45 +08:00 |
|
|
fengzero
|
53ceeac9ff
|
del unused errorcode
|
2022-06-16 10:04:04 +00:00 |
|
|
fengzero
|
e93e517f95
|
refactor CmakeLists.txt
|
2022-06-15 09:45:07 +00:00 |
|
|
fengzero
|
f44a8db699
|
plugin: remove argument in open()
|
2022-06-15 06:49:02 +00:00 |
|
|
fengzero
|
2d38ae5f50
|
refactor plugin interface config
|
2022-06-15 06:40:30 +00:00 |
|
|
fengzero
|
95db2396ba
|
feat(msg): notify app subscribe/unsubscribe info
|
2022-06-14 09:13:21 +00:00 |
|
|
eeff
|
3a8cc645ed
|
chore: update ekuiper plugin to use new log interface
|
2022-06-14 15:25:46 +08:00 |
|
|
eeff
|
449e1bdf1a
|
fix(ekuiper): use mutex instead of C11 atomic
|
2022-06-13 11:07:52 +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
|
38a2652930
|
remove vector and data_expr
|
2022-06-10 04:43:05 +00:00 |
|
|
fengzero
|
c8234633e0
|
add/del/get group
|
2022-06-10 04:43:05 +00:00 |
|
|
fengzero
|
4a1a34de43
|
simplify the plugin type to driver and app
|
2022-05-30 02:45:17 +00:00 |
|
|
fengzero
|
a7781b63ce
|
log: replace log with zlog
|
2022-05-28 09:27:52 +00:00 |
|
|
eeff
|
8ef762313a
|
fix: ekuiper plugin link state reporting
|
2022-05-17 09:38:38 +08:00 |
|
|
eeff
|
307cf84041
|
feat: update ekuiper plugin to handle write request
|
2022-04-15 18:03:20 +08:00 |
|
|
eeff
|
dc52d25d4f
|
feat: add ekuiper plugin json decoding utilities
|
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 |
|
|
eeff
|
62c93d3574
|
feat: add ekuiper json encoding utilities
|
2022-04-13 17:07:51 +08:00 |
|
|
eeff
|
b8ecf26b25
|
refactor: move ekuiper plugin struct into header file
|
2022-04-13 15:26:38 +08:00 |
|
|
eeff
|
ee2695acd2
|
Add plugin skeleton for ekuiper
|
2022-04-12 12:01:06 +08:00 |
|