Thales Macedo Garitezi
|
62eeb4b8e8
|
feat(resource): reset metrics when stopping a resource
|
2022-10-18 09:32:35 -03:00 |
|
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
|
9aa7e826cb
|
refactor(resource): fast resume resource worker if inflight msgs are ACKed
|
2022-09-17 00:34:30 +08:00 |
|
Shawn
|
d5d3972ff5
|
chore: add test cases for MQTT Bridge reconnecting
|
2022-09-15 10:19:33 +08:00 |
|
Shawn
|
1c03c236f5
|
fix(mqtt_bridge): handle send_to_remote in idle state
|
2022-09-14 15:19:30 +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
|
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
|
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
|
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 |
|
Shawn
|
de3a325953
|
fix: revert the changes in connector mysql
|
2022-08-16 09:06:13 +08:00 |
|
Shawn
|
665ef4142d
|
fix: unify the health check interval
|
2022-08-15 17:21:14 +08:00 |
|
Shawn
|
0cdf4b47f1
|
feat: add more resource creation opts
|
2022-08-12 13:47:45 +08:00 |
|
Shawn
|
2872f0b668
|
fix(bridges): support create resources with options
|
2022-08-11 19:11:44 +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
|
75adba0781
|
fix: increase resource metrics using the resource id
|
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 |
|
Shawn
|
d6ef2f7502
|
refactor: graceful recreate resources
|
2022-06-17 05:29:18 +08:00 |
|
Shawn
|
cc25f92273
|
feat: add start_after_created option to resource:create/4
|
2022-06-16 23:34:52 +08:00 |
|
Shawn
|
b7f27157e5
|
fix: also alarm resource down when start resource failed
|
2022-06-01 15:41:55 +08:00 |
|
Shawn
|
88ca25c60c
|
fix(resource): fast return when starting a unavailable resource
|
2022-06-01 08:24:53 +08:00 |
|
Shawn
|
9f69e3cad6
|
fix(resource): discard dry_run resource down alarm
|
2022-06-01 08:24:53 +08:00 |
|
Shawn
|
d37a66e9b8
|
fix(test): update test cases for emqx_resource:health_check/1
|
2022-05-31 10:14:37 +08:00 |
|
Shawn
|
1054c364ad
|
refactor(resource): improve health check and alarm it if resource down
|
2022-05-31 01:40:40 +08:00 |
|
EMQ-YangM
|
b5addf7e05
|
fix: log all ignore events
|
2022-05-16 15:08:03 +08:00 |
|
EMQ-YangM
|
bbbfea1b5b
|
fix: ignore all other events
|
2022-05-16 15:08:03 +08:00 |
|
EMQ-YangM
|
1a1c82932a
|
fix: when connecting health check failed, update status.
|
2022-05-16 10:47:20 +08:00 |
|
Xinyu Liu
|
c4fd31ae25
|
Merge pull request #7916 from emqx/EMQX-4204-auto-timer-based-retry-when-in-disconnected-state
feat: add auto_retry for disconnected state in resource manager
|
2022-05-16 09:34:08 +08:00 |
|
Chris
|
6574c33797
|
feat: add auto_retry for disconnected state in resource manager
|
2022-05-13 11:19:39 +02:00 |
|
EMQ-YangM
|
d5c416736b
|
fix: restart resource should not clear metrics
|
2022-05-13 16:05:41 +08:00 |
|
Chris
|
0b3e30e813
|
feat: isolate resource manager processes
|
2022-05-09 13:24:34 +02:00 |
|
Zaiming (Stone) Shi
|
f42a5b90df
|
Revert "feat: isolate resource manager processes"
This reverts commit 40cca58d4f.
|
2022-04-26 16:13:38 +02:00 |
|
Chris
|
40cca58d4f
|
feat: isolate resource manager processes
|
2022-04-26 13:28:29 +02:00 |