This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch server-ng-pr5-responses-recut
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 41cf2c5ba refactor(server): split responses.rs by role and unify reply
framing
add 3c1a8ccf6 feat(python): add WebSocketConfig transport configuration
(#4000)
add 6c07954a0 chore(deps): Bump the csharp group with 1 update (#4087)
add a71ed7420 fix(metadata): roll deleted partitions and topics out of
parent stats (#4046)
add 2e3823196 feat(connectors): add RabbitMQ sink (#3973)
add a2a4a2cb9 fix(consensus): keep a replica off a hole in its committed
prefix (#4073)
add 8dde7e7f6 feat(java): let TCP clients run one I/O thread or share a
group (#4096)
add 422810f82 chore(deps): Bump the java group across 3 directories with 1
update (#4098)
add 051a5270f Merge branch 'master' into server-ng-pr5-responses-recut
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/pre-merge/action.yml | 5 +-
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/coverage-baseline.yml | 5 +-
.github/workflows/edge-release.yml | 1 +
Cargo.lock | 1495 ++++++++++++++------
Cargo.toml | 8 +-
bdd/java/build.gradle.kts | 2 +-
.../websocket_config/websocket_client_config.rs | 75 +-
core/common/src/types/streaming_stats.rs | 367 +++--
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/consensus/src/impls.rs | 440 ++++--
core/consensus/src/plane_helpers.rs | 169 ++-
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 +-
.../data_integrity/verify_after_server_restart.rs | 52 +
core/integration/tests/server/general.rs | 14 +-
.../scenarios/delete_stats_rollback_scenario.rs | 225 +++
core/integration/tests/server/scenarios/mod.rs | 137 +-
.../server/scenarios/purge_delete_scenario.rs | 26 +-
.../scenarios/stream_size_validation_scenario.rs | 140 +-
core/metadata/src/impls/metadata.rs | 18 +
core/metadata/src/stm/stream.rs | 899 +++++++++++-
core/partitions/src/iggy_partition.rs | 309 +++-
core/sdk/src/prelude.rs | 4 +-
core/server/src/boot/mod.rs | 16 -
core/server/src/boot/recovery.rs | 2 +-
core/server/src/http/metrics.rs | 71 +-
core/server/src/http/reads.rs | 10 +-
core/server/src/partition_reconciler.rs | 331 ++++-
core/server/src/responses.rs | 28 +-
core/shard/src/lib.rs | 997 +++++++++++--
core/shard/src/router.rs | 9 +
core/simulator/src/bin/workload-fuzz.rs | 44 +-
core/simulator/src/lib.rs | 138 +-
core/simulator/src/workload/invariants.rs | 164 ++-
core/simulator/src/workload/oracle.rs | 14 +
core/simulator/src/workload/state_checker.rs | 170 ++-
examples/java/build.gradle.kts | 2 +-
examples/python/getting-started/consumer.py | 17 +-
examples/python/getting-started/producer.py | 17 +-
foreign/csharp/Directory.Packages.props | 2 +-
foreign/java/README.md | 30 +
foreign/java/gradle/libs.versions.toml | 2 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 32 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 79 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 88 +-
.../client/blocking/tcp/IggyTcpClientBuilder.java | 31 +
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 94 ++
.../tcp/AsyncIggyTcpClientEventLoopGroupTest.java | 464 ++++++
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 4 +
foreign/python/README.md | 11 +-
foreign/python/apache_iggy.pyi | 209 ++-
foreign/python/docker-compose.test.yml | 2 +
foreign/python/src/client.rs | 21 +-
foreign/python/src/config.rs | 529 ++++++-
foreign/python/src/lib.rs | 4 +
foreign/python/tests/test_websocket_config.py | 522 +++++++
foreign/python/tests/utils.py | 11 +
scripts/bump-version.sh | 2 +-
72 files changed, 9297 insertions(+), 1225 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%)
create mode 100644
core/integration/tests/server/scenarios/delete_stats_rollback_scenario.rs
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientEventLoopGroupTest.java
create mode 100644 foreign/python/tests/test_websocket_config.py
