996c62a75d
chore(connection): stop/start connection
2022-08-18 09:21:20 +00:00
79665e140b
fix(http): remove aio timeout
2022-08-12 05:44:11 +00:00
ed1dca302c
fix: http aio cancel fn
2022-08-01 02:58:07 +00:00
83233ace32
chore: log aio error
2022-08-01 02:52:11 +00:00
632915b4ae
fix(mqtt): crash caused by global static variables
2022-07-27 17:22:07 +08:00
7ebb391ab2
Merge pull request #655 from gc87/branch-mqtt
...
refactor(mqtt): update module description
2022-07-21 09:53:13 +08:00
b55b9a5556
Merge pull request #656 from eeff/eeff/dev
...
Revert "feat(restful): enable websocket logging"
2022-07-21 09:49:17 +08:00
e19923b131
Revert "feat(restful): enable websocket logging"
...
This reverts commit 0ed6b39b28
2022-07-19 18:31:36 +08:00
93fbc3eaa5
refactor(mqtt): update module description
2022-07-19 17:51:27 +08:00
5cece84ca9
fix(http): aio timeout
2022-07-19 07:28:11 +00:00
e9d0052791
Merge pull request #650 from gc87/branch-mqtt
...
fix(mqtt): free ctx if msg send error
2022-07-18 18:38:07 +08:00
b820d74796
fix(mqtt): free ctx if msg send error
2022-07-18 18:24:26 +08:00
e4b2eaadeb
modbus: write coil using 0x05
2022-07-18 09:51:56 +00:00
f628c9153b
Merge pull request #636 from gc87/branch-mqtt
...
Add heartbeat support for mqtt plugin
2022-07-15 17:21:22 +08:00
003c31e4a6
fix(connection): send with bolck flag if conn is bolck
2022-07-15 06:48:08 +00: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
0d9e2c4515
Revert "change default password"
...
This reverts commit b16df3d3d3
2022-07-15 01:48:16 +00:00
b16df3d3d3
change default password
2022-07-14 09:46:54 +00:00
3c5ae487b0
fix(errorcode): return NEU_ERR_PLUGIN_TAG_NOT_READY when the tag value cache does not exist
2022-07-14 07:34:13 +00:00
c3217db4ff
modbus: modify the number of bulk reads
2022-07-14 05:40:52 +00:00
1fbebd3872
feat(connection): wait fixed msg
2022-07-13 07:46:38 +00:00
9ddf2cde78
ft: add error code
2022-07-11 08:00:21 +00:00
50089b7238
Merge pull request #623 from eeff/eeff/fix
...
fix: ekuiper start error code
2022-07-08 14:45:11 +08:00
5d22caa3b8
rname nona11
2022-07-07 08:19:41 +00:00
a793b8ed8b
fix: ekuiper start error code
2022-07-07 11:00:47 +08:00
282ca37050
ci: remove cppcheck errors
2022-07-04 22:49:58 +08:00
3299eab989
Merge pull request #612 from eeff/eeff/log
...
feat(restful): support log file downloading
2022-07-04 17:22:02 +08:00
a7d5270b65
Merge pull request #601 from eeff/eeff/dev
...
feat(restful): add websocket logging facilities
2022-07-04 17:21:07 +08:00
0b1fb54543
fix: cppcheck warning
2022-07-04 09:12:44 +00:00
a5e6512d74
feat(restful): support log file downloading
2022-07-04 16:30:59 +08:00
d9211a6a3f
feat(restful): add websocket log level and category filtering
2022-07-04 11:36:30 +08:00
5b35eb9555
Merge pull request #611 from gc87/branch-mqtt
...
fix(mqtt): connection in stoped state
2022-07-04 09:31:26 +08:00
0ed6b39b28
feat(restful): enable websocket logging
2022-07-01 17:44:56 +08:00
cbf51beffe
feat(restful): add websocket logging facilities
2022-07-01 17:44:49 +08:00
a2c9da83b8
fix(mqtt): connection in stoped state
2022-07-01 14:28:57 +08:00
98306b5adb
connection: add buf used log
2022-06-24 11:34:22 +00:00
23b83b7df2
refactor(mqtt): gettimeofday-> common.timestamp
2022-06-24 09:45:07 +08:00
48b6913e18
refactor(ekuiper): use plugin common timestamp
2022-06-23 16:11:44 +08:00
7cb727581f
chore(api): check node/group name len
2022-06-23 05:48:52 +00:00
44b9d622e6
Merge pull request #576 from eeff/eeff/dev
...
fix(ekuiper): read signed number
2022-06-22 14:10:12 +08:00
5264a42546
fix(ekuiper): read signed number
2022-06-22 14:05:45 +08:00
972204d8aa
fix(adapter): read signed number
2022-06-22 03:38:50 +00:00
b7881b4b93
fix(mqtt): write response topic error
2022-06-22 10:30:10 +08:00
fengzero