Thales Macedo Garitezi
|
f0ff32c031
|
test: fix tests after counter changes
|
2022-10-11 17:45:48 -03:00 |
|
Shawn
|
9aa7e826cb
|
refactor(resource): fast resume resource worker if inflight msgs are ACKed
|
2022-09-17 00:34:30 +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
|
6b0ccfbc43
|
refactor: rename the error return resource_down -> recoverable_error
|
2022-08-26 17:11:12 +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
|
35fe70b887
|
feat: support aysnc callback to connector modules
|
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 |