434 Commits

Author SHA1 Message Date
liyuxi 5d195d5cb1 fix download log coredump 2023-02-02 06:49:49 +00:00
fengzero e7fc946ae6 type: string limit 512byte 2023-01-16 06:39:47 +00:00
eeff 639e8fb9ab feat(monitor): add node state metrics 2023-01-11 11:00:40 +08:00
fengzero 34f0b19b81 add timestamp in trans_data 2022-12-30 01:43:06 +00:00
fengzero 3ad96be5a3 fix compile warning 2022-12-29 03:32:24 +00:00
fengzero cef60d01c2 2308 code 2022-11-30 05:51:48 +00:00
fengzero b5c3c28622 create timer with plugin parameter 2022-11-30 03:30:10 +00:00
fengzero 0a2e6cb723 event: timer type block/noblock 2022-11-30 03:14:54 +00:00
eeff 4072c67e79 feat(mqtt-client): refactor set cache interface 2022-11-29 17:30:48 +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
fengzero 3ed84459a9 chore(arg): default log level 2022-11-28 07:16:53 +00:00
eeff 514e232c58 feat(mqtt-client): add neu_mqtt_client_get_cached_msgs_num 2022-11-28 14:41:49 +08:00
fengzeroz 5e980ccd07 Merge pull request #932 from eeff/eeff/dev
feat(mqtt-client): refactor publish/subscribe interface
2022-11-28 10:25:15 +08:00
eeff afe11b7a73 feat(mqtt-client): refactor publish/subscribe interface 2022-11-27 19:25:35 +08:00
fengzero 327bda38c3 new type 2022-11-25 10:55:21 +00:00
fengzero adfd29d02a chore: tag/node/group name length 2022-11-22 07:42:19 +00:00
eeff e14b012b68 feat(mqtt-client): add method neu_mqtt_client_set_id 2022-11-21 12:07:22 +08:00
eeff 341c54d388 feat(mqtt-client): update client interface
1. Change constructor neu_mqtt_client_new to take only version argument
  2. Add constructor new_mqtt_client_from_addr
  3. Add method neu_mqtt_client_set_addr
2022-11-18 16:36:10 +08:00
lixiumei123 d2b85071a1 add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt 2022-11-16 08:44:43 +00:00
eeff 8d2e533492 feat(mqtt-client): implement subscribe method 2022-11-15 18:02:12 +08:00
eeff a7f8678940 fix(mqtt-client): not sqlite caching when cache limit is zero 2022-11-15 00:23:44 +08:00
eeff 4ca5b5ad37 feat: add mqtt client 2022-11-14 16:52:59 +08:00
eeff 47ce1132d0 feat: move mqtt_client_intf stuff from base to plugin mqtt 2022-11-14 14:40:54 +08:00
eeff 611f3586e9 fix: function neu_json_decode_new and neu_parse_param 2022-11-14 10:23:58 +08:00
fengzero 64d5407c05 fix tag name limit 2022-11-10 10:15:40 +00:00
fengzero 700131614b metric: add counter_set 2022-11-10 03:24:44 +00:00
fengzero 3a9e4b888d connection: statics of bytes sent and recvied 2022-11-10 02:29:52 +00:00
fengzero 9ca8edd307 chore: reduce the cache expiration time 2022-11-09 06:51:29 +00:00
fengzero bccbf6082d fix: global_timestamp 2022-11-07 08:36:04 +00:00
fengzero bab2a82469 improve(timestamp): remove update timestamp from adapter 2022-11-04 06:56:31 +00:00
fengzeroz 3403a3e3df Merge pull request #879 from eeff/eeff/refactor
fix: replace `group_send_msgs_total` with `group_last_send_msgs`
2022-11-01 14:00:41 +08:00
eeff f95f2f56d5 fix: replace group_send_msgs_total with group_last_send_msgs 2022-11-01 12:00:46 +08:00
fengzeroz 1c7e6b2ddc Merge pull request #877 from eeff/eeff/refactor
feat(monitor): add constant NEU_METRIC_LAST_RTT_MS_MAX
2022-10-31 18:02:13 +08:00
eeff 650c41ee34 feat(monitor): add constant NEU_METRIC_LAST_RTT_MS_MAX 2022-10-31 17:40:17 +08:00
fengzero da4ca6597e api: get tags filter by tag name 2022-10-31 06:40:08 +00:00
lixiumei123 03ef8add7e fix(api): automatically switch to default log level 2022-10-27 10:16:14 +00:00
fengzeroz af29f27a66 Merge pull request #870 from eeff/eeff/refactor
Adapter callbacks: `register_metric` and `update_metric`
2022-10-27 17:45:04 +08:00
eeff b0e290ea86 feat: adapter callback update_metric add group name param 2022-10-27 15:30:44 +08:00
eeff 9f2fade755 feat: add adapter register_metric callback 2022-10-26 18:15:14 +08:00
fengzeroz 8e3fba46e1 Merge pull request #864 from eeff/eeff/refactor
feat(monitor): add app node metrics
2022-10-26 15:07:17 +08:00
eeff fe7601a7ac feat(monitor): add app node metrics 2022-10-26 14:07:14 +08:00
fengzeroz 81531e821d Merge pull request #863 from eeff/eeff/refactor
feat(monitor): handling driver group metrics generation
2022-10-26 10:28:59 +08:00
eeff f1a82ed529 feat(monitor): handling driver group metrics generation 2022-10-25 23:47:32 +08:00
fengzeroz 522ad2faf3 Merge pull request #857 from fengzeroz/main
modify api of get nodes & fix connection recv
2022-10-25 10:38:20 +08:00
eeff 1f0445712e feat(monitor): handling driver metrics generation 2022-10-24 18:32:03 +08:00
fengzero 1f3bc7af37 api: get nodes filter by plugin/node 2022-10-24 06:41:32 +00:00
eeff 04da8039f8 refactor: monitor global metrics generation 2022-10-21 18:13:56 +08:00