This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch simulator-liveness
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 5040c5db4 fix(consensus): let a probe answer expose a divergent head
add f77d64b2f fix(server): distribute TCP-TLS and WSS connections across
shards (#4193)
add 71f29618b fix(cluster): prevent spurious heartbeat elections (#4194)
add 5c571cedd chore(deps): Bump the github-actions group with 2 updates
(#4197)
add 003cfe845 docs(node): fix "diclaimer" typo in README (#4188)
add 01e123dc0 Merge branch 'master' into simulator-liveness
No new revisions were added by this update.
Summary of changes:
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/_common.yml | 4 +-
.github/workflows/_test.yml | 2 +-
.github/workflows/coverage-baseline.yml | 6 +-
.github/workflows/post-merge.yml | 2 +-
core/configs/src/server_config/message_bus.rs | 3 +-
core/consensus/src/impls.rs | 131 ++++++++-
core/integration/tests/server/specific.rs | 187 ++++++++++++-
core/message_bus/src/client_listener/mod.rs | 31 ++-
core/message_bus/src/client_listener/tcp_tls.rs | 27 +-
core/message_bus/src/client_listener/wss.rs | 16 +-
core/message_bus/src/connector.rs | 38 +--
core/message_bus/src/fd_transfer.rs | 26 +-
core/message_bus/src/installer/common.rs | 7 +-
core/message_bus/src/installer/mod.rs | 56 +++-
core/message_bus/src/installer/replica.rs | 14 +-
core/message_bus/src/installer/tcp.rs | 5 +
core/message_bus/src/installer/tcp_tls.rs | 9 +-
core/message_bus/src/installer/wss.rs | 5 +-
core/message_bus/src/lib.rs | 52 ++--
.../src/lifecycle/connection_registry.rs | 11 +-
core/message_bus/src/replica/io.rs | 45 ++-
core/message_bus/src/transports/tcp_tls.rs | 6 +-
core/message_bus/src/transports/wss.rs | 28 +-
core/message_bus/tests/backpressure.rs | 11 +-
core/message_bus/tests/common/mod.rs | 111 +++++++-
core/message_bus/tests/connection_lost_notify.rs | 4 +-
core/message_bus/tests/directional_connection.rs | 13 +-
core/message_bus/tests/head_of_line.rs | 4 +-
core/message_bus/tests/replica_roundtrip.rs | 4 +-
core/message_bus/tests/replica_tls_bench.rs | 4 +-
core/message_bus/tests/replica_tls_mitm.rs | 4 +-
core/message_bus/tests/replica_tls_roundtrip.rs | 8 +-
core/message_bus/tests/shard_zero_gating.rs | 11 +-
core/message_bus/tests/tcp_tls_client_listener.rs | 5 +
core/message_bus/tests/tcp_tls_client_roundtrip.rs | 3 +-
core/message_bus/tests/vectored_batch.rs | 11 +-
core/message_bus/tests/wss_client_listener.rs | 108 ++++++++
core/message_bus/tests/wss_client_roundtrip.rs | 3 +-
core/server/config.toml | 3 +-
core/server/src/boot/listeners.rs | 64 ++---
core/server/src/boot/mod.rs | 7 +-
core/server/src/dispatch/mod.rs | 11 +-
core/server/src/dispatch/test_support.rs | 18 +-
core/shard/src/coordinator.rs | 308 +++++++++++++++++++--
core/shard/src/lib.rs | 23 +-
core/shard/src/router.rs | 24 ++
core/simulator/src/bus.rs | 22 +-
foreign/node/README.md | 2 +-
49 files changed, 1159 insertions(+), 340 deletions(-)
