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
discard 0ef2afcc3 feat(message_bus): thread schema [quic] into transport config
discard 717af0eca docs(message_bus): tighten transport-trait + ws/quic
invariants
discard 8b7a36981 chore(message_bus): allow iter_with_drain on hoisted batch
loops
discard 75dda0ea3 fix(message_bus): bound the full TLS close sequence by
close_grace
discard d3d09d438 docs(message_bus): drop fragile file:line cites and finding
tags
discard 23876f704 perf(message_bus): hoist batch buffer in tcp_tls/ws/wss pumps
discard 0ce13ae7d docs(message_bus): correct SO_KEEPALIVE doc at four sites
discard 8af15b42a docs(message_bus): flag deleted replica-plane authn at
listener auth section
discard c9f5aeb4a feat(message_bus): add QUIC, TCP-TLS, WS, WSS client
transports
add 842538572 test(csharp): add leader_redirection scenario to BDD tests
(#3193)
add 4f55e9563 feat(connectors): implement Avro payload support with
separate encoder, decoder and transform crates (#3141)
add 87e22a1cc feat(go): add delete segments support (#3191)
add d484c107e feat(message_bus): add QUIC, TCP-TLS, WS, WSS client
transports
add 57a0051f7 docs(message_bus): flag deleted replica-plane authn at
listener auth section
add f26ea7852 docs(message_bus): correct SO_KEEPALIVE doc at four sites
add 361bb73f9 perf(message_bus): hoist batch buffer in tcp_tls/ws/wss pumps
add ed0077397 docs(message_bus): drop fragile file:line cites and finding
tags
add 3d080b7aa fix(message_bus): bound the full TLS close sequence by
close_grace
add cdbbcc757 chore(message_bus): allow iter_with_drain on hoisted batch
loops
add bd42fe829 docs(message_bus): tighten transport-trait + ws/quic
invariants
add 7ee1bf18d feat(message_bus): thread schema [quic] into transport config
add 133e90887 test(message_bus): lock tcp_tls cancel-safety, doc authn
boundary
add dc231f993 style(message_bus): drop F-tag from tcp_tls rustdoc
add 7d1c3b838 docs(message_bus): tighten replica trust boundary statement
add 89124e329 docs(message_bus): correct batching, ALPN, and ws_config doc
lies
add af8749eb8 docs(message_bus): clear PR-introduced rustdoc broken-link
warnings
add f56ca0d3d fix(configs): align QUIC byte-size units to KiB and pin
parity
add 44d77571f fix(configs): tighten MessageBusConfig validation
add 098aebc33 fix(configs): validate QuicConfig field ranges at boot
add 283bde926 fix(configs): wire TcpSocket and MessageBus defaults to
SERVER_NG_CONFIG
add ba6d8e21e fix(message_bus): reap finished background tasks in
track_background
add cb0ef1533 test(message_bus): pin background_tasks reap and
post-shutdown drain
add 75de7d84b fix(message_bus): bound QUIC reader+writer drain by
close_grace
add 208a908da fix(message_bus): drive tls.shutdown under close_grace on
WSS shutdown
add f4d8f8763 test(shard): cover delegate_client and delegate_ws_client
paths
add 85504a383 style(message_bus): clear clippy doc-pedantic warnings
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0ef2afcc3)
\
N -- N -- N refs/heads/feat/message-bus-multi-transport
(85504a383)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
Cargo.toml | 3 +-
bdd/docker-compose.yml | 9 +-
...eature_delete.go => segments_feature_delete.go} | 35 +-
core/configs/src/server_ng_config/defaults.rs | 50 +-
core/configs/src/server_ng_config/message_bus.rs | 100 ++++
core/configs/src/server_ng_config/quic.rs | 154 +++++-
core/configs/src/server_ng_config/validators.rs | 4 +
core/configs/src/server_ng_config/websocket.rs | 2 +-
core/connectors/runtime/src/configs/connectors.rs | 21 +-
core/connectors/runtime/src/sink.rs | 28 +-
core/connectors/runtime/src/source.rs | 21 +-
core/connectors/sdk/Cargo.toml | 1 +
core/connectors/sdk/src/decoders/avro.rs | 442 +++++++++++++++
core/connectors/sdk/src/decoders/mod.rs | 1 +
core/connectors/sdk/src/encoders/avro.rs | 604 +++++++++++++++++++++
core/connectors/sdk/src/encoders/flatbuffer.rs | 1 +
core/connectors/sdk/src/encoders/mod.rs | 1 +
core/connectors/sdk/src/encoders/proto.rs | 12 +
core/connectors/sdk/src/lib.rs | 17 +-
core/connectors/sdk/src/transforms/avro_convert.rs | 398 ++++++++++++++
core/connectors/sdk/src/transforms/mod.rs | 8 +
.../connectors/sdk/src/transforms/proto_convert.rs | 17 +
core/connectors/sinks/http_sink/src/lib.rs | 8 +
core/message_bus/src/client_listener/mod.rs | 37 ++
core/message_bus/src/config.rs | 97 +++-
core/message_bus/src/installer/quic.rs | 3 +-
core/message_bus/src/lib.rs | 75 ++-
core/message_bus/src/replica/listener.rs | 45 +-
core/message_bus/src/transports/mod.rs | 29 +-
core/message_bus/src/transports/quic.rs | 60 +-
core/message_bus/src/transports/tcp_tls.rs | 36 +-
core/message_bus/src/transports/wss.rs | 18 +-
core/message_bus/tests/installer_panic_cleanup.rs | 12 +
core/message_bus/tests/tcp_tls_cancel_safe.rs | 167 ++++++
core/server-ng/config.toml | 13 +-
core/shard/src/coordinator.rs | 64 +++
.../Iggy_SDK.Tests.BDD/Context/TestContext.cs | 5 +
.../csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs | 19 +-
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 9 +-
.../StepDefinitions/LeaderRedirectionSteps.cs | 317 +++++++++++
...{tcp_utilities.go => tcp_segment_management.go} | 26 +-
foreign/go/contracts/client.go | 9 +
foreign/go/internal/command/code.go | 1 +
.../command/segment.go} | 29 +-
.../command/{topic_test.go => segment_test.go} | 35 +-
46 files changed, 2864 insertions(+), 180 deletions(-)
copy bdd/go/tests/tcp_test/{partitions_feature_delete.go =>
segments_feature_delete.go} (75%)
create mode 100644 core/connectors/sdk/src/decoders/avro.rs
create mode 100644 core/connectors/sdk/src/encoders/avro.rs
create mode 100644 core/connectors/sdk/src/transforms/avro_convert.rs
create mode 100644 core/message_bus/tests/tcp_tls_cancel_safe.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.BDD/StepDefinitions/LeaderRedirectionSteps.cs
copy foreign/go/client/tcp/{tcp_utilities.go => tcp_segment_management.go}
(75%)
copy foreign/go/{client/tcp/tcp_clients_management.go =>
internal/command/segment.go} (59%)
copy foreign/go/internal/command/{topic_test.go => segment_test.go} (58%)
