This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch
dependabot/nuget/foreign/csharp/csharp-685ef18fec
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 470c25afd chore(deps): Bump the csharp group with 5 updates
add b4dd04ce2 fix(cluster): preserve group membership and reduce
produce/poll overhead (#4169)
add ce83ed700 Merge branch 'master' into
dependabot/nuget/foreign/csharp/csharp-685ef18fec
No new revisions were added by this update.
Summary of changes:
core/binary_protocol/src/codes.rs | 16 +
core/binary_protocol/src/dispatch.rs | 8 +
.../src/requests/consumer_offsets/mod.rs | 62 +
.../src/requests/system/attach_consumer_session.rs | 87 ++
core/binary_protocol/src/requests/system/mod.rs | 2 +
core/binary_protocol/src/responses/messages/mod.rs | 2 +
.../src/responses/messages/poll_routing.rs | 95 ++
.../src/traits/binary_impls/consumer_offsets.rs | 4 +-
core/common/src/traits/binary_impls/messages.rs | 13 +-
core/common/src/traits/binary_impls/users.rs | 3 +
core/common/src/traits/binary_transport.rs | 35 +-
core/common/src/wire_conversions.rs | 15 +
core/configs/src/server_config/defaults.rs | 1 +
core/configs/src/server_config/message_bus.rs | 38 +-
core/configs/src/server_config/partition.rs | 4 +-
core/configs/src/server_config/server.rs | 2 +-
core/configs/src/server_config/sharding.rs | 6 +-
core/configs/src/server_config/validators.rs | 8 +-
core/consensus/src/client_table.rs | 114 ++
.../tests/cluster/partition_primary_routing.rs | 831 ++++++++++++-
.../tests/cluster/register_forwarding.rs | 2 +-
.../server/scenarios/authentication_scenario.rs | 51 +-
.../scenarios/reconnect_after_restart_scenario.rs | 13 +-
.../scenarios/segment_rotation_race_scenario.rs | 2 +-
.../tests/server/scenarios/system_scenario.rs | 39 +-
core/integration/tests/server/specific.rs | 2 +-
core/journal/src/partition_journal.rs | 183 ++-
core/message_bus/src/config.rs | 6 +-
core/message_bus/src/installer/tcp.rs | 4 +-
core/metadata/src/stm/stream.rs | 158 ++-
core/partitions/Cargo.toml | 7 +
core/partitions/src/iggy_partition.rs | 717 ++++++++---
core/partitions/src/journal.rs | 300 ++++-
core/partitions/src/persistence.rs | 113 +-
core/partitions/src/poll_plan.rs | 592 +++++++--
core/sdk/Cargo.toml | 1 +
core/sdk/README.md | 11 +
core/sdk/src/leader_aware.rs | 19 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/poll_routing.rs | 1284 ++++++++++++++++++++
core/sdk/src/quic/quic_client.rs | 111 ++
core/sdk/src/tcp/tcp_client.rs | 263 +++-
core/sdk/src/vsr.rs | 18 +
core/sdk/src/websocket/websocket_client.rs | 221 +++-
core/server/README.md | 8 +
core/server/config.toml | 49 +-
core/server/src/dispatch/authz.rs | 26 +-
core/server/src/dispatch/mod.rs | 36 +-
core/server/src/dispatch/partition.rs | 156 ++-
core/server/src/dispatch/reads.rs | 237 +++-
core/server/src/dispatch/submit.rs | 17 +
core/server/src/http.rs | 13 +-
core/server/src/http/forward.rs | 424 +++++--
core/server/src/http/state.rs | 2 +-
core/server/src/http/submit.rs | 2 +
core/server/src/responses.rs | 13 +-
core/server/src/session_manager.rs | 120 ++
core/server_common/src/send_messages.rs | 78 +-
core/shard/Cargo.toml | 2 +-
core/shard/src/lib.rs | 40 +-
core/shard/src/metrics.rs | 35 +
core/shard/src/poll.rs | 127 +-
core/shard/src/poll/completion.rs | 16 +-
core/shard/src/poll/completion_tests.rs | 502 +++++++-
core/shard/src/poll/timeout_tests.rs | 4 +-
core/shard/src/router.rs | 18 +-
core/simulator/src/storage/tests.rs | 37 +
.../TcpMessageStream.PollRouting.cs | 463 +++++++
.../Implementations/TcpMessageStream.Vsr.cs | 8 +
.../IggyClient/Implementations/TcpMessageStream.cs | 26 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 2 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 4 +
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 28 +-
foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs | 1 +
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 5 +-
foreign/csharp/Iggy_SDK_Tests/VsrTests/MockNode.cs | 14 +-
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 635 ++++++++++
.../VsrTests/VsrProtocolDriftTests.cs | 1 +
foreign/csharp/README.md | 7 +
foreign/go/README.md | 31 +
foreign/go/client/tcp/cluster.go | 7 +
foreign/go/client/tcp/tcp_core.go | 70 +-
foreign/go/client/tcp/tcp_messaging.go | 17 +-
foreign/go/client/tcp/tcp_poll_routing.go | 435 +++++++
foreign/go/client/tcp/tcp_poll_routing_test.go | 815 +++++++++++++
foreign/go/client/tcp/tcp_session_management.go | 4 +
foreign/go/client/tcp/tcp_testing_test.go | 6 +-
foreign/go/client/tcp/tcp_user_management.go | 40 +
foreign/go/contracts/client.go | 7 +
foreign/go/internal/command/code.go | 104 +-
foreign/go/internal/vsr/header.go | 14 +
foreign/go/internal/vsr/header_test.go | 31 +
foreign/go/internal/vsr/protocol_parity_test.go | 1 +
foreign/go/tests/e2e_test.go | 88 ++
foreign/java/README.md | 8 +
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 130 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 136 ++-
.../iggy/client/async/tcp/LoginRoutingHook.java | 3 +
.../iggy/client/async/tcp/MessagesTcpClient.java | 168 ++-
.../apache/iggy/client/async/tcp/PollRouter.java | 499 ++++++++
.../iggy/client/async/tcp/UsersTcpClient.java | 15 +-
.../client/async/tcp/vsr/ConsensusSession.java | 18 +
.../iggy/client/async/tcp/vsr/VsrHeaders.java | 1 +
.../client/async/tcp/vsr/VsrResponseHandler.java | 6 +
.../org/apache/iggy/serde/BytesSerializer.java | 194 ++-
.../java/org/apache/iggy/serde/CommandCode.java | 5 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 1026 +++++++++++++++-
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 55 +
.../async/tcp/vsr/VsrResponseHandlerTest.java | 18 +
.../iggy/serde/MessagesBatchWireFormatTest.java | 123 +-
foreign/node/README.md | 7 +
foreign/node/src/client/client.connection.ts | 4 +-
foreign/node/src/client/client.socket.test.ts | 641 ++++++++++
foreign/node/src/client/client.socket.ts | 302 ++++-
foreign/node/src/wire/command.code.ts | 4 +
.../src/wire/message/poll-messages.command.test.ts | 14 +
.../node/src/wire/message/poll-messages.command.ts | 5 +-
foreign/node/src/wire/vsr/header.ts | 1 +
foreign/node/src/wire/vsr/index.ts | 2 +-
119 files changed, 12799 insertions(+), 876 deletions(-)
create mode 100644
core/binary_protocol/src/requests/system/attach_consumer_session.rs
create mode 100644 core/binary_protocol/src/responses/messages/poll_routing.rs
create mode 100644 core/sdk/src/poll_routing.rs
create mode 100644
foreign/csharp/Iggy_SDK/IggyClient/Implementations/TcpMessageStream.PollRouting.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs
create mode 100644 foreign/go/client/tcp/tcp_poll_routing.go
create mode 100644 foreign/go/client/tcp/tcp_poll_routing_test.go
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PollRouter.java
