2734e40f8f
fix timestamp
2022-10-21 06:39:12 +00:00
658779c28f
refactor(mqtt): improved mqtt schema description
2022-09-14 09:53:07 +08:00
bdaba2c339
fix(api): fix double type precision
2022-09-06 09:13:04 +00:00
18481a4faa
fix: remove timer for checking connection status
2022-09-06 11:23:54 +08:00
638effaca3
fix: move memory cache to the plugin(node)
2022-09-02 18:50:50 +08:00
722632f6d6
feat(mqtt): add cache setting to ui & webapi
2022-08-29 22:49:25 +08:00
cd3c9213f6
fix(mqtt): add cache send & fix cache bug
2022-08-29 21:09:24 +08:00
610745e35d
feat: add memory cache to mqtt plugin
2022-08-28 23:30:50 +08:00
2bdb38129c
feat: add memory cache unit test
2022-08-28 20:07:57 +08:00
c2a136a6a6
feat: memory cache implemented
2022-08-27 22:15:29 +08:00
e888e8adaf
feat: add mem cache for tran data store
2022-08-26 16:57:33 +08:00
84d8acac29
fix(mqtt): add config validate
2022-08-25 18:09:14 +08:00
c1adf27a13
fix(mqtt): make ssl field optional
2022-08-25 18:09:14 +08:00
0b36f3a57e
fix(mqtt): rm unused code about topic
2022-08-25 18:09:14 +08:00
c7f5e5da59
fix(mqtt): use short client id
2022-08-25 18:09:14 +08:00
caff948cd6
refactor: rm clientid & make topic field required
2022-08-25 18:09:14 +08:00
23be6a9e1f
chore(manager): remove notify app sub/unsub
2022-08-24 05:53:22 +00:00
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
bcd5fc15f7
fix: new msg handle for node state
2022-08-19 09:44:54 +08:00
de26f6518c
chore(adapter): add node_deleted and get_all_tags msg
2022-08-17 10:22:12 +00:00
3d87ab63da
chore(connection): remove connecting state
2022-08-16 06:24:02 +00:00
7f9d4cd84c
feat(driver): set float precision
2022-08-10 10:30:38 +00:00
4f8263d8f3
feat(manager): send nodes state periodically
2022-08-01 08:48:26 +00:00
8cf9ba95f8
refactor(mqtt): static alloc -> dynamic alloc
2022-07-29 15:52:39 +08:00
fbd8f267cf
fix(mqtt): crash caused by global static variables
2022-07-27 17:34:45 +08:00
93fbc3eaa5
refactor(mqtt): update module description
2022-07-19 17:51:27 +08:00
b820d74796
fix(mqtt): free ctx if msg send error
2022-07-18 18:24:26 +08:00
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
094dc7f122
refactor(mqtt): nng timer -> event timer
2022-07-15 13:51:02 +08:00
3c59046314
feat(mqtt): setting optional field
2022-07-15 13:51:02 +08:00
96992eff71
refactor(mqtt): Modify unreasonable code
...
* Modify header file ordering
* Modify mqtt.* to mqtt_*.* to avoid ide parsing exception
* Modify part of the code according to the pr revision comments
2022-07-15 13:51:02 +08:00
596cd699fd
feat(mqtt): state json string send
2022-07-15 13:51:02 +08:00
1f9e3ea0db
feat(mqtt): add node state cache & add hb command
2022-07-15 13:51:02 +08:00
1c9d6a4b68
feat(mqtt): add heartbeat timer
2022-07-15 13:51:02 +08:00
649de85b61
feat(mqtt): add heartbeat setting
2022-07-15 13:51:02 +08:00
a2c9da83b8
fix(mqtt): connection in stoped state
2022-07-01 14:28:57 +08:00
23b83b7df2
refactor(mqtt): gettimeofday-> common.timestamp
2022-06-24 09:45:07 +08:00
b7881b4b93
fix(mqtt): write response topic error
2022-06-22 10:30:10 +08:00
d47ea13594
feat(mqtt): add zlog with cat to mqtt_c_client.c
2022-06-21 10:51:31 +08:00
566487d1f8
add NEU_RESP_APP_SUBSCRIBE_GROUP msg nofity app subscribe group
2022-06-20 09:57:26 +00:00
993530f86b
refactor persist & adapter msg
2022-06-20 08:08:40 +00:00
41dec9b209
fix(mqtt): plog to mqtt
2022-06-17 18:46:30 +08:00
5e16738a23
fix(mqtt): double free and context leak
2022-06-17 17:57:14 +08:00
341bdfd61f
Merge pull request #557 from gc87/mqtt-queue-remove
...
refactor(mqtt): remove sys/queue.h deps
2022-06-17 15:25:15 +08:00
1e29e4cb1c
remove plugin_info.h & adapter_msg.h
2022-06-17 07:02:32 +00:00
fe98452624
refactor(mqtt): remove sys/queue.h deps
2022-06-17 15:01:28 +08:00
dcb17c80cb
Merge pull request #553 from gc87/mqtt-queue-remove
...
Disconnect on user send stop command
2022-06-17 14:50:21 +08:00
67f0c2b2f0
rename tag address and replace neu_dtype_e
2022-06-17 03:48:51 +00:00
6881025f79
fix(mqtt): string leak
2022-06-16 18:45:32 +08:00
7da3b7b50a
feat(mqtt): stop/start -> disconnect/reconnect
2022-06-16 18:45:32 +08:00
fengzero