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 0dd5939c2 test(simulator): validate committed consumer state
new c98e26680 fix(sdk): preserve routed admission and history freshness
new bb9f77806 fix(server): refine consumer progress dispatch
new 1bd2d0d6e refactor(partitions): publish only planned emptied markers
new 23fac06d6 test(simulator): exercise stale owners and strict offsets
new 3d1b10da8 fix(cli): preserve cluster metadata list column order
new c0d4445e2 docs(consensus): clarify shared request ID history coverage
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../binary_cluster/get_cluster_metadata.rs | 4 +-
core/consensus/src/client_table.rs | 15 +-
.../cli/system/test_cluster_metadata_command.rs | 3 +-
core/partitions/src/iggy_partition.rs | 51 +++-
core/server/src/dispatch/mod.rs | 313 +++++++++++++++++----
core/server/src/dispatch/partition.rs | 117 +++++++-
core/server/src/http/forward.rs | 5 +-
core/simulator/src/bin/workload-fuzz.rs | 5 +-
core/simulator/src/lib.rs | 32 ++-
core/simulator/src/workload/actions.rs | 1 +
core/simulator/src/workload/mod.rs | 195 +++++++++++++
core/simulator/src/workload/ops/mod.rs | 2 +
...ixture_group.rs => store_stale_owner_offset.rs} | 68 ++---
core/simulator/src/workload/options.rs | 4 +-
core/simulator/src/workload/oracle.rs | 15 +-
core/simulator/src/workload/shadow.rs | 65 ++++-
core/simulator/src/workload/state_checker.rs | 208 +++++++++++++-
foreign/csharp/Iggy_SDK/Contracts/ClusterNode.cs | 2 +-
.../TcpMessageStream.PollRouting.cs | 5 +-
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 32 +++
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 29 ++
foreign/go/client/tcp/tcp_poll_routing.go | 17 +-
foreign/go/client/tcp/tcp_poll_routing_test.go | 48 ++++
.../apache/iggy/client/async/tcp/PollRouter.java | 4 +-
.../java/org/apache/iggy/cluster/ClusterNode.java | 6 +
.../AsyncIggyTcpClientTransientFailoverTest.java | 12 +-
.../iggy/client/async/tcp/PollRouterTest.java | 50 +++-
.../client/blocking/http/ObjectMapperTest.java | 19 ++
foreign/node/src/client/client.socket.test.ts | 53 +++-
foreign/node/src/client/client.socket.ts | 2 +-
30 files changed, 1221 insertions(+), 161 deletions(-)
copy core/simulator/src/workload/ops/{leave_fixture_group.rs =>
store_stale_owner_offset.rs} (52%)
