fengzero
|
7c2b405164
|
check license when add node/tag
|
2023-08-18 09:12:41 +00:00 |
|
eeff
|
0fde678e1e
|
fix(ekuiper): check setting host and port is available
|
2023-06-27 15:23:25 +08:00 |
|
fengzero
|
4472c2aeb1
|
Revert "fix(ekuiper): check ip address listenable"
This reverts commit 3fcbe3f7b7.
|
2023-06-16 10:47:06 +00:00 |
|
eeff
|
3fcbe3f7b7
|
fix(ekuiper): check ip address listenable
|
2023-06-14 17:36:52 +08:00 |
|
eeff
|
149093fa7a
|
fix: send update license request to all type of adapters
|
2023-06-07 17:54:33 +08:00 |
|
eeff
|
bcfb4dc454
|
chore(ekuiper): update log level
|
2023-05-17 17:06:59 +08:00 |
|
fengzero
|
cb261468dd
|
improve schema field name/description
|
2023-03-14 03:49:23 +00:00 |
|
eeff
|
a2b6e5c6dd
|
feat(ekuiper): host setting default to 0.0.0.0
|
2023-03-01 14:53:14 +08:00 |
|
eeff
|
bc94a94aab
|
fix(ekuiper): memory leak on NEU_REQ_SUBSCRIBE_GROUP
|
2023-03-01 00:28:33 +08:00 |
|
eeff
|
9feb204f3d
|
chore: reduce eKuiper plugin log level
|
2023-03-01 00:24:07 +08:00 |
|
eeff
|
3ec7a4588c
|
feat(ekuiper): remove singleton
|
2023-02-13 18:37:43 +08:00 |
|
fengzero
|
13760bf12c
|
chore(log): modify log level
|
2023-02-02 06:18:23 +00:00 |
|
liyuxi
|
db68b8e2d4
|
fix plugin name
|
2023-01-04 07:24:04 +00:00 |
|
fengzeroz
|
97884ecb6a
|
Merge pull request #1018 from eeff/eeff/dev
feat(ekuiper): switch from ipc to tcp transport
|
2023-01-04 15:02:21 +08:00 |
|
eeff
|
66e4f9f300
|
feat(ekuiper): switch from ipc to tcp transport
|
2023-01-04 11:54:27 +08:00 |
|
eeff
|
68faa67742
|
fix(ekuiper): memory leak
|
2023-01-04 11:48:38 +08:00 |
|
liyuxi
|
206fc8b59f
|
fix getting schema api
|
2023-01-04 03:36:55 +00:00 |
|
liyuxi
|
f63ded6847
|
add(schema):add schema field in getting plugins api
|
2023-01-03 10:01:25 +00:00 |
|
fengzero
|
4ceacb2764
|
new type: WORD/DWORD/LWORD
|
2022-12-01 05:42:10 +00:00 |
|
lixiumei123
|
d2b85071a1
|
add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt
|
2022-11-16 08:44:43 +00:00 |
|
fengzero
|
bab2a82469
|
improve(timestamp): remove update timestamp from adapter
|
2022-11-04 06:56:31 +00:00 |
|
eeff
|
82664aaf74
|
chore: enlarge ekuiper plugin send/recv queue length
|
2022-11-03 18:00:47 +08:00 |
|
fengzero
|
6aa4db2ecd
|
fix(ekuiper): float/double precision
|
2022-10-28 05:48:50 +00: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
|
5da9c2a841
|
feat(ekuiper): update average rtt statistics
|
2022-09-14 16:46:35 +08:00 |
|
eeff
|
ea16f54691
|
feat(ekuiper): update node send/receive bytes and messages statistics
|
2022-09-08 14:51:21 +08: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 |
|