This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch harness-single-node-default
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 6a06d7ed7 test(integration): default vsr harness to single node
add 125a82e8b feat(partitions): implement state transfer (#3808)
add 8b09f19d1 chore(deps): Bump rules_rust from 0.71.3 to 0.72.0 in
/foreign/cpp in the cpp group across 1 directory (#3829)
add 2e1cbfa45 chore(deps): Bump the node group across 2 directories with 2
updates (#3830)
add 50518c448 chore(deps): Bump the web group across 1 directory with 5
updates (#3831)
add 094f8a1e6 Merge branch 'master' into harness-single-node-default
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
core/bench/Cargo.toml | 12 +
core/bench/src/main.rs | 14 +
core/binary_protocol/src/consensus/header.rs | 58 +-
core/binary_protocol/src/consensus/operation.rs | 15 +
core/configs/src/server_ng_config/defaults.rs | 5 +
core/configs/src/server_ng_config/displays.rs | 20 +-
core/configs/src/server_ng_config/partition.rs | 76 +
core/configs/src/server_ng_config/validators.rs | 28 +
core/consensus/src/impls.rs | 16 +-
core/consensus/src/lib.rs | 9 +-
core/consensus/src/state_manifest.rs | 36 +-
core/consensus/src/state_transfer.rs | 279 ++
core/consensus/src/vsr_state.rs | 112 +-
core/integration/src/bench_utils.rs | 94 +-
.../src/harness/orchestrator/harness.rs | 31 +
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/partition_state_transfer.rs | 599 ++++
.../data_integrity/verify_after_server_restart.rs | 75 +-
core/integration/tests/sdk/hello_world.rs | 1 -
.../tests/server/cluster_view_durability_vsr.rs | 17 +-
core/integration/tests/server/mod.rs | 4 +
.../tests/server/partition_view_durability_vsr.rs | 330 ++
.../server/scenarios/purge_delete_scenario.rs | 95 +-
core/journal/src/lib.rs | 1 +
core/journal/src/local_gate.rs | 207 ++
core/journal/src/superblock.rs | 68 +-
core/metadata/src/impls/metadata.rs | 149 +-
core/metadata/src/impls/recovery.rs | 1 +
core/metadata/src/lib.rs | 4 +
core/partitions/Cargo.toml | 1 +
core/partitions/src/iggy_partition.rs | 1503 ++++++++-
core/partitions/src/iggy_partitions.rs | 32 +-
core/partitions/src/journal.rs | 102 +-
core/partitions/src/lib.rs | 6 +-
core/partitions/src/offset_storage.rs | 21 +-
core/partitions/src/state_transfer.rs | 3002 ++++++++++++++++++
core/partitions/src/types.rs | 21 +
core/server-ng/config.toml | 30 +
core/server-ng/src/auth.rs | 31 +-
core/server-ng/src/bootstrap.rs | 245 +-
core/server-ng/src/consumer_group.rs | 21 +-
core/server-ng/src/dispatch.rs | 193 +-
core/server-ng/src/dispatch/authz.rs | 61 +-
core/server-ng/src/partition_helpers.rs | 300 +-
core/server-ng/src/partition_reconciler.rs | 50 +-
core/server-ng/src/responses.rs | 94 +-
core/server-ng/src/segment_recovery.rs | 269 +-
core/server-ng/src/server_error.rs | 104 +
core/server-ng/src/users.rs | 6 +-
core/shard/src/builder.rs | 20 +-
core/shard/src/lib.rs | 3223 +++++++++++++++++---
core/shard/src/metrics.rs | 22 +
core/shard/src/router.rs | 99 +-
core/simulator/src/lib.rs | 110 +-
core/simulator/src/replica.rs | 13 +-
examples/node/package-lock.json | 26 +-
examples/node/package.json | 2 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 4 +-
foreign/node/package-lock.json | 8 +-
foreign/node/package.json | 2 +-
web/package-lock.json | 544 ++--
web/package.json | 10 +-
64 files changed, 11263 insertions(+), 1272 deletions(-)
create mode 100644 core/consensus/src/state_transfer.rs
create mode 100644 core/integration/tests/cluster/partition_state_transfer.rs
create mode 100644
core/integration/tests/server/partition_view_durability_vsr.rs
create mode 100644 core/journal/src/local_gate.rs
create mode 100644 core/partitions/src/state_transfer.rs
