This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch fix_partition_replica_commit
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 00b57ffde fix(partitions): don't commit a stale prepare after adopting
a newer view
add 07d2a2136 chore(deps): Bump the github-actions group with 3 updates
(#4426)
add 651ccea4e chore(deps): Bump postcss-selector-parser from 7.1.4 to
7.1.6 in /web (#4425)
add 50a0db603 chore(deps): Bump mako from 1.4.1 to 1.4.2 in /bdd/python
(#4423)
add 0ce152402 chore(deps): Bump joi from 17.13.7 to 17.13.8 in /web (#4422)
add a263a813d fix(ci): skip unaffected license checks (#4428)
add 4843593b1 chore(deps): Bump source-map-js from 1.2.1 to 1.2.2 in /web
(#4424)
add 2c1f70b53 chore(repo): bump Rust toolchain to 1.99.0 (#4430)
add 5da16eba2 chore(deps): Bump the java group across 3 directories with 6
updates (#4427)
add 43fb44364 feat(node): wire up snapshot command in system client (#4389)
add 4b3e5684b Merge branch 'master' into fix_partition_replica_commit
No new revisions were added by this update.
Summary of changes:
.devcontainer/Dockerfile | 2 +-
.github/workflows/_common.yml | 10 +-
.github/workflows/_detect.yml | 27 ++++++
.github/workflows/_test.yml | 2 +-
.github/workflows/coverage-baseline.yml | 6 +-
.github/workflows/pre-merge.yml | 3 +
Cargo.lock | 1 -
Cargo.toml | 1 -
Dockerfile | 2 +-
bdd/java/Dockerfile | 2 +-
bdd/java/build.gradle.kts | 6 +-
bdd/java/gradle/wrapper/gradle-wrapper.properties | 2 +-
bdd/java/gradlew | 4 +-
bdd/php/Dockerfile | 2 +-
bdd/python/Dockerfile | 2 +-
bdd/python/uv.lock | 6 +-
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Dockerfile | 2 +-
core/bench/dashboard/frontend/src/api/mod.rs | 9 +-
.../frontend/src/components/app_content.rs | 28 ++++--
.../frontend/src/components/chart/trend_chart.rs | 4 +-
.../frontend/src/components/layout/sidebar.rs | 4 +-
.../dashboard/frontend/src/state/benchmark.rs | 22 +++--
core/bench/dashboard/server/Dockerfile | 2 +-
core/bench/report/Cargo.toml | 1 -
core/bench/report/src/types/hardware.rs | 2 +-
core/bench/src/utils/client_factory.rs | 20 ++--
core/binary_protocol/src/framing.rs | 6 +-
core/connectors/runtime/Dockerfile | 2 +-
core/consensus/src/client_table.rs | 2 +-
core/consensus/src/impls.rs | 2 +-
.../tests/connectors/runtime/http_state.rs | 2 +-
core/journal/src/prepare_journal.rs | 2 +-
core/metadata/src/impls/metadata.rs | 18 ++--
core/metadata/src/stm/mux.rs | 2 +-
core/metadata/src/stm/stream.rs | 2 +-
core/metadata/src/stm/user.rs | 23 ++---
core/partitions/src/iggy_partition.rs | 23 ++---
core/partitions/src/offset_recovery.rs | 4 +-
core/partitions/src/persistence.rs | 2 +-
core/server/Dockerfile | 2 +-
core/server/src/consumer_group.rs | 6 +-
core/server/src/consumer_group/lease.rs | 4 +-
core/server/src/consumer_group/liveness.rs | 6 +-
core/server/src/http/session.rs | 4 +-
core/server/src/http/wire.rs | 2 +-
core/server/src/partition_helpers.rs | 6 +-
core/server/src/sysinfo_probe.rs | 2 +-
core/server_common/src/iobuf.rs | 2 +-
core/shard/src/lib.rs | 2 +-
core/shard/src/poll/completion.rs | 2 +-
core/simulator/src/executor/time.rs | 4 +-
core/simulator/src/lib.rs | 4 +-
examples/java/build.gradle.kts | 2 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 2 +-
examples/java/gradlew | 4 +-
.../iggy/examples/MultiTenantAccessTest.java | 4 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/java/gradle/libs.versions.toml | 6 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 2 +-
foreign/java/gradlew | 4 +-
.../client/async/tcp/ClientRoutingStateTest.java | 5 +-
foreign/node/src/e2e/tcp.system.e2e.ts | 7 ++
foreign/node/src/wire/command-set.ts | 2 +
foreign/node/src/wire/command.code.ts | 2 +-
foreign/node/src/wire/system/index.ts | 1 +
.../node/src/wire/system/snapshot.command.test.ts | 107 +++++++++++++++++++++
foreign/node/src/wire/system/snapshot.command.ts | 103 ++++++++++++++++++++
foreign/php/Dockerfile.test | 2 +-
gateways/kafka/Dockerfile | 2 +-
gateways/kafka/src/protocol/acl.rs | 4 +-
gateways/kafka/src/protocol/handlers/metadata.rs | 2 +-
.../kafka/tests/bridge_iggy_integration_tests.rs | 2 +-
gateways/kafka/tests/consumer_group_tests.rs | 10 +-
gateways/kafka/tests/fetch_real_bridge_tests.rs | 8 +-
gateways/kafka/tests/metadata_real_bridge_tests.rs | 2 +-
gateways/kafka/tests/produce_real_bridge_tests.rs | 2 +-
gateways/kafka/tests/server_e2e_tests.rs | 2 +-
rust-toolchain.toml | 2 +-
web/package-lock.json | 18 ++--
80 files changed, 438 insertions(+), 181 deletions(-)
create mode 100644 foreign/node/src/wire/system/snapshot.command.test.ts
create mode 100644 foreign/node/src/wire/system/snapshot.command.ts
