Zaiming (Stone) Shi
|
f6ac4c3a76
|
Merge pull request #8798 from zmstone/0815-feat-add-kafka-connector
feat: Add Kafka connector
|
2022-09-24 22:57:50 +02:00 |
|
Shawn
|
b325633390
|
refactor(resource): resume from queue/inflight-window with async-sending and batching
|
2022-09-21 22:58:47 +08:00 |
|
Shawn
|
9aa7e826cb
|
refactor(resource): fast resume resource worker if inflight msgs are ACKed
|
2022-09-17 00:34:30 +08:00 |
|
Shawn
|
8307f04c2e
|
refactor(resource): save inflight size into the ETS table
|
2022-09-16 16:52:08 +08:00 |
|
Shawn
|
d5d3972ff5
|
chore: add test cases for MQTT Bridge reconnecting
|
2022-09-15 10:19:33 +08:00 |
|
Shawn
|
4e211c12d3
|
fix(mqtt_bridge): return value of sending messages was discarded
|
2022-09-15 08:57:01 +08:00 |
|
Shawn
|
1c03c236f5
|
fix(mqtt_bridge): handle send_to_remote in idle state
|
2022-09-14 15:19:30 +08:00 |
|
Shawn
|
f41adb0997
|
refactor: change some default values of resource_opts
|
2022-09-14 15:18:07 +08:00 |
|
Zaiming (Stone) Shi
|
0c1595be02
|
feat: Add Kafka connector
|
2022-09-13 19:46:56 +02:00 |
|
Shawn
|
b9ae4ea276
|
refactor: rename some metrics for emqx_resource
|
2022-09-13 14:04:25 +08:00 |
|
Shawn
|
2b33ca6d49
|
fix: no error log print if insert bool values into mysql
|
2022-09-07 16:00:09 +08:00 |
|
Shawn
|
26234d38b9
|
fix: mark the async msg 'queuing' not 'sent.inflight' on recoverable_error
|
2022-09-02 18:41:43 +08:00 |
|
Shawn
|
83f21b4c65
|
refactor(resource): remove metrics 'sent.exception'
|
2022-09-02 12:46:53 +08:00 |
|
Shawn
|
b45f3de8db
|
refactor(resource): rename metrics batched,queued -> batching,queuing
|
2022-09-02 12:41:14 +08:00 |
|
Shawn
|
33c9c7d497
|
fix: incorrect message order when batch is enabled
|
2022-09-01 14:51:13 +08:00 |
|
Shawn
|
0ef0b68de4
|
refactor: change '{recoverable_error,Reason}' to '{error,{recoverable_error,Reason}}'
|
2022-08-31 18:25:00 +08:00 |
|
Shawn
|
73e19d84ee
|
feat: use the new metrics to bridge APIs
|
2022-08-30 23:47:58 +08:00 |
|
Shawn
|
9e50866cd0
|
fix: rename queue_max_bytes -> max_queue_bytes
|
2022-08-30 17:18:54 +08:00 |
|
Shawn
|
c4106c0d77
|
fix: resume the resource worker on health check success
|
2022-08-30 12:28:43 +08:00 |
|
Shawn
|
6fde37791c
|
refactor: new metrics for resources
|
2022-08-30 10:14:10 +08:00 |
|
Shawn
|
1625b8eaeb
|
fix(mysql_bridge): export the query_mode option to the APIs
|
2022-08-26 17:11:24 +08:00 |
|
Shawn
|
6b0ccfbc43
|
refactor: rename the error return resource_down -> recoverable_error
|
2022-08-26 17:11:12 +08:00 |
|
Shawn
|
a896aa8b27
|
fix: incorrect replayq dir for the emqx_resource
|
2022-08-25 16:06:18 +08:00 |
|
Shawn
|
86577365e4
|
fix: use gen_statem:cast/3 for async query
|
2022-08-23 22:41:45 +08:00 |
|
JimMoen
|
f0c2b53868
|
fix(bpapi): make bpapi static_checks happy
|
2022-08-22 10:51:44 +08:00 |
|
JimMoen
|
62ecf6f545
|
fix(resource): keep `auto_retry` in `disconnected` state
Automatic retries should be maintained even in `disconnected` state without any state transition.
|
2022-08-22 02:52:06 +08:00 |
|
JimMoen
|
7c4ea38c06
|
fix(resource): make some resource opts internal
Resource options `start_after_created` and `start_timeout` are internal opts.
Not provided to users anymore.
|
2022-08-22 02:22:57 +08:00 |
|
JimMoen
|
06363e63d9
|
fix(influxdb): connector use a fallbacke `pool_size` for influxdb client
|
2022-08-19 15:54:19 +08:00 |
|
Shawn
|
9e35032d78
|
fix: make resume_interval defaults to health_check_interval
|
2022-08-16 10:09:02 +08:00 |
|
Shawn
|
de3a325953
|
fix: revert the changes in connector mysql
|
2022-08-16 09:06:13 +08:00 |
|
Xinyu Liu
|
2898966439
|
Merge branch 'dev/ee5.0' into resource_opts
|
2022-08-15 21:43:22 +08:00 |
|
Shawn
|
19d85d485b
|
refactor(resource): add resource_opts level into config structure
|
2022-08-15 21:40:10 +08:00 |
|
Shawn
|
d1de262f31
|
fix: inc 'actions.failed' if bridge query failed
|
2022-08-15 17:21:14 +08:00 |
|
Shawn
|
665ef4142d
|
fix: unify the health check interval
|
2022-08-15 17:21:14 +08:00 |
|
JimMoen
|
68946f1f6c
|
feat: influxdb support `async`/`batch_async` query
|
2022-08-15 14:02:17 +08:00 |
|
JimMoen
|
b01ae8ece6
|
chore: refine influxdb bridge/connector i18n
|
2022-08-15 14:00:14 +08:00 |
|
JimMoen
|
594d071c05
|
feat(influxdb): add async callback
|
2022-08-12 18:26:47 +08:00 |
|
JimMoen
|
fa5e8f1422
|
chore: refine i18n label
|
2022-08-12 16:39:03 +08:00 |
|
JimMoen
|
3678673124
|
fix: schema default value using raw type before convert
|
2022-08-12 16:38:46 +08:00 |
|
Shawn
|
0cdf4b47f1
|
feat: add more resource creation opts
|
2022-08-12 13:47:45 +08:00 |
|
Shawn
|
c3c4ed02b4
|
fix: bump emqx_dashboard to 5.0.4
|
2022-08-12 00:24:58 +08:00 |
|
JimMoen
|
3a76a50382
|
fix: syntax error and compile error
|
2022-08-11 20:58:43 +08:00 |
|
Shawn
|
2872f0b668
|
fix(bridges): support create resources with options
|
2022-08-11 19:11:44 +08:00 |
|
JimMoen
|
0f6c371760
|
feat(influxdb): influxdb connector add `on_batch_query/3` callback
|
2022-08-11 18:12:41 +08:00 |
|
JimMoen
|
22a4ca311c
|
feat(resource): resource batch/async/queue config schema
|
2022-08-11 16:59:18 +08:00 |
|
Shawn
|
6203a01320
|
feat: add inflight window to emqx_resource
|
2022-08-11 08:36:35 +08:00 |
|
Shawn
|
82550a585a
|
fix: add test cases for query async
|
2022-08-10 00:45:34 +08:00 |
|
Shawn
|
efd6c56dd9
|
fix: test cases for batch query sync
|
2022-08-10 00:45:34 +08:00 |
|
Shawn
|
145ff66a9a
|
fix: issues found by dialyzer and elvis
|
2022-08-10 00:45:26 +08:00 |
|
Shawn
|
35fe70b887
|
feat: support aysnc callback to connector modules
|
2022-08-10 00:34:35 +08:00 |