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 |
|
Shawn
|
f1419d52f1
|
fix(resource): remove resource at the end of each test
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
a2afdeeb48
|
feat: add test cases for batching query
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
75adba0781
|
fix: increase resource metrics using the resource id
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
d3950b9534
|
fix(resource): make option 'queue_enabled' disabled by default
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
0377d3cf61
|
fix: update existing testcases for new emqx_resource
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
2fb42e4d37
|
refactor: create emqx_resource_worker_sup for resource workers
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
0087b7c960
|
fix: remove the extra file replay.erl
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
d8d8d674e4
|
feat(resource): start emqx_resource_worker in pools
|
2022-08-10 00:34:35 +08:00 |
|
Shawn
|
12904d797f
|
feat(resource): first commit for batching/async/caching mechanism
|
2022-08-10 00:34:35 +08:00 |
|
DDDHuang
|
98b36c4681
|
fix: hstream db connector , TODO: start apps
|
2022-07-27 11:38:45 +08:00 |
|
JianBo He
|
a78a389206
|
chore: using standard log format
|
2022-07-01 12:06:35 +08:00 |