This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch server_perf_cut_extra_work
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 889f55506 fix(ci): gate poll diagnostics test imports
add a7b8288a7 fix(sdk): preserve group membership during primary polling
No new revisions were added by this update.
Summary of changes:
.../TcpMessageStream.PollRouting.cs | 457 ++++++++++++++++++
.../Implementations/TcpMessageStream.Vsr.cs | 2 +
.../IggyClient/Implementations/TcpMessageStream.cs | 26 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 2 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 3 +
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 27 +-
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 | 509 ++++++++++++++++++++
.../VsrTests/VsrProtocolDriftTests.cs | 1 +
foreign/go/README.md | 18 +
foreign/go/client/tcp/cluster.go | 1 +
foreign/go/client/tcp/tcp_core.go | 54 ++-
foreign/go/client/tcp/tcp_messaging.go | 12 +-
foreign/go/client/tcp/tcp_poll_routing.go | 417 ++++++++++++++++
foreign/go/client/tcp/tcp_poll_routing_test.go | 514 ++++++++++++++++++++
foreign/go/client/tcp/tcp_session_management.go | 4 +
foreign/go/client/tcp/tcp_user_management.go | 40 ++
foreign/go/contracts/client.go | 7 +
foreign/go/internal/command/code.go | 103 ++--
foreign/go/internal/vsr/header.go | 15 +
foreign/go/internal/vsr/header_test.go | 31 ++
foreign/go/internal/vsr/protocol_parity_test.go | 1 +
foreign/go/tests/e2e_test.go | 76 +++
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 71 ++-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 83 +++-
.../iggy/client/async/tcp/LoginRoutingHook.java | 3 +
.../iggy/client/async/tcp/MessagesTcpClient.java | 98 +++-
.../apache/iggy/client/async/tcp/PollRouter.java | 459 ++++++++++++++++++
.../iggy/client/async/tcp/UsersTcpClient.java | 13 +-
.../client/async/tcp/vsr/ConsensusSession.java | 18 +
.../iggy/client/async/tcp/vsr/VsrHeaders.java | 1 +
.../client/async/tcp/vsr/VsrResponseHandler.java | 7 +
.../java/org/apache/iggy/serde/CommandCode.java | 5 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 534 ++++++++++++++++++++-
foreign/node/src/client/client.socket.test.ts | 393 +++++++++++++++
foreign/node/src/client/client.socket.ts | 275 ++++++++++-
foreign/node/src/wire/command.code.ts | 3 +
.../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 +-
43 files changed, 4219 insertions(+), 106 deletions(-)
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
