This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch partitions_refactor
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d6625713c remove plan
add 8c1d844e6 refactor(go): move command /foreign/go/internal/command
(#2881)
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 7e4d5f6f0 Merge branch 'master' into partitions_refactor
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/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 | 24 +-
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/cluster.go | 7 +-
.../go/client/tcp/tcp_access_token_management.go | 7 +-
foreign/go/client/tcp/tcp_clients_management.go | 5 +-
.../go/client/tcp/tcp_consumer_group_management.go | 23 +-
foreign/go/client/tcp/tcp_core.go | 22 +-
foreign/go/client/tcp/tcp_messaging.go | 5 +-
foreign/go/client/tcp/tcp_offset_management.go | 7 +-
foreign/go/client/tcp/tcp_partition_management.go | 5 +-
foreign/go/client/tcp/tcp_session_management.go | 7 +-
foreign/go/client/tcp/tcp_stream_management.go | 11 +-
foreign/go/client/tcp/tcp_topic_management.go | 11 +-
foreign/go/client/tcp/tcp_user_management.go | 15 +-
foreign/go/client/tcp/tcp_utilities.go | 5 +-
foreign/go/contracts/access_tokens.go | 45 -
foreign/go/contracts/change_password.go | 52 -
foreign/go/contracts/cluster.go | 29 -
foreign/go/contracts/command_codes.go | 71 --
foreign/go/contracts/consumer_groups.go | 97 --
foreign/go/contracts/create_stream.go | 39 -
foreign/go/contracts/create_topic.go | 91 --
foreign/go/contracts/create_user.go | 77 --
foreign/go/contracts/delete_stream.go | 30 -
foreign/go/contracts/delete_topic.go | 31 -
foreign/go/contracts/delete_user.go | 30 -
foreign/go/contracts/get_stream.go | 30 -
foreign/go/contracts/get_streams.go | 28 -
foreign/go/contracts/get_topic.go | 31 -
foreign/go/contracts/get_topics.go | 30 -
foreign/go/contracts/get_user.go | 30 -
foreign/go/contracts/get_users.go | 28 -
foreign/go/contracts/identifier.go | 2 +-
.../contracts/{get_stats.go => identity_info.go} | 13 +-
foreign/go/contracts/{ping.go => offset.go} | 12 +-
foreign/go/contracts/partitions.go | 60 -
foreign/go/contracts/poll_messages.go | 93 --
foreign/go/contracts/poll_messages_test.go | 85 --
foreign/go/contracts/send_messages_test.go | 86 --
foreign/go/contracts/update_stream_test.go | 48 -
foreign/go/contracts/update_topic.go | 76 --
foreign/go/contracts/update_user_permissions.go | 63 -
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
.../command/access_token.go} | 40 +-
foreign/go/internal/command/code.go | 71 ++
.../ping.go => internal/command/command.go} | 15 +-
.../command/consumer_group.go} | 94 +-
.../command/message.go} | 107 +-
foreign/go/internal/command/message_test.go | 150 +++
.../offsets.go => internal/command/offset.go} | 44 +-
foreign/go/internal/command/partition.go | 84 ++
.../go/{contracts => internal/command}/session.go | 19 +-
.../command/stream.go} | 66 +-
.../command/stream_test.go} | 30 +-
.../command.go => internal/command/system.go} | 57 +-
foreign/go/internal/command/topic.go | 185 +++
.../command/topic_test.go} | 10 +-
.../{contracts => internal/command}/update_user.go | 16 +-
foreign/go/internal/command/user.go | 192 +++
.../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 +-
143 files changed, 6340 insertions(+), 2627 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%)
delete mode 100644 foreign/go/contracts/change_password.go
delete mode 100644 foreign/go/contracts/cluster.go
delete mode 100644 foreign/go/contracts/command_codes.go
delete mode 100644 foreign/go/contracts/create_stream.go
delete mode 100644 foreign/go/contracts/create_topic.go
delete mode 100644 foreign/go/contracts/create_user.go
delete mode 100644 foreign/go/contracts/delete_stream.go
delete mode 100644 foreign/go/contracts/delete_topic.go
delete mode 100644 foreign/go/contracts/delete_user.go
delete mode 100644 foreign/go/contracts/get_stream.go
delete mode 100644 foreign/go/contracts/get_streams.go
delete mode 100644 foreign/go/contracts/get_topic.go
delete mode 100644 foreign/go/contracts/get_topics.go
delete mode 100644 foreign/go/contracts/get_user.go
delete mode 100644 foreign/go/contracts/get_users.go
rename foreign/go/contracts/{get_stats.go => identity_info.go} (80%)
copy foreign/go/contracts/{ping.go => offset.go} (83%)
delete mode 100644 foreign/go/contracts/poll_messages.go
delete mode 100644 foreign/go/contracts/poll_messages_test.go
delete mode 100644 foreign/go/contracts/send_messages_test.go
delete mode 100644 foreign/go/contracts/update_stream_test.go
delete mode 100644 foreign/go/contracts/update_topic.go
delete mode 100644 foreign/go/contracts/update_user_permissions.go
copy foreign/go/{contracts/access_tokens.go =>
internal/command/access_token.go} (80%)
create mode 100644 foreign/go/internal/command/code.go
rename foreign/go/{contracts/ping.go => internal/command/command.go} (82%)
copy foreign/go/{contracts/consumer_groups.go =>
internal/command/consumer_group.go} (61%)
rename foreign/go/{contracts/send_messages.go => internal/command/message.go}
(53%)
create mode 100644 foreign/go/internal/command/message_test.go
rename foreign/go/{contracts/offsets.go => internal/command/offset.go} (83%)
create mode 100644 foreign/go/internal/command/partition.go
rename foreign/go/{contracts => internal/command}/session.go (86%)
rename foreign/go/{contracts/update_stream.go => internal/command/stream.go}
(50%)
rename foreign/go/{contracts/create_stream_test.go =>
internal/command/stream_test.go} (66%)
rename foreign/go/{contracts/command.go => internal/command/system.go} (65%)
create mode 100644 foreign/go/internal/command/topic.go
rename foreign/go/{contracts/update_topic_test.go =>
internal/command/topic_test.go} (91%)
rename foreign/go/{contracts => internal/command}/update_user.go (86%)
create mode 100644 foreign/go/internal/command/user.go
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
