This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch bus
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c223852c1 feat(message_bus): async fire-and-forget transport for VSR
consensus
add da31b5226 docs(shard): document ShardZeroCoordinator sender ordering
contract
add c885e7546 fix(message_bus): downgrade duplicate client-id panic to warn
add 9d8cdcf72 perf(message_bus): parallel drain with FuturesUnordered
add 7eb981398 perf(message_bus): array-backed ReplicaRegistry for u8 keys
add 73636f47e perf(message_bus): pass Frozen through MessageBus trait for
zero-copy fan-out
No new revisions were added by this update.
Summary of changes:
core/consensus/src/impls.rs | 6 +-
core/consensus/src/plane_helpers.rs | 30 +-
core/message_bus/src/installer.rs | 14 +-
core/message_bus/src/lib.rs | 61 ++--
.../src/lifecycle/connection_registry.rs | 317 ++++++++++++++++++---
core/message_bus/src/lifecycle/mod.rs | 2 +-
core/message_bus/src/writer_task.rs | 10 +-
core/message_bus/tests/backpressure.rs | 2 +-
core/message_bus/tests/duplicate_client_id.rs | 75 +++++
core/message_bus/tests/graceful_shutdown.rs | 5 +-
core/message_bus/tests/head_of_line.rs | 6 +-
core/message_bus/tests/replica_roundtrip.rs | 6 +-
core/message_bus/tests/tcp_client_roundtrip.rs | 2 +-
core/message_bus/tests/vectored_batch.rs | 2 +-
core/metadata/src/impls/metadata.rs | 8 +-
core/partitions/src/iggy_partition.rs | 2 +-
core/shard/src/coordinator.rs | 23 +-
core/shard/src/lib.rs | 67 ++---
core/simulator/src/bus.rs | 27 +-
19 files changed, 507 insertions(+), 158 deletions(-)
create mode 100644 core/message_bus/tests/duplicate_client_id.rs
