850c378fe4
fix(ekuiper): start from init state
2022-04-22 10:42:23 +00:00
0f62c93fea
fix(connection): send with dontwait
2022-04-22 01:58:39 +00:00
36ef45a303
fix(adapter): the adapter state does not enter ready
2022-04-21 07:14:36 +00:00
cebdc3f469
chore(adapter): add write_response interface
2022-04-21 02:55:22 +00:00
52f5fe353b
fix(events): stop flag
2022-04-20 08:24:32 +00:00
ec8b6e27a3
fix(driver): del unused tag cache
2022-04-19 02:52:06 +00:00
38f03eadec
refactor(log): lower log level
2022-04-18 08:09:52 +00:00
289173d63f
fix(adapter): driver adapter create
2022-04-18 06:18:40 +00:00
5cdb2d2d05
Merge pull request #434 from gc87/mqtt-cert-load-directly
...
fix: remove incorrect error logs
2022-04-18 13:07:08 +08:00
c1bb0ad7f4
fix: remove incorrect error logs
2022-04-18 12:53:09 +08:00
dee64f0909
Merge pull request #433 from gc87/mqtt-cert-load-directly
...
MQTT Load the certificate and CA in memory
2022-04-18 11:32:06 +08:00
8276f7db27
fix(adapter): adapter destory crash
2022-04-18 03:24:07 +00:00
990f83c968
refactor(mqtt): load the CA in memory
2022-04-18 10:08:11 +08:00
4b09f83a3d
refactor(mqtt): Load the certificate in memory
2022-04-18 09:24:22 +08:00
dc52d25d4f
feat: add ekuiper plugin json decoding utilities
2022-04-15 18:03:20 +08:00
c187fafc2f
fix(adapter): init
2022-04-15 09:59:02 +00:00
1b1984bcb0
fix(adapter): uninit plugin
2022-04-15 09:36:40 +00:00
5bc6b1f406
refactor(adapter): remove update name api
2022-04-15 09:36:40 +00:00
adbc2245bc
rename adapter id
2022-04-15 09:36:40 +00:00
2cc3ae2c89
refactor(adapter): remove node_id in adapter
2022-04-15 09:36:40 +00:00
7100992531
refactor(adapter): rename and class plugin info in neu_adapter
2022-04-15 09:36:40 +00:00
fd03785205
refactor(adapter): remove stop field in neu_adapter
2022-04-15 09:36:40 +00:00
3548917bc6
refactor(adapter): remove adapter_type
2022-04-15 09:36:40 +00:00
d7d8d33b5d
feat(mqtt): add values-errors upload format
2022-04-15 17:12:36 +08:00
1e58f57ff8
refactor: group_config_name -> group_name
...
Modify the group_config_name in the read-write and periodic upload messages of the mqtt plugin to group_name
2022-04-15 17:03:05 +08:00
f53edc3948
Merge pull request #428 from fengzeroz/main
...
refactor adapter
2022-04-15 16:32:55 +08:00
d62a9fc750
refactor(adapter): explicit adapter classification
...
driver: connect physical devices to read/write tag, such as PLC.
config: add/del/update plugin/group/tag, and persistent configuration.
control: periodically upload data and accept write tag.
2022-04-15 08:17:44 +00:00
ec0c8a1889
Fixing warnings in CI compilation
2022-04-15 08:13:09 +00:00
e22fcd1c0d
refactor(adapter): use adapter events to upload tag data
2022-04-15 03:34:53 +00:00
eacfc6720a
perf(adapter): use neu_event to monitor nng-fd event
2022-04-14 09:53:20 +00:00
47a31a691c
fix(adapter): update value based on name
2022-04-14 05:51:38 +00:00
54a5a2b9d4
Add driver type adapter, simplify driver development
...
use one thread to upload data, and another thread to trigger the driver
to read and write data and process msg.
2022-04-13 09:47:59 +00:00
d13747cfc8
refactor: remove neu_list dependency
...
Use sys/queue.h instead of neu_list.h
2022-04-12 16:56:14 +08:00
594b0b21ed
Fix subscription list release order
2022-04-11 15:56:44 +08:00
d2aa1ea7f3
Merge pull request #416 from eeff/eeff/dev
...
Fix command line `--restart` option number conversion
2022-04-11 11:29:54 +08:00
7fb1deb23b
Fix command line --restart option number conversion
2022-04-11 11:11:58 +08:00
6e7a14e0c9
Merge pull request #415 from eeff/eeff/dev
...
Add daemon restart policy and enable core dump
2022-04-11 10:59:05 +08:00
a959df37a3
Try to enable core dump for neuron process
2022-04-11 10:38:50 +08:00
a8c45725d2
Implement neuron daemon restart policy
2022-04-11 10:38:50 +08:00
e4c0c60cba
Add command line option --restart for restart policy
2022-04-11 10:38:50 +08:00
982d299b4a
Merge pull request #413 from gc87/try-fix-mqtt-connection
...
Fix issue associated with mqtt connection
2022-04-11 09:59:36 +08:00
34c2f85a49
Replace nng mutex with pthread mutex in main.c
...
nng internal will check against fork-reentrant, replace with pthread
mutex to avoid this problem.
2022-04-10 23:54:22 +08:00
b4859032a9
Add neuron daemon mode feature
2022-04-10 23:07:12 +08:00
5fe22ce971
Refactor main.c neuron setup logic into separate function
2022-04-10 23:02:45 +08:00
669b6428de
neu_list.h -> sys/queue.h
2022-04-10 11:51:31 +08:00
d5e118ef68
Refactor: better global variable naming in main.c
2022-04-09 23:59:19 +08:00
687b53e433
Fix src/argparse.h header guard
2022-04-09 23:59:19 +08:00
f858fa6304
mqtt client exits asynchronously
2022-04-08 17:08:10 +08:00
6bedae37e8
ssl connection to mqtt to set client keypair
2022-04-08 17:08:10 +08:00
a53a41a570
Disable part of the mqtt control interface
2022-04-08 17:08:10 +08:00
fengzero