289428cc5a
refactor(kafka): rename bridge type 'kafka' to 'kafka_producer'
2023-10-30 00:19:27 +01:00
1b248279fd
test(bridge_v2): test case for the local_topic feature
2023-10-28 17:59:11 +02:00
5cfe151f7c
fix: type conversion for rule with converted bridge V1 reference
...
* Make sure that a rule that refer to a bridge that has been converted to
a bridge V2 bridge gets its type converted if needed.
* Add test case for sending message to a Bridge V2 through a rule
2023-10-28 15:18:36 +02:00
d61d80f338
fix: almost working bridge v1 compatibility layer for HTTP API
...
Most operation for the bridge V1 HTTP API compatibility layer are now
working. This has been tested by creating/deleting/updating Kafka bridge
through HTTP API, sending message to it, and resetting and checking
metrics.
The start, stop, restart, enable, disable operations still need to be
fixed.
2023-10-27 18:25:11 +02:00
951184014e
test(bridge_v2): add test cases for root post config update handler callback
2023-10-27 08:42:59 -03:00
27aff47c17
fix(connector): check that there are no active channels when removing
2023-10-27 08:23:28 -03:00
f2c9739ce2
feat(bridge_v2): validate connector references when creating/updating bridges
2023-10-27 11:53:42 +02:00
90a23d98fe
fix: channel handling when resource not connected
2023-10-27 11:53:42 +02:00
bba5b42c99
fix: broken test cases
2023-10-27 11:53:41 +02:00
477ed11de8
fix: periodical status checks and alarms for channels
2023-10-27 11:53:41 +02:00
d8a9778d7c
feat: add compatibilty layer function for checking if valid bridge_v1
2023-10-27 11:53:41 +02:00
a5a060473c
feat: restructure emqx_bridge_v2 for better readability
2023-10-27 11:53:41 +02:00
e13196c1ca
feat(bridge_v2): dry_run and specific test suite
2023-10-27 11:53:41 +02:00
Zaiming (Stone) Shi