This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch bus
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7edc32cd0 feat(shard): wire bus ConnectionLost callback into shard-0
inbox
add 8ca322d5a fix(message_bus): close PR 3134 critical review findings
No new revisions were added by this update.
Summary of changes:
core/configs/src/server_config/cluster.rs | 1 +
core/configs/src/server_config/validators.rs | 76 +++++
core/message_bus/Cargo.toml | 2 +-
core/message_bus/src/framing.rs | 12 +-
core/message_bus/src/installer.rs | 173 +++++++---
core/message_bus/src/lib.rs | 12 +-
.../src/lifecycle/connection_registry.rs | 359 +++++++++++++++++++--
core/message_bus/src/lifecycle/mod.rs | 4 +-
core/message_bus/src/writer_task.rs | 2 +-
core/message_bus/tests/duplicate_client_id.rs | 43 +++
core/partitions/src/iggy_partition.rs | 90 ++++--
core/server/src/main.rs | 53 ---
12 files changed, 657 insertions(+), 170 deletions(-)
