This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch fix/integration-flaky-tests
in repository https://gitbox.apache.org/repos/asf/iggy.git
from f0ba62494 fix(server-ng): make partition reconvergence safe for
in-flight sends
add ab944b558 chore(deps): Bump the csharp group with 8 updates (#3759)
add cfa104c37 feat(server-ng): add cluster.nodes.advertised_address for
clients (#3757)
add 89045771e feat(consensus): rework client table for session resume
across restarts (#3753)
add f88e8a862 feat(server-ng): harden configuration surface (#3756)
add b6a2f81c0 fix(sdk): forward unknown command codes instead of rejecting
them (#3766)
add ba541bb9c fix(server-ng): stop restart panic when WAL replay recovers
sessions (#3768)
add 91fcb9300 fix(ci): propagate failures in pre-commit hooks (#3743)
add 265bd265a chore(deps): Bump com.gradleup.shadow from 9.5.1 to 9.6.0 in
/foreign/java in the java group across 1 directory (#3771)
add 3153e456f chore(deps): Bump the github-actions group with 5 updates
(#3772)
add 61cc797c4 Merge branch 'master' into fix/integration-flaky-tests
No new revisions were added by this update.
Summary of changes:
.github/workflows/_build_python_wheels.yml | 14 +-
.github/workflows/_build_rust_artifacts.yml | 6 +-
.github/workflows/_common.yml | 32 +-
.github/workflows/_detect.yml | 2 +-
.github/workflows/_publish_rust_crates.yml | 2 +-
.github/workflows/_test.yml | 2 +-
.github/workflows/_test_bdd.yml | 2 +-
.github/workflows/_test_examples.yml | 6 +-
.github/workflows/coverage-baseline.yml | 26 +-
.github/workflows/edge-release.yml | 2 +-
.github/workflows/post-merge.yml | 4 +-
.github/workflows/publish.yml | 16 +-
.pre-commit-config.yaml | 8 +-
Cargo.lock | 6 +-
Cargo.toml | 6 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/consensus/header.rs | 55 +-
core/binary_protocol/src/consensus/operation.rs | 3 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 4 +-
core/configs/src/lib.rs | 5 +-
core/configs/src/server_ng_config/cluster.rs | 963 +++++++++++++++-
core/configs/src/server_ng_config/defaults.rs | 63 +-
core/configs/src/server_ng_config/displays.rs | 12 +-
core/configs/src/server_ng_config/message_bus.rs | 137 +--
core/configs/src/server_ng_config/metadata.rs | 89 +-
core/configs/src/server_ng_config/mod.rs | 1 +
core/configs/src/server_ng_config/partition.rs | 212 ++++
core/configs/src/server_ng_config/server_ng.rs | 2 +
core/configs/src/server_ng_config/validators.rs | 290 +++++
core/configs/src/server_ng_config/websocket.rs | 105 +-
core/consensus/src/client_table.rs | 1181 ++++++++++++--------
core/consensus/src/impls.rs | 163 ++-
core/consensus/src/lib.rs | 7 +-
core/consensus/src/metadata_helpers.rs | 492 ++++----
core/consensus/src/plane_helpers.rs | 74 +-
core/consensus/src/vsr_timeout.rs | 83 +-
.../tests/cluster/client_table_restart.rs | 382 +++++--
core/integration/tests/sdk/raw.rs | 13 +-
.../scenarios/reconnect_after_restart_scenario.rs | 9 +
core/message_bus/src/cache/connection.rs | 2 -
core/message_bus/src/client_listener/mod.rs | 2 +-
core/message_bus/src/config.rs | 56 +-
core/metadata/src/impls/metadata.rs | 795 ++++++++++---
core/metadata/src/impls/recovery.rs | 287 ++++-
core/metadata/src/lib.rs | 2 +-
core/metadata/src/stm/stream.rs | 6 +-
core/metadata/src/stm/user.rs | 2 +-
core/partitions/src/journal.rs | 25 +-
core/partitions/src/lib.rs | 1 +
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/client.rs | 5 +-
core/sdk/src/vsr.rs | 88 +-
core/server-ng/Cargo.toml | 5 +-
core/server-ng/config.toml | 200 +++-
core/server-ng/src/auth.rs | 5 +-
core/server-ng/src/bootstrap.rs | 477 +++++++-
core/server-ng/src/cluster_meta.rs | 81 +-
core/server-ng/src/dispatch.rs | 103 +-
core/server-ng/src/http.rs | 10 +-
core/server-ng/src/http/error.rs | 161 ++-
core/server-ng/src/http/handlers.rs | 19 +-
core/server-ng/src/http/reads.rs | 114 +-
core/server-ng/src/http/session.rs | 73 +-
core/server-ng/src/http/state.rs | 109 +-
core/server-ng/src/http/submit.rs | 90 +-
core/server-ng/src/http/tls.rs | 29 +-
core/server-ng/src/login_register.rs | 9 +-
core/server-ng/src/partition_helpers.rs | 20 +-
core/server-ng/src/session_manager.rs | 26 +
core/server-ng/src/users.rs | 10 +-
core/server_common/src/consensus_message.rs | 68 ++
core/shard/src/coordinator.rs | 232 +++-
core/shard/src/lib.rs | 73 +-
core/simulator/src/workload/mod.rs | 4 +-
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 8 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 10 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 4 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.Shared.csproj | 2 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 10 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 10 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 4 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 10 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 10 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 4 +-
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 4 +-
foreign/csharp/Directory.Packages.props | 6 +-
foreign/java/gradle/libs.versions.toml | 2 +-
foreign/python/Cargo.toml | 2 +-
justfile | 4 +-
92 files changed, 6237 insertions(+), 1535 deletions(-)
create mode 100644 core/configs/src/server_ng_config/partition.rs
