This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch topic_durability
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 78d7a46e9 improvements
add 2e3823196 feat(connectors): add RabbitMQ sink (#3973)
add 390d836e8 Merge branch 'master' into topic_durability
No new revisions were added by this update.
Summary of changes:
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/edge-release.yml | 1 +
Cargo.lock | 1495 ++++++++++++++------
Cargo.toml | 2 +
core/connectors/README.md | 1 +
.../example_config/connectors/rabbitmq_sink.toml} | 32 +-
core/connectors/sinks/README.md | 1 +
.../Cargo.toml | 20 +-
core/connectors/sinks/rabbitmq_sink/README.md | 50 +
.../config.toml | 29 +-
core/connectors/sinks/rabbitmq_sink/src/lib.rs | 783 ++++++++++
core/integration/Cargo.toml | 1 +
core/integration/tests/connectors/fixtures/mod.rs | 6 +
.../connectors/fixtures/rabbitmq/container.rs | 327 +++++
.../fixtures/{clickhouse => rabbitmq}/mod.rs | 5 +-
.../tests/connectors/fixtures/rabbitmq/sink.rs | 273 ++++
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/{quickwit => rabbitmq}/mod.rs | 2 +-
.../tests/connectors/rabbitmq/rabbitmq_sink.rs | 429 ++++++
.../tests/connectors/{delta => rabbitmq}/sink.toml | 2 +-
scripts/bump-version.sh | 2 +-
21 files changed, 2963 insertions(+), 501 deletions(-)
copy core/connectors/{sinks/mongodb_sink/config.toml =>
runtime/example_config/connectors/rabbitmq_sink.toml} (68%)
copy core/connectors/sinks/{elasticsearch_sink => rabbitmq_sink}/Cargo.toml
(80%)
create mode 100644 core/connectors/sinks/rabbitmq_sink/README.md
copy core/connectors/sinks/{meilisearch_sink => rabbitmq_sink}/config.toml
(68%)
create mode 100644 core/connectors/sinks/rabbitmq_sink/src/lib.rs
create mode 100644
core/integration/tests/connectors/fixtures/rabbitmq/container.rs
copy core/integration/tests/connectors/fixtures/{clickhouse =>
rabbitmq}/mod.rs (77%)
create mode 100644 core/integration/tests/connectors/fixtures/rabbitmq/sink.rs
copy core/integration/tests/connectors/{quickwit => rabbitmq}/mod.rs (97%)
create mode 100644 core/integration/tests/connectors/rabbitmq/rabbitmq_sink.rs
copy core/integration/tests/connectors/{delta => rabbitmq}/sink.toml (94%)
