289428cc5a
refactor(kafka): rename bridge type 'kafka' to 'kafka_producer'
2023-10-30 00:19:27 +01:00
27aff47c17
fix(connector): check that there are no active channels when removing
2023-10-27 08:23:28 -03:00
da7d495da9
test: fix emqx_connector_SUITE
2023-10-27 11:53:41 +02:00
2228a0d477
feat: port azure event hub to bridge_v2
2023-10-27 11:53:41 +02:00
f760f0a5c5
fix: backport 7b607c3300
2023-10-27 11:53:41 +02:00
b72abaf661
fix: wording from copy-paste error
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
16f8848281
test: fix emqx_connector_SUITE
2023-10-27 11:53:41 +02:00
38bf2ae445
fix: issues found by spellcheck script
2023-10-27 11:53:41 +02:00
2d05e3a975
fix: dialyzer problem for community edition
2023-10-27 11:53:41 +02:00
6c6c2e0cff
fix: dialyzer warnings for community edition
2023-10-27 11:53:41 +02:00
a847b043df
fix: disable bridge_v2 tests if not on enterprise
2023-10-27 11:53:41 +02:00
e72b952138
fix: problems reported by dialyzer
2023-10-27 11:53:41 +02:00
7822d7db76
fix: strange issue with `erlfmt`
2023-10-27 11:53:41 +02:00
29ca7f944f
fix: simplify by enabling check_schema
2023-10-27 11:53:41 +02:00
2a1e135304
test: fix tests after emqx_authn changes
2023-10-27 11:53:41 +02:00
f49011ece4
fix: unused variable warning
2023-10-27 11:53:41 +02:00
2cd1c88f7f
fix: fixup after rebasing on release-23
2023-10-27 11:53:41 +02:00
38f5c7dcf4
feat: HTTP API for bridge_v2
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
828bbc57ac
feat: test case fixes and compatibility layer probe etc
...
* test case fixes for Bridge V1 suite
* Bug fixes
* local_topic
* Bridge V1 probe compatibility functionality
2023-10-27 11:53:41 +02:00
1c62b5bcf3
fix: use correct body_schema
2023-10-27 11:53:41 +02:00
291d54eef0
test: use no_link in init for mecks
2023-10-27 11:53:41 +02:00
671b5306cd
fix: cleanup start/stop/restart operations
2023-10-27 11:53:41 +02:00
1816b450f0
test: (re-)add inconsistent connector test
2023-10-27 11:53:41 +02:00
0ad156bfa9
test: make sure mocks are ready before init_mocks terminates
2023-10-27 11:53:41 +02:00
ee8e469086
test: port all remaining tests
2023-10-27 11:53:40 +02:00
a9a7f4ae3a
fix: set bpapi version to 1
2023-10-27 11:53:40 +02:00
cb8691438a
test: use mock instead of actual kafka service
2023-10-27 11:53:40 +02:00
7f3e23eed9
test: initial add of /connectors api suite
2023-10-27 11:53:40 +02:00
f3648c5232
fix: allow Type in resource-id and pass it on
2023-10-27 11:53:40 +02:00
8567ccafc1
fix: don't assume resource-id starts with "connector:"
2023-10-27 11:53:40 +02:00
c9b683fd78
fix: add missing function for non enterprise
2023-10-27 11:53:40 +02:00
229bc0ee34
fix: schema fixes for connector and kafka as connector
2023-10-27 11:53:40 +02:00
64faf32842
style: cleanup examples
2023-10-27 11:53:40 +02:00
7641c22455
fix: add missing parts
2023-10-27 11:53:40 +02:00
ed8aa46602
refactor: copy bridge api code over to emqx_connector
2023-10-27 11:53:40 +02:00
d05f2010b3
fix: fail remove connector with active channels
2023-10-27 11:53:40 +02:00
cc864f4821
feat: add update/3
2023-10-27 11:53:40 +02:00
9195838c17
test: add disable_enable tests
2023-10-27 11:53:40 +02:00
009b9c3d39
style: remove unused commented fn
2023-10-27 11:53:40 +02:00
c0df85ac09
feat: Bridge V2 compatiblilty layer progress and local topic
...
* Most Bridge V1 HTTP API calls are now compatible with Bridge V2
* Local topics works for Bridge V2 now
* A lot of work on trying to get the old Kafka producer test suite
to work after the refactorings
2023-10-27 11:53:40 +02:00
16d7f4d3e6
style: cleanup emqx_connector_resource
2023-10-27 11:53:40 +02:00
99904cab27
fix: don't break root for non enterprise
2023-10-27 11:53:40 +02:00
bc6e1da2fb
test: add suite for emqx_connector
2023-10-27 11:53:40 +02:00
8f109da62b
style: cleanup emqx_connector
2023-10-27 11:53:40 +02:00
f7984be946
feat: add connector schema scaffold and break out Kafka conector
...
This commit is the beginning of an effort to split bridges into a
connector part and a bridge part.
Several bridges should be able to share a connector pool defined by a
single connector. The connectors should be possible to enable and
disable similar to how one can disable and enable bridges. There should
also be an API for checking the status of a connector and for
add/edit/delete connectors similar to the current bridge API.
Issues:
https://emqx.atlassian.net/browse/EMQX-10805
2023-10-27 11:53:40 +02:00
dafd7c6085
chore: bump apps versions
2023-09-21 10:58:42 +02:00
2f1fa2e961
chore: unified slog message formatting to improve logging consistency
2023-09-20 18:13:00 +08:00
24230a64df
chore: bump app versions
2023-09-04 11:39:21 +02:00
Zaiming (Stone) Shi