 eeff
|
9658d8ac72
|
fix(mqtt-client): add task queue and avoid blocking
1. use nng_send_aio instead of nng_sendmsg to avoid blocking due
to NanoSDK quirks
2. add task queue for both sending/receiving messages
|
2022-11-18 11:34:15 +08:00 |
|
|
fengzeroz
|
b0fb82f5ef
|
Merge pull request #918 from lixiumei123/main
add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt
|
2022-11-17 10:07:17 +08:00 |
|
|
fengzeroz
|
6f9c9565bf
|
Merge pull request #917 from brianbinbin/feature/zt
support create pvc automatically
|
2022-11-17 10:06:34 +08:00 |
|
|
lixiumei123
|
d2b85071a1
|
add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt
|
2022-11-16 08:44:43 +00:00 |
|
|
bin
|
78a068b6e0
|
update README
Signed-off-by: bin <brian.xb.bian@gmail.com>
|
2022-11-16 13:48:17 +08:00 |
|
|
bin
|
e6ec9d8d7f
|
support create pvc automatically
Signed-off-by: bin <brian.xb.bian@gmail.com>
|
2022-11-16 13:24:40 +08:00 |
|
|
fengzeroz
|
ef536f6f99
|
Merge pull request #916 from eeff/eeff/dev
feat(nano-mqtt): handle read/write request
|
2022-11-16 09:32:28 +08:00 |
|
|
eeff
|
5862b3e528
|
feat(nano-mqtt): handling write request and response generation
|
2022-11-15 18:02:12 +08:00 |
|
|
eeff
|
7ddd17fc71
|
feat(nano-mqtt): handling read request and response generation
|
2022-11-15 18:02:12 +08:00 |
|
|
eeff
|
8d2e533492
|
feat(mqtt-client): implement subscribe method
|
2022-11-15 18:02:12 +08:00 |
|
|
fengzeroz
|
d74a91c9c1
|
Merge pull request #913 from eeff/eeff/dev
feat(nano-mqtt): handling upload data generation
|
2022-11-15 17:50:29 +08:00 |
|
|
eeff
|
221ba531d1
|
feat(nano-mqtt): handling upload data generation
|
2022-11-15 16:28:43 +08:00 |
|
|
fengzeroz
|
88bd98949e
|
Merge pull request #915 from fengzeroz/main
Revert "link shared openssl"
|
2022-11-15 15:02:20 +08:00 |
|
|
fengzero
|
49722da706
|
Revert "link shared openssl"
This reverts commit dea4975a22.
|
2022-11-15 07:01:41 +00:00 |
|
|
fengzeroz
|
27c5ab3897
|
Merge pull request #914 from fengzeroz/main
link shared openssl
|
2022-11-15 14:43:53 +08:00 |
|
|
fengzero
|
dea4975a22
|
link shared openssl
|
2022-11-15 06:38:10 +00:00 |
|
|
fengzeroz
|
784fa51118
|
Merge pull request #911 from fengzeroz/main
fix tcp server accept
|
2022-11-15 14:04:51 +08:00 |
|
|
fengzero
|
25cb987a1a
|
fix tcp server accept
|
2022-11-15 05:56:40 +00:00 |
|
|
fengzeroz
|
362e0a0817
|
Merge pull request #910 from eeff/eeff/dev
feat(nano-mqtt): handling heartbeat generation
|
2022-11-15 11:35:52 +08:00 |
|
|
eeff
|
a8cfeaa268
|
feat(nano-mqtt): handling heartbeat generation
|
2022-11-15 00:23:44 +08:00 |
|
|
eeff
|
f919f5c565
|
feat(nano-mqtt): open/close mqtt client when config/start/stop plugin
|
2022-11-15 00:23:44 +08:00 |
|
|
eeff
|
a7f8678940
|
fix(mqtt-client): not sqlite caching when cache limit is zero
|
2022-11-15 00:23:44 +08:00 |
|
|
fengzeroz
|
9402cc6d52
|
Merge pull request #907 from eeff/eeff/dev
feat: add mqtt client
|
2022-11-14 17:06:04 +08:00 |
|
|
fengzeroz
|
8cfc5c9cd7
|
Merge pull request #908 from fengzeroz/main
fix(connection): tcp server accpet client
|
2022-11-14 16:59:59 +08:00 |
|
|
eeff
|
4ca5b5ad37
|
feat: add mqtt client
|
2022-11-14 16:52:59 +08:00 |
|
|
eeff
|
8894132897
|
chore: rename mqtt_client_intf symbols
|
2022-11-14 16:52:59 +08:00 |
|
|
fengzero
|
301b023806
|
fix(connection): tcp server accpet client
|
2022-11-14 08:09:40 +00:00 |
|
|
eeff
|
47ce1132d0
|
feat: move mqtt_client_intf stuff from base to plugin mqtt
|
2022-11-14 14:40:54 +08:00 |
|
|
fengzeroz
|
c03fea6b3a
|
Merge pull request #906 from eeff/eeff/dev
feat(nano-mqtt): add node setting
|
2022-11-14 14:40:03 +08:00 |
|
|
fengzeroz
|
fc56c2c1a0
|
Merge pull request #905 from fengzeroz/main
connection(tty): flush input/output
|
2022-11-14 14:28:24 +08:00 |
|
|
eeff
|
47f320a1c1
|
feat(nano-mqtt): add node setting
|
2022-11-14 10:30:01 +08:00 |
|
|
eeff
|
32d8271556
|
fix: neu_decode64 on empty string
|
2022-11-14 10:23:58 +08:00 |
|
|
eeff
|
611f3586e9
|
fix: function neu_json_decode_new and neu_parse_param
|
2022-11-14 10:23:58 +08:00 |
|
|
fengzero
|
e5634002df
|
connection(tty): flush input/output
|
2022-11-14 01:59:48 +00:00 |
|
|
fengzeroz
|
f210f1cb43
|
Merge pull request #902 from eeff/eeff/dev
feat(nano-mqtt): add plugin skeleton
|
2022-11-14 09:55:49 +08:00 |
|
|
fengzeroz
|
6393beba63
|
Merge pull request #903 from fengzeroz/main
fix name length check
|
2022-11-11 14:47:19 +08:00 |
|
|
fengzero
|
08134396ea
|
fix: name length check
|
2022-11-11 06:38:34 +00:00 |
|
|
fengzero
|
07f5871d41
|
update cmake
|
2022-11-11 06:38:12 +00:00 |
|
|
eeff
|
422bd36582
|
feat(nano-mqtt): add plugin skeleton
|
2022-11-11 10:26:46 +08:00 |
|
|
fengzeroz
|
ef6d9245ab
|
Merge pull request #900 from fengzeroz/main
fix tag name limit
|
2022-11-10 18:26:11 +08:00 |
|
|
fengzero
|
64d5407c05
|
fix tag name limit
|
2022-11-10 10:15:40 +00:00 |
|
|
fengzeroz
|
037511d383
|
Merge pull request #899 from fengzeroz/main
fix(event): read error
|
2022-11-10 17:20:53 +08:00 |
|
|
fengzero
|
8c5fdd4ef2
|
fix(event): read error
|
2022-11-10 09:14:13 +00:00 |
|
|
fengzeroz
|
99fd3726ef
|
Merge pull request #892 from eeff/eeff/dev
build: add mbedtls as dependency to neuron-base
|
2022-11-10 15:24:12 +08:00 |
|
|
fengzeroz
|
3973c1ceb0
|
Merge pull request #898 from fengzeroz/main
metric: add counter_set
|
2022-11-10 11:26:13 +08:00 |
|
|
fengzero
|
700131614b
|
metric: add counter_set
|
2022-11-10 03:24:44 +00:00 |
|
|
fengzeroz
|
56a178e58a
|
Merge pull request #897 from fengzeroz/main
connection: statics of bytes sent and recvied
|
2022-11-10 10:56:00 +08:00 |
|
|
fengzero
|
04d990e79b
|
modbus: connection state
|
2022-11-10 02:50:37 +00:00 |
|
|
fengzero
|
3a9e4b888d
|
connection: statics of bytes sent and recvied
|
2022-11-10 02:29:52 +00:00 |
|
|
eeff
|
93fa2a17c4
|
ci: update to use neugates/build:2.3
|
2022-11-10 10:26:58 +08:00 |
|