Commit Graph
673 Commits
Author SHA1 Message Date
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
fengzeroz cc768c3dfa Merge pull request #1010 from eeff/eeff/dev
feat(monitor): add cpu utilisation metric
2022-12-30 15:02:57 +08:00
eeff 99ab71c63d feat(monitor): add cpu utilisation metric 2022-12-29 15:56:01 +08:00
liyuxi 6c398c803a add write function for file plugin 2022-12-29 05:54:58 +00:00
eeff 0404ff4688 feat(monitor): add disk usage metrics 2022-12-28 23:13:02 +08:00
eeff bbb6b1f800 feat(monitor): add memory metrics 2022-12-28 16:17:49 +08:00
eeff 297fa37bf5 feat(monitor): add distro and kernel info 2022-12-28 11:14:24 +08:00
liyuxi a6741f23e9 fix(file plugin):fix format 2022-12-26 08:48:38 +00:00
liyuxi dd05082f9a added plugin for reading files 2022-12-26 08:42:11 +00:00
fengzero 6bba7d4ab6 remove sub msg 2022-12-20 07:08:01 +00:00
fengzeroz 1ce151176c Merge pull request #987 from eeff/eeff/dev
chore: remove unused websocket code
2022-12-20 10:24:02 +08:00
fengzero 21ec914b4e metric api: remove verify 2022-12-20 02:21:40 +00:00
eeff 6b33d5a83e chore: remove unused websocket code 2022-12-19 17:40:30 +08:00
fengzeroz 380b9ae885 Merge pull request #982 from eeff/eeff/dev
feat(mqtt): remove setting/publishing `heartbeat-topic`
2022-12-15 14:01:59 +08:00
eeff 96aa7cd69f fix: monitor plugin memory leak 2022-12-15 10:40:22 +08:00
eeff c08a895b0a feat(mqtt): remove setting/publishing heartbeat-topic 2022-12-14 16:42:07 +08:00
eeff 08efaf5b99 fix: mqtt plugin memory leak 2022-12-13 16:32:53 +08:00
eeff 063ae46e9c feat(monitor): add heartbeat monitoring 2022-12-13 15:27:45 +08:00
eeff 8f5999995b feat(monitor): add mqtt handle 2022-12-13 14:19:20 +08:00
eeff ee04a9b0fe feat(monitor): add setting heartbeat-interval 2022-12-12 18:06:25 +08:00
eeff 9376f8dbdd feat(monitor): add mqtt client 2022-12-12 17:07:47 +08:00
eeff d541255938 feat(monitor): add setting 2022-12-10 12:24:52 +08:00
eeff fdae3b977f feat: make builtin monitor as a dynamic singleton plugin 2022-12-09 11:01:11 +08:00
eeff 66c2bce7f0 feat: put utils/http_handler.h functions in namespace neu 2022-12-08 12:26:03 +08:00
eeff 942b361109 feat: move handle.h from restful plugin to neuron base 2022-12-08 12:24:02 +08:00
eeff ec019a71e6 feat: put utils/http.h functions in namespace neu 2022-12-07 18:19:52 +08:00
eeff 07411406a6 feat: move http.h from restful plugin to neuron base 2022-12-07 18:19:52 +08:00
lixiumei123 e3124b354d remove the top-level directory for download logs 2022-12-01 06:55:51 +00:00
fengzero 4ceacb2764 new type: WORD/DWORD/LWORD 2022-12-01 05:42:10 +00:00
gc87 ee344f9509 refactor(mqtt): make nanomqtt plugin default 2022-11-30 09:56:15 +08:00
gc87 b5fd6ea692 refactor(mqtt): rm all old mqtt source file
- Delete the mqtt plugin implemented based on mqtt-c
2022-11-29 20:59:57 +08:00
eeff f4b7b0356d feat(nano-mqtt): split cache limit into cache memory and cache disk size 2022-11-29 17:34:57 +08:00
eeff 84ab19c632 fix(nano-mqtt): avoid segfault 2022-11-29 17:28:43 +08:00
fengzeroz 9c62e847cc Merge pull request #942 from eeff/eeff/dev
fix(mqtt-client): avoid data condition
2022-11-28 18:00:40 +08:00
eeff 738ec1fa7f fix(mqtt-client): avoid data condition 2022-11-28 17:53:12 +08:00
fengzeroz 7d98d81bd8 Merge pull request #936 from eeff/eeff/dev
feat(nano-mqtt): update cached messages metric
2022-11-28 17:14:58 +08:00
fengzero 2c9a267800 metric api: verify jwt 2022-11-28 09:06:53 +00:00
eeff 323f4cd7d5 feat(nano-mqtt): update cached messages metric 2022-11-28 14:41:49 +08:00
eeff f5e6f5c449 feat(nano-mqtt): update metrics 2022-11-27 19:25:35 +08:00
eeff afe11b7a73 feat(mqtt-client): refactor publish/subscribe interface 2022-11-27 19:25:35 +08:00
eeff 75083e65ba fix(mqtt-client): connect with correct url w/wo tls 2022-11-23 11:43:46 +08:00
eeff 910a3090db feat(nano-mqtt): add client-id setting 2022-11-21 12:07:22 +08:00
eeff c08130b836 fix(nano-mqtt): connect to the correct host when reconfigured 2022-11-18 16:38:59 +08:00
eeff c76feca0e6 fix(restful): handle mqtt error codes 2022-11-18 15:21:09 +08:00
eeff 2706f2b4d7 fix(nano-mqtt): keep sending messages when caching enabled 2022-11-18 15:16:16 +08:00