53 Commits
Author SHA1 Message Date
eeff 125bdbd2b2 fix(mqtt): update trans_data metric only when plugin is started 2024-05-29 14:42:09 +08:00
eeff 6b24d4bf7a fix(mqtt): handle NEU_REQ_DEL_GROUP 2024-03-05 18:06:44 +08:00
eeff 59f1f5d97d feat(mqtt): add rolling metrics 2024-02-04 15:56:21 +08:00
fengzero 7e34947c8a chore: remove neuron in description 2023-11-10 09:50:39 +00:00
fengzero bf4acdfb85 feat(core): trans_data msg are sent using a separate channel 2023-10-08 06:59:07 +00:00
eeff 2b3690826f fix(mqtt): handle group update 2023-09-01 11:55:55 +08:00
eeff efc7ece5d8 fix(mqtt): handle driver delete 2023-08-31 15:02:21 +08:00
eeff 5d781a1340 fix(mqtt): handle driver name update 2023-08-31 14:41:17 +08:00
fengzero 5c0c6f6e06 core: neu_type_ptr 2023-08-24 06:09:18 +00:00
eeff 6b96510f9e fix(mqtt): cache-sync-interval setting default to 100 when cache disabled 2023-08-23 16:42:38 +08:00
fengzero 85ec40684a check license when add node/tag 2023-08-18 09:20:24 +00:00
eeff 3430e1a14b feat(mqtt): add cache-sync-interval setting 2023-08-15 17:46:20 +08:00
eeff 1e296a5872 feat(mqtt): handle subscription update 2023-08-02 18:07:48 +08:00
eeff 149093fa7a fix: send update license request to all type of adapters 2023-06-07 17:54:33 +08:00
eeff 07aecc7d7b chore(mqtt): update log level 2023-05-17 16:11:05 +08:00
eeff cc4a10eb63 feat(mqtt): make CA parameter optional 2023-05-08 17:09:45 +08:00
eeff bc6cb180e6 feat(mqtt): use write-req-topic and write-resp-topic 2023-05-05 18:18:36 +08:00
eeff 41225edd75 feat(mqtt): use QoS setting for message delivery 2023-03-20 12:27:52 +08:00
eeff 8dfd6191c0 fix(mqtt): create topic mistakes 2023-01-17 23:31:46 +08:00
eeff afa0e52d43 feat(mqtt): pub data to NEU_REQ_SUBSCRIBE_GROUP message specified topic 2023-01-11 11:13:29 +08:00
liyuxi db68b8e2d4 fix plugin name 2023-01-04 07:24:04 +00: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 6bba7d4ab6 remove sub msg 2022-12-20 07:08:01 +00: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
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
lixiumei123 d2b85071a1 add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt 2022-11-16 08:44:43 +00:00
eeff 8894132897 chore: rename mqtt_client_intf symbols 2022-11-14 16:52:59 +08:00
gc87 18481a4faa fix: remove timer for checking connection status 2022-09-06 11:23:54 +08:00
gc87 638effaca3 fix: move memory cache to the plugin(node) 2022-09-02 18:50:50 +08:00
gc87 722632f6d6 feat(mqtt): add cache setting to ui & webapi 2022-08-29 22:49:25 +08:00
gc87 cd3c9213f6 fix(mqtt): add cache send & fix cache bug 2022-08-29 21:09:24 +08:00
gc87 610745e35d feat: add memory cache to mqtt plugin 2022-08-28 23:30:50 +08:00
gc87 84d8acac29 fix(mqtt): add config validate 2022-08-25 18:09:14 +08:00
gc87 0b36f3a57e fix(mqtt): rm unused code about topic 2022-08-25 18:09:14 +08:00
gc87 caff948cd6 refactor: rm clientid & make topic field required 2022-08-25 18:09:14 +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
gc87 bcd5fc15f7 fix: new msg handle for node state 2022-08-19 09:44:54 +08:00
fengzero de26f6518c chore(adapter): add node_deleted and get_all_tags msg 2022-08-17 10:22:12 +00:00
fengzero 3d87ab63da chore(connection): remove connecting state 2022-08-16 06:24:02 +00:00
fengzero 7f9d4cd84c feat(driver): set float precision 2022-08-10 10:30:38 +00:00
fengzero 4f8263d8f3 feat(manager): send nodes state periodically 2022-08-01 08:48:26 +00:00
gc87 8cf9ba95f8 refactor(mqtt): static alloc -> dynamic alloc 2022-07-29 15:52:39 +08:00
gc87 fbd8f267cf fix(mqtt): crash caused by global static variables 2022-07-27 17:34:45 +08:00
gc87 93fbc3eaa5 refactor(mqtt): update module description 2022-07-19 17:51:27 +08:00
gc87 b820d74796 fix(mqtt): free ctx if msg send error 2022-07-18 18:24:26 +08:00
gc87 9d3b411627 fix(mqtt): setting free
* Add unit test for setting
* Set mqtt.json format field to optinal
2022-07-15 14:39:57 +08:00