c3ed9cc69d
chore(persist): get persist db
2023-03-17 09:02:09 +00:00
253f254bd3
feat: move persister to neuron base
2023-03-17 15:17:16 +08:00
214c82b508
feat: remove persister dependency on g_config_dir
2023-03-17 15:17:16 +08:00
cfb3d073c5
fix(main): manager destroy when recv SIGINT or SIGTERM
2023-03-14 05:48:53 +00:00
5c543e0077
fix(event): handle EINTR
2023-03-10 02:17:54 +00:00
fd6c3aca96
chore(main): handle SIGSEGV signal
2023-03-07 05:20:55 +00:00
68587420e0
fix(connection): disconnect if recv return 0
2023-03-07 03:23:30 +00:00
5d2cff0aef
fix(connection): tcp server accept assert
2023-01-30 02:26:25 +00:00
639e8fb9ab
feat(monitor): add node state metrics
2023-01-11 11:00:40 +08:00
34f0b19b81
add timestamp in trans_data
2022-12-30 01:43:06 +00:00
105f1e64a7
reduce the frequency of timestamp update
2022-12-30 01:42:50 +00:00
87ba865774
del report state timer
2022-12-28 07:11:29 +00:00
582bf17b28
manager timer type
2022-12-28 07:09:34 +00:00
5dfa8484b1
fix group timer
2022-12-26 07:24:07 +00:00
3dfdc2a18b
fix group timer
2022-12-26 07:20:01 +00:00
b51a2ff374
report data using noblock timer
2022-12-21 08:47:45 +00:00
2c02652cd6
chore: persister load tags in insertion order
2022-12-09 10:38:43 +08:00
8a96a51abd
fix db schema limit
2022-12-06 08:45:08 +00:00
597932ba8b
Merge pull request #972 from eeff/eeff/dev
...
fix(mqtt-client): work around segfault due to NanoSDK race condition
2022-12-06 16:28:03 +08:00
2927e17a74
fix(mqtt-client): work around segfault due to NanoSDK race condition
2022-12-06 14:51:39 +08:00
6ba9d26027
fix connection log cate
2022-12-06 02:36:20 +00:00
40926b33dc
try scanf certs directory
2022-12-02 06:09:25 +00:00
af582c5d2c
fix debug log time
2022-12-01 14:12:54 +00:00
d35fd4db08
fix(mqtt-client): publish method memory leak when sock not ready
2022-12-01 16:02:03 +08:00
b5c3c28622
create timer with plugin parameter
2022-11-30 03:30:10 +00:00
0a2e6cb723
event: timer type block/noblock
2022-11-30 03:14:54 +00:00
4072c67e79
feat(mqtt-client): refactor set cache interface
2022-11-29 17:30:48 +08:00
9c62e847cc
Merge pull request #942 from eeff/eeff/dev
...
fix(mqtt-client): avoid data condition
2022-11-28 18:00:40 +08:00
738ec1fa7f
fix(mqtt-client): avoid data condition
2022-11-28 17:53:12 +08:00
7d98d81bd8
Merge pull request #936 from eeff/eeff/dev
...
feat(nano-mqtt): update cached messages metric
2022-11-28 17:14:58 +08:00
4aaefc67b9
fix: metric hash crash if del group
2022-11-28 08:41:43 +00:00
a1773a8b72
jwt: load key from config and persistence dir
2022-11-28 07:46:30 +00:00
3ed84459a9
chore(arg): default log level
2022-11-28 07:16:53 +00:00
514e232c58
feat(mqtt-client): add neu_mqtt_client_get_cached_msgs_num
2022-11-28 14:41:49 +08:00
62959d16a1
fix: init adapter register_metric callback
2022-11-28 11:54:49 +08:00
5e980ccd07
Merge pull request #932 from eeff/eeff/dev
...
feat(mqtt-client): refactor publish/subscribe interface
2022-11-28 10:25:15 +08:00
afe11b7a73
feat(mqtt-client): refactor publish/subscribe interface
2022-11-27 19:25:35 +08:00
327bda38c3
new type
2022-11-25 10:55:21 +00:00
07c32470c5
fix: command --reset-password
2022-11-25 16:08:04 +08:00
20feda1fc8
fix(mqtt-client): task callback free only SUBACK/UNSUBACK messages
2022-11-23 17:48:53 +08:00
d36ea326d5
fix(mqtt-client): disable cache correctly
2022-11-23 16:27:27 +08:00
75083e65ba
fix(mqtt-client): connect with correct url w/wo tls
2022-11-23 11:43:46 +08:00
ef5f0edc9a
fix: function neu_parse_param check NULL pointer
2022-11-23 11:16:17 +08:00
6c8e461220
Merge pull request #924 from eeff/eeff/dev
...
feat(nano-mqtt): add client-id setting
2022-11-22 10:54:38 +08:00
c9926fde0f
fix tcp server recv
2022-11-21 08:07:18 +00:00
e14b012b68
feat(mqtt-client): add method neu_mqtt_client_set_id
2022-11-21 12:07:22 +08:00
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
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
d2b85071a1
add(plugin Chinese description):modbus-tcp,ekuiper,mqtt,nano-mqtt
2022-11-16 08:44:43 +00:00
ef536f6f99
Merge pull request #916 from eeff/eeff/dev
...
feat(nano-mqtt): handle read/write request
2022-11-16 09:32:28 +08:00
fengzero