This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/durable-protocol-and-sessions
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit ac036de00 test(consensus): preserve pinned receipts in reordered
retries
omit 4fb724b1a test(integration): accept reauthentication denial after user
deletion
omit 1a1121352 fix(consensus): preserve revoked sessions through recovery
and replay
omit 1d93ec831 fix(server): prevent retirement stalls and bound protocol
versions
omit b41ae6a78 fix(server): preserve session fences across recovery and
retirement
omit 1d93f7f74 fix(sdk): resume retained sessions and preserve uncertain
outcomes
omit ce658ea26 fix(consensus): fence retirement and preserve recovery
frontiers
omit ca3a74542 fix(sdk): sync Swift error codes and golden fixtures
omit 989ad0f69 fix(partitions): preserve transferred retry checkpoints
omit 1b4e25ecd fix(consensus): reject invalid bindings and trim retry
overhead
omit 93b7d7108 fix(consensus): close receipt recovery and retirement gaps
omit 4f5a8c687 fix(sdk): require login after explicit disconnect
omit a7de00dfe fix(server): restore startup and buffered recovery
omit deaa32de7 feat(consensus): persist retry receipts and shared sessions
add f6dfbdbb3 feat(server): store offsets of groups managed outside Iggy
(#4392)
new fbc2c5842 feat(consensus): persist retry receipts and shared sessions
new 882c61cb8 fix(server): restore startup and buffered recovery
new 8fa1c4a2b fix(sdk): require login after explicit disconnect
new 78e9fca92 fix(consensus): close receipt recovery and retirement gaps
new 18a87ce3a fix(consensus): reject invalid bindings and trim retry
overhead
new 4ae2a2cf9 fix(partitions): preserve transferred retry checkpoints
new f454e4323 fix(sdk): sync Swift error codes and golden fixtures
new ae6dfb9c5 fix(consensus): fence retirement and preserve recovery
frontiers
new 7ae28b838 fix(sdk): resume retained sessions and preserve uncertain
outcomes
new b841581cd fix(server): preserve session fences across recovery and
retirement
new 4a43938dd fix(server): prevent retirement stalls and bound protocol
versions
new 07ed42fa8 fix(consensus): preserve revoked sessions through recovery
and replay
new f7fe210bf test(integration): accept reauthentication denial after user
deletion
new 79de990d5 test(consensus): preserve pinned receipts in reordered
retries
new 56cc05a96 fix(partitions): resume commits after persistence completes
new 77d9f513a test(partitions): align offset fixtures with durable retry
state
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 (ac036de00)
\
N -- N -- N refs/heads/feat/durable-protocol-and-sessions
(77d9f513a)
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.
The 16 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:
core/binary_protocol/src/lib.rs | 4 +-
core/binary_protocol/src/primitives/consumer.rs | 29 +-
core/cli/src/args/consumer_offset.rs | 6 +-
.../binary_consumer_offsets/get_consumer_offset.rs | 1 +
core/common/src/traits/consumer_offset_client.rs | 6 +
core/common/src/traits/message_client.rs | 1 +
core/common/src/types/consumer/consumer_kind.rs | 78 +-
core/integration/src/harness/disk.rs | 1 +
core/integration/tests/cli/consumer_offset/mod.rs | 1 +
.../test_consumer_offset_external_group_command.rs | 149 ++
.../test_consumer_offset_get_command.rs | 6 +-
.../test_consumer_offset_set_command.rs | 6 +-
.../tests/cluster/partition_state_transfer.rs | 52 +-
core/integration/tests/server/cg.rs | 10 +-
.../scenarios/external_group_offsets_scenario.rs | 142 ++
core/integration/tests/server/scenarios/mod.rs | 1 +
core/partitions/src/consumer_offset_capacity.rs | 3 +
core/partitions/src/iggy_partition.rs | 1831 ++++++++++++++------
core/partitions/src/iggy_partitions.rs | 14 +
core/partitions/src/lib.rs | 1 +
core/partitions/src/offset_recovery.rs | 19 +-
core/partitions/src/partition_storage.rs | 272 +--
core/partitions/src/persistence.rs | 5 +-
core/partitions/src/segment_recovery.rs | 23 +-
core/partitions/src/state_transfer.rs | 435 +++--
core/partitions/src/types.rs | 15 +
core/partitions/tests/consumer_offset_history.rs | 1 +
core/sdk/src/http/consumer_offsets.rs | 72 +-
core/sdk/src/http/messages.rs | 1 +
.../stream_builder/build/build_iggy_consumer.rs | 3 +
.../stream_builder/config/config_iggy_consumer.rs | 41 +-
core/sdk/src/stream_builder/iggy_stream.rs | 35 +-
.../sdk/src/stream_builder/iggy_stream_consumer.rs | 28 +-
core/server/README.md | 4 +
core/server/config.toml | 28 +-
core/server/src/consumer_group.rs | 22 +-
core/server/src/dispatch/partition.rs | 64 +-
core/server/src/http/handlers.rs | 9 +-
core/server/src/namespace.rs | 18 +-
core/server/src/partition_reconciler.rs | 22 +-
core/shard/src/lib.rs | 20 +-
core/shard/src/metrics.rs | 58 +-
core/shard/src/poll.rs | 8 +
core/shard/src/router.rs | 30 +-
core/simulator/src/storage/purge.rs | 226 ++-
core/simulator/src/workload/ops/mod.rs | 25 +-
.../src/workload/ops/store_consumer_offset.rs | 2 +-
examples/rust/src/new-sdk/consumer/main.rs | 1 +
48 files changed, 2856 insertions(+), 973 deletions(-)
create mode 100644
core/integration/tests/cli/consumer_offset/test_consumer_offset_external_group_command.rs
create mode 100644
core/integration/tests/server/scenarios/external_group_offsets_scenario.rs
