You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gk...@apache.org on 2026/09/28 10:59:34 UTC
(iggy) 01/01: Merge branch 'master' into kafka_idempotence_stub
This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a commit to branch kafka_idempotence_stub
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 0f2d456442bdc951813571be44b2ef2a07d8953f
Merge: 4c6647c20 32278f5dd
Author: Grzegorz Koszyk <11...@users.noreply.github.com>
AuthorDate: Mon Sep 28 12:59:29 2026 +0200
Merge branch 'master' into kafka_idempotence_stub
core/configs/src/common/system.rs | 3 -
core/configs/src/server_config/server.rs | 76 +-
.../tests/cluster/crash_recovery_corruption.rs | 2 +-
core/metadata/src/stm/authz.rs | 8 +-
core/metadata/src/stm/mod.rs | 14 +-
core/metadata/src/stm/stream.rs | 37 +-
core/metadata/src/stm/user.rs | 21 +-
core/partitions/src/iggy_index.rs | 6 +-
core/partitions/src/iggy_partition.rs | 1 -
core/partitions/src/lib.rs | 12 +
core/{server => partitions}/src/offset_recovery.rs | 22 +-
core/partitions/src/partition_storage.rs | 725 +++++++++++++++++++
.../{server => partitions}/src/segment_recovery.rs | 703 +++++++++++++-----
core/partitions/src/types.rs | 48 ++
core/server/src/boot/mod.rs | 63 +-
core/server/src/boot/recovery.rs | 41 +-
core/server/src/consumer_group.rs | 9 +-
core/server/src/dispatch/authz.rs | 65 +-
core/server/src/dispatch/host.rs | 213 ++++++
core/server/src/dispatch/mod.rs | 226 +++---
core/server/src/dispatch/partition.rs | 12 +-
core/server/src/dispatch/session_ops.rs | 16 +-
core/server/src/dispatch/submit.rs | 250 +++----
core/server/src/dispatch/test_support.rs | 1 -
core/server/src/http/reads.rs | 125 +++-
core/server/src/lib.rs | 14 +-
core/server/src/namespace.rs | 218 +++---
core/server/src/partition_helpers.rs | 792 ++-------------------
core/server/src/partition_reconciler.rs | 19 +-
core/server/src/server_error.rs | 320 +--------
core/server/src/session_manager.rs | 2 +-
core/server/src/shell.rs | 57 +-
core/shard/src/builder.rs | 26 +-
core/shard/src/host.rs | 103 +++
core/shard/src/lib.rs | 109 ++-
core/shard/src/poll/completion_tests.rs | 11 +-
core/shard/src/router.rs | 6 +-
core/simulator/src/replica.rs | 63 +-
core/simulator/src/storage/purge.rs | 17 +-
39 files changed, 2367 insertions(+), 2089 deletions(-)