This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/message-bus-multi-transport
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 54b5b8dce fix(message_bus): bound replica listener and survive
dispatch panics
add 73743401c refactor(message_bus): consume server-ng schema directly
add 7b70442b4 fix(message_bus): close TLS read cancel-safety + per-frame
flush hazards
add 707394cfd fix(message_bus): close PR3192 remaining review findings
add 75ab18b3c refactor(server-ng): remove request dedup module from PR3192
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
core/configs/src/lib.rs | 4 +-
core/configs/src/server_ng_config/defaults.rs | 167 +++++-
core/configs/src/server_ng_config/displays.rs | 86 ++-
core/configs/src/server_ng_config/message_bus.rs | 78 ++-
core/configs/src/server_ng_config/mod.rs | 3 +
.../{server_config => server_ng_config}/quic.rs | 10 +-
core/configs/src/server_ng_config/server_ng.rs | 6 +-
.../src/{server_config => server_ng_config}/tcp.rs | 7 +
.../websocket.rs | 10 +
core/message_bus/Cargo.toml | 1 +
core/message_bus/src/config.rs | 124 +++--
core/message_bus/src/error.rs | 1 +
core/message_bus/src/installer/conn_info.rs | 5 +
core/message_bus/src/installer/mod.rs | 8 +-
core/message_bus/src/installer/quic.rs | 22 +-
core/message_bus/src/installer/replica.rs | 12 +-
core/message_bus/src/installer/tcp.rs | 3 +-
core/message_bus/src/lib.rs | 77 ++-
.../src/lifecycle/connection_registry.rs | 12 +-
core/message_bus/src/lifecycle/shutdown.rs | 8 +-
core/message_bus/src/transports/mod.rs | 9 +
core/message_bus/src/transports/quic.rs | 34 +-
core/message_bus/src/transports/tcp.rs | 14 +
core/message_bus/src/transports/tcp_tls.rs | 448 +++++++++++++---
core/message_bus/src/transports/ws.rs | 27 +-
core/message_bus/src/transports/wss.rs | 27 +-
core/message_bus/tests/common/mod.rs | 5 +-
core/message_bus/tests/installer_panic_cleanup.rs | 104 ++++
core/message_bus/tests/quic_client_roundtrip.rs | 2 +
core/message_bus/tests/tcp_tls_client_listener.rs | 3 +-
core/message_bus/tests/tcp_tls_client_roundtrip.rs | 1 +
core/message_bus/tests/ws_client_roundtrip.rs | 1 +
core/message_bus/tests/wss_client_listener.rs | 3 +-
core/message_bus/tests/wss_client_roundtrip.rs | 1 +
core/server-ng/config.toml | 33 +-
core/server-ng/src/dedup.rs | 582 ---------------------
core/server-ng/src/lib.rs | 5 -
core/shard/src/coordinator.rs | 8 +-
core/shard/src/router.rs | 2 +-
40 files changed, 1144 insertions(+), 810 deletions(-)
copy core/configs/src/{server_config => server_ng_config}/quic.rs (86%)
copy core/configs/src/{server_config => server_ng_config}/tcp.rs (85%)
copy core/configs/src/{server_config => server_ng_config}/websocket.rs (89%)
delete mode 100644 core/server-ng/src/dedup.rs
