This is an automated email from the ASF dual-hosted git repository. hubcio pushed a commit to branch dependabot/npm_and_yarn/foreign/node/node-c343792cda in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 04ca04c8b8e74fe06cf2894d7cc6ea6b63920e79 Merge: 14230b1ae 71c67e432 Author: Hubert Gruszecki <[email protected]> AuthorDate: Mon Aug 3 08:33:43 2026 +0200 Merge branch 'master' into dependabot/npm_and_yarn/foreign/node/node-c343792cda Cargo.lock | 6 + core/binary_protocol/src/consensus/command.rs | 19 +- core/binary_protocol/src/consensus/header.rs | 337 +++- core/binary_protocol/src/consensus/mod.rs | 3 +- core/binary_protocol/src/lib.rs | 5 +- core/configs/src/server_ng_config/cluster.rs | 71 +- core/configs/src/server_ng_config/sharding.rs | 74 + core/configs/src/server_ng_config/validators.rs | 13 + core/connectors/sinks/s3_sink/Cargo.toml | 6 + core/consensus/Cargo.toml | 2 + core/consensus/src/client_table.rs | 979 +++++++++++- core/consensus/src/impls.rs | 840 +++++++++- core/consensus/src/le_cursor.rs | 115 ++ core/consensus/src/lib.rs | 15 +- core/consensus/src/metadata_helpers.rs | 27 +- core/consensus/src/observability.rs | 4 +- core/consensus/src/plane_helpers.rs | 15 +- core/consensus/src/state_manifest.rs | 309 ++++ core/consensus/src/vsr_state.rs | 224 +++ core/integration/Cargo.toml | 13 +- core/integration/src/harness/config/resolve.rs | 7 +- core/integration/src/harness/handle/server.rs | 83 +- .../src/harness/orchestrator/harness.rs | 26 + .../cli/message/test_message_flush_command.rs | 5 + .../tests/cluster/client_table_restart.rs | 14 +- .../tests/cluster/metadata_checkpoint_restart.rs | 276 ++++ .../tests/cluster/metadata_state_transfer.rs | 406 +++++ core/integration/tests/cluster/mod.rs | 2 + core/integration/tests/data_integrity/mod.rs | 11 +- .../data_integrity/verify_after_server_restart.rs | 31 + .../tests/server/cluster_view_durability_vsr.rs | 266 ++++ core/integration/tests/server/flush_vsr.rs | 4 + .../server/metadata_checkpoint_recovery_vsr.rs | 138 ++ core/integration/tests/server/mod.rs | 8 + .../scenarios/segment_rotation_race_scenario.rs | 9 - core/journal/Cargo.toml | 2 + core/journal/src/lib.rs | 31 + core/journal/src/prepare_journal.rs | 508 +++++- core/journal/src/superblock.rs | 824 ++++++++++ core/message_bus/src/client_listener/mod.rs | 5 +- core/message_bus/src/client_listener/quic.rs | 24 +- core/message_bus/src/framing.rs | 8 +- core/message_bus/src/installer/replica.rs | 2 +- core/message_bus/src/replica/auth.rs | 106 +- core/message_bus/src/replica/handshake.rs | 21 +- core/message_bus/src/socket_opts.rs | 59 +- core/message_bus/tests/common/mod.rs | 7 +- core/message_bus/tests/replica_auth_handshake.rs | 28 + core/metadata/src/impls/metadata.rs | 1389 ++++++++++++++-- core/metadata/src/impls/recovery.rs | 985 +++++++++++- core/metadata/src/lib.rs | 5 +- core/metadata/src/stm/mod.rs | 10 + core/metadata/src/stm/mux.rs | 40 +- core/metadata/src/stm/snapshot.rs | 129 +- core/metadata/src/stm/stream.rs | 252 ++- core/metadata/src/stm/user.rs | 69 +- core/partitions/src/iggy_partition.rs | 96 +- core/partitions/src/iggy_partitions.rs | 2 +- core/partitions/src/journal.rs | 10 + core/partitions/src/log.rs | 24 + core/partitions/src/poll_plan.rs | 57 +- core/server-ng/Cargo.toml | 1 - core/server-ng/config.toml | 26 +- core/server-ng/src/auth.rs | 100 +- core/server-ng/src/bootstrap.rs | 714 ++++++--- core/server-ng/src/dispatch.rs | 111 +- core/server-ng/src/http.rs | 160 +- core/server-ng/src/http/metrics.rs | 297 ++++ core/server-ng/src/http/state.rs | 8 + core/server-ng/src/http/submit.rs | 37 +- core/server-ng/src/partition_reconciler.rs | 2 +- core/server-ng/src/pat.rs | 182 ++- core/server-ng/src/responses.rs | 17 +- core/server-ng/src/server_error.rs | 16 +- core/server_common/src/consensus_message.rs | 34 +- core/shard/src/lib.rs | 1661 ++++++++++++++++++-- core/shard/src/router.rs | 32 +- core/simulator/src/deps.rs | 131 ++ core/simulator/src/lib.rs | 517 +++++- core/simulator/src/replica.rs | 126 +- foreign/python/apache_iggy.pyi | 334 +++- foreign/python/src/client.rs | 103 +- foreign/python/src/lib.rs | 6 + foreign/python/src/permissions.rs | 458 ++++++ foreign/python/src/user.rs | 9 + foreign/python/tests/test_permissions.py | 695 ++++++++ foreign/python/tests/test_user.py | 113 +- foreign/python/tests/utils.py | 23 + 88 files changed, 14010 insertions(+), 959 deletions(-)
