This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/partition-routing
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 94aa5de40 feat(server): route partition requests to their primaries
add ffd3098ab fix(simulator): avoid private links in public rustdoc
add e4b41305c fix(sdk): migrate partition routing to the PR4 protocol
No new revisions were added by this update.
Summary of changes:
bdd/go/tests/tcp_test/messages_feature_send.go | 4 +-
bdd/go/tests/tcp_test/offset_feature_delete.go | 2 +-
core/simulator/src/workload/options.rs | 2 +-
core/simulator/src/workload/oracle.rs | 2 +-
foreign/cpp/src/lib.rs | 1 +
foreign/cpp/src/type_conversion.rs | 1 +
foreign/csharp/Iggy_SDK/Contracts/ClusterNode.cs | 3 +
.../SdkVersion.cs => Contracts/PartitionRoute.cs} | 13 +-
.../Exceptions/IggyInvalidStatusCodeException.cs | 2 +
.../TcpMessageStream.PollRouting.cs | 420 ++++++++----------
.../Implementations/TcpMessageStream.Vsr.cs | 51 ++-
.../IggyClient/Implementations/TcpMessageStream.cs | 101 +----
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 21 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 +-
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 8 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 1 +
foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 2 +-
.../ConsumerTests/OffsetContinuationTests.cs | 9 +-
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 27 +-
.../VsrTests/EndpointFailoverTests.cs | 21 +-
.../Iggy_SDK_Tests/VsrTests/GroupPollingTests.cs | 1 +
foreign/csharp/Iggy_SDK_Tests/VsrTests/MockNode.cs | 41 +-
.../VsrTests/PartitionContextTests.cs | 54 +--
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 427 ++++++++++++++++--
foreign/go/README.md | 2 +-
foreign/go/client/tcp/cluster.go | 12 +
foreign/go/client/tcp/tcp_core.go | 74 ++--
foreign/go/client/tcp/tcp_core_review_test.go | 2 +-
foreign/go/client/tcp/tcp_core_test.go | 35 +-
foreign/go/client/tcp/tcp_failover_test.go | 4 +-
foreign/go/client/tcp/tcp_messaging.go | 174 ++++----
foreign/go/client/tcp/tcp_offset_management.go | 27 +-
foreign/go/client/tcp/tcp_partition_management.go | 3 +
foreign/go/client/tcp/tcp_poll_routing.go | 247 ++++++-----
foreign/go/client/tcp/tcp_poll_routing_test.go | 450 +++++++++++++++----
foreign/go/client/tcp/tcp_stream_management.go | 1 +
foreign/go/client/tcp/tcp_testing_test.go | 19 +-
foreign/go/client/tcp/tcp_topic_cache.go | 44 +-
foreign/go/client/tcp/tcp_topic_cache_test.go | 71 ++-
foreign/go/contracts/cluster_metadata_test.go | 56 ++-
foreign/go/contracts/cluster_node.go | 10 +-
foreign/go/contracts/partitions.go | 26 ++
foreign/go/errors/errors.yaml | 4 +
foreign/go/errors/errors_gen.go | 15 +
foreign/go/internal/command/code.go | 2 +-
foreign/go/internal/vsr/envelope.go | 5 +
foreign/go/internal/vsr/envelope_test.go | 4 +-
foreign/go/internal/vsr/session.go | 46 +-
foreign/go/internal/vsr/session_test.go | 40 +-
foreign/go/tests/e2e_test.go | 29 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 69 ++-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 137 +++---
.../iggy/client/async/tcp/ClientRoutingState.java | 36 +-
.../client/async/tcp/ConsumerOffsetsTcpClient.java | 49 +--
.../iggy/client/async/tcp/MessagesTcpClient.java | 146 +------
.../iggy/client/async/tcp/PartitionContexts.java | 191 --------
.../apache/iggy/client/async/tcp/PollRouter.java | 431 +++++++++++++------
.../client/async/tcp/RawPartitionRequests.java | 12 +-
.../client/async/tcp/vsr/ConsensusSession.java | 21 +-
.../iggy/client/async/tcp/vsr/VsrHeaders.java | 2 +-
.../client/async/tcp/vsr/VsrRequestEncoder.java | 13 +-
.../java/org/apache/iggy/cluster/ClusterNode.java | 8 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 1 +
.../org/apache/iggy/partition/PartitionRoute.java | 47 ++
.../org/apache/iggy/serde/BytesDeserializer.java | 5 +-
.../java/org/apache/iggy/serde/CommandCode.java | 2 +-
.../AsyncIggyTcpClientEndpointFailoverTest.java | 1 +
.../AsyncIggyTcpClientPartitionContextTest.java | 141 ++++--
.../tcp/AsyncIggyTcpClientRawRequestTest.java | 192 ++++++---
.../AsyncIggyTcpClientSendContextCacheTest.java | 99 ++++-
.../AsyncIggyTcpClientTransientFailoverTest.java | 124 +++---
.../tcp/AsyncTcpConnectionLifecycleBusyTest.java | 52 ++-
.../client/async/tcp/ClientRoutingStateTest.java | 40 --
.../iggy/client/async/tcp/LeaderAwarenessTest.java | 2 +-
.../iggy/client/async/tcp/PollRouterTest.java | 56 ++-
.../async/tcp/vsr/VsrRequestEncoderTest.java | 35 +-
.../apache/iggy/partition/PartitionRouteTest.java | 65 +++
.../apache/iggy/serde/BytesDeserializerTest.java | 3 +
foreign/node/src/client/client.socket.test.ts | 478 +++++++++++++++------
foreign/node/src/client/client.socket.ts | 461 +++++++++-----------
foreign/node/src/e2e/tcp.cluster.e2e.ts | 1 +
foreign/node/src/wire/cluster/cluster.utils.ts | 6 +-
foreign/node/src/wire/command.code.ts | 2 +-
foreign/node/src/wire/error.code.ts | 1 +
.../src/wire/message/send-messages.command.test.ts | 52 ++-
.../node/src/wire/message/send-messages.command.ts | 56 ++-
foreign/node/src/wire/offset/get-offset.command.ts | 2 +-
foreign/node/src/wire/offset/offset.utils.ts | 12 +-
.../src/wire/partition/partition-route.test.ts | 46 ++
foreign/node/src/wire/partition/partition-route.ts | 51 +++
foreign/node/src/wire/vsr/index.ts | 2 +-
foreign/node/src/wire/vsr/session.ts | 5 +-
foreign/node/src/wire/vsr/vsr.test.ts | 4 +-
94 files changed, 3550 insertions(+), 2231 deletions(-)
copy foreign/csharp/Iggy_SDK/{Utils/SdkVersion.cs =>
Contracts/PartitionRoute.cs} (73%)
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PartitionContexts.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/partition/PartitionRoute.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/partition/PartitionRouteTest.java
create mode 100644 foreign/node/src/wire/partition/partition-route.test.ts
create mode 100644 foreign/node/src/wire/partition/partition-route.ts
