This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch drain-bus
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit bdda8ac67 feat(message_bus): add drain method to collect buffered
outbound messages
add c182bfc8c refactor(go): upgrade go-retry to v5 and enable infinite
reconnection (#2884)
add 3bcf7ff5e ci(go): merge BDD and e2e test coverage into Go SDK Codecov
reports (#2859)
add ae29f6c31 feat(js): add TCP/TLS integration tests and examples (#2822)
add 7d20f31a8 feat(java): implement Async Connection Pooling using
FixedChannelPool (#2606)
add f91486031 feat(connectors): add MongoDB sink connector (#2815)
add 52afc3c12 feat(rust): add dedicated TCP/TLS producer and consumer
examples (#2820)
add dbbbba5a7 chore: bump Rust to 1.94 (#2900)
add 782c8c379 chore(deps): upgrade workspace dependencies, bump all edge
iggy crates (#2901)
add 08845bf36 ci: split examples-suite into per-SDK example components
(#2899)
add 0625ba955 ci: fix flaky keyring tests with eval and collection warmup
(#2908)
add 7aac5d31f feat(message_bus): add drain method to collect buffered
outbound messages
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (bdda8ac67)
\
N -- N -- N refs/heads/drain-bus (7aac5d31f)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/actions/go/pre-merge/action.yml | 25 +-
.github/actions/node-npm/pre-merge/action.yml | 31 +-
.github/actions/rust/pre-merge/action.yml | 5 +-
.github/config/components.yml | 101 +-
.github/workflows/_detect.yml | 5 +-
.github/workflows/_test.yml | 4 +-
.github/workflows/_test_examples.yml | 30 +-
.github/workflows/post-merge.yml | 29 +-
Cargo.lock | 1349 +++++++++++++-------
Cargo.toml | 73 +-
DEPENDENCIES.md | 284 +++--
Dockerfile | 2 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
bdd/java/Dockerfile | 2 +-
bdd/python/Dockerfile | 2 +-
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Cargo.toml | 5 +-
core/ai/mcp/Dockerfile | 2 +-
core/ai/mcp/src/log.rs | 4 +-
core/ai/mcp/src/service/mod.rs | 7 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/dashboard/server/Dockerfile | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/Dockerfile | 2 +-
core/connectors/runtime/src/log.rs | 4 +-
core/connectors/runtime/src/sink.rs | 3 +-
core/connectors/sdk/src/lib.rs | 6 +
core/connectors/sdk/src/sink.rs | 3 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
.../sinks/{stdout_sink => mongodb_sink}/Cargo.toml | 16 +-
core/connectors/sinks/mongodb_sink/README.md | 146 +++
.../{postgres_sink => mongodb_sink}/config.toml | 21 +-
core/connectors/sinks/mongodb_sink/src/lib.rs | 912 +++++++++++++
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/integration/Cargo.toml | 1 +
core/integration/src/harness/handle/mcp.rs | 14 +-
core/integration/tests/connectors/fixtures/mod.rs | 5 +
.../tests/connectors/fixtures/mongodb/container.rs | 244 ++++
.../fixtures/{elasticsearch => mongodb}/mod.rs | 8 +-
.../tests/connectors/fixtures/mongodb/sink.rs | 390 ++++++
core/integration/tests/connectors/mod.rs | 1 +
.../connectors/{elasticsearch => mongodb}/mod.rs | 3 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 1162 +++++++++++++++++
.../connectors/{iceberg => mongodb}/sink.toml | 2 +-
core/integration/tests/mcp/mod.rs | 24 +-
core/sdk/Cargo.toml | 2 +-
core/server/Cargo.toml | 3 +-
core/server/Dockerfile | 2 +-
core/server/src/log/logger.rs | 4 +-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/README.md | 22 +
examples/node/package.json | 4 +-
examples/node/src/{basic => tcp-tls}/consumer.ts | 123 +-
examples/node/src/tcp-tls/producer.ts | 126 ++
examples/node/test-examples.sh | 9 +
examples/rust/Cargo.toml | 8 +
examples/rust/README.md | 22 +
examples/rust/src/shared/args.rs | 2 +
.../{getting-started => tcp-tls}/consumer/main.rs | 73 +-
.../{getting-started => tcp-tls}/producer/main.rs | 64 +-
foreign/go/client/tcp/tcp_core.go | 15 +-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 15 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 18 +
.../iggy/client/async/tcp/AsyncTcpConnection.java | 408 ++++--
.../iggy/client/async/tcp/IggyAuthenticator.java | 79 ++
.../iggy/client/async/tcp/IggyFrameEncoder.java | 63 +
foreign/node/src/e2e/tls.system.e2e.ts | 142 +++
foreign/python/Cargo.toml | 14 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/consumer.rs | 4 +-
foreign/python/src/receive_message.rs | 2 +-
foreign/python/src/send_message.rs | 2 +-
rust-toolchain.toml | 2 +-
scripts/run-node-examples-from-readme.sh | 86 +-
scripts/run-rust-examples-from-readme.sh | 82 +-
89 files changed, 5269 insertions(+), 1106 deletions(-)
copy core/connectors/sinks/{stdout_sink => mongodb_sink}/Cargo.toml (75%)
create mode 100644 core/connectors/sinks/mongodb_sink/README.md
copy core/connectors/sinks/{postgres_sink => mongodb_sink}/config.toml (75%)
create mode 100644 core/connectors/sinks/mongodb_sink/src/lib.rs
create mode 100644
core/integration/tests/connectors/fixtures/mongodb/container.rs
copy core/integration/tests/connectors/fixtures/{elasticsearch =>
mongodb}/mod.rs (79%)
create mode 100644 core/integration/tests/connectors/fixtures/mongodb/sink.rs
copy core/integration/tests/connectors/{elasticsearch => mongodb}/mod.rs (94%)
create mode 100644 core/integration/tests/connectors/mongodb/mongodb_sink.rs
copy core/integration/tests/connectors/{iceberg => mongodb}/sink.toml (94%)
copy examples/node/src/{basic => tcp-tls}/consumer.ts (51%)
create mode 100644 examples/node/src/tcp-tls/producer.ts
copy examples/rust/src/{getting-started => tcp-tls}/consumer/main.rs (66%)
copy examples/rust/src/{getting-started => tcp-tls}/producer/main.rs (76%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/IggyAuthenticator.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/IggyFrameEncoder.java
create mode 100644 foreign/node/src/e2e/tls.system.e2e.ts
