This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch rework_topic_commands
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8245d0d3c add limit to the max key value pair entries
add b7b62a088 chore(deps): Bump
org.apache.httpcomponents.client5:httpclient5 from 5.6.2 to 5.6.3 (#3865)
add f14e5e6e9 ci: make Rust image matching portable (#3871)
add 550ff8660 chore(deps): Bump rules_rust from 0.72.0 to 0.73.0 in
/foreign/cpp in the cpp group across 1 directory (#3863)
add f4a9aac56 chore(deps): Bump the node group across 2 directories with 2
updates (#3861)
add cb0818c1c chore(deps): Bump github.com/cucumber/godog from 0.15.1 to
0.16.0 in /bdd/go in the go group across 1 directory (#3862)
add 9b1938b81 chore(deps): Bump the web group across 1 directory with 2
updates (#3864)
add 7dee4d8d2 chore(deps): Bump the github-actions group with 2 updates
(#3868)
add fb9307e01 feat(server)!: auth-gate cluster metadata, forward register
to primary (#3872)
add cd14bb6be chore(deps): Bump the python group across 3 directories with
2 updates (#3866)
add 3e7bf7a25 chore(deps): Update pytest requirement from <10.0,>=9.0.3 to
>=9.1.1,<10.0 in /examples/python (#3867)
add 4eb879e82 ci(csharp): split e2e integration tests per target framework
(#3874)
add 8da1ddc12 merge master
add cbeb410f4 fix(consensus): close metadata and consensus plane TODOs
(#3870)
add ca150e2a7 merge upstream
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 19 +-
.github/config/components.yml | 2 +-
.github/workflows/_common.yml | 4 +-
.github/workflows/_test.yml | 2 +-
.github/workflows/coverage-baseline.yml | 4 +-
.github/workflows/post-merge.yml | 2 +-
Cargo.lock | 61 +-
Cargo.toml | 11 +-
bdd/go/go.mod | 9 +-
bdd/go/go.sum | 40 +-
bdd/python/pyproject.toml | 4 +-
bdd/python/uv.lock | 78 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/consensus/command.rs | 21 +-
core/binary_protocol/src/consensus/header.rs | 777 +++++++++++-
core/binary_protocol/src/consensus/mod.rs | 4 +-
core/binary_protocol/src/lib.rs | 15 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/traits/cluster_client.rs | 3 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 2 +-
core/connectors/sinks/doris_sink/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/s3_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/consensus/src/client_table.rs | 20 +-
core/consensus/src/fatal.rs | 56 +
core/consensus/src/impls.rs | 804 +++++++++++--
core/consensus/src/lib.rs | 13 +
core/consensus/src/metadata_helpers.rs | 12 +-
core/consensus/src/plane_helpers.rs | 52 +-
core/consensus/src/vsr_timeout.rs | 11 +
core/integration/src/harness/handle/common.rs | 30 +
core/integration/src/harness/handle/server.rs | 17 +
.../tests/cluster/client_table_restart.rs | 5 +
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/register_forwarding.rs | 382 ++++++
core/integration/tests/server/legacy_login_vsr.rs | 6 +-
.../server/scenarios/authentication_scenario.rs | 9 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/impls/metadata.rs | 312 +++--
core/metadata/src/impls/recovery.rs | 127 +-
core/metadata/src/stm/authz.rs | 3 +-
core/metadata/src/stm/mod.rs | 25 +-
core/metadata/src/stm/snapshot.rs | 276 ++++-
core/metadata/src/stm/user.rs | 20 +-
core/partitions/src/iggy_partition.rs | 42 +-
core/partitions/src/iggy_partitions.rs | 21 +
core/partitions/src/state_transfer.rs | 2 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/leader_aware.rs | 38 +
core/sdk/src/quic/quic_client.rs | 34 +-
core/sdk/src/tcp/tcp_client.rs | 34 +-
core/sdk/src/websocket/websocket_client.rs | 32 +-
core/server/Cargo.toml | 2 +-
core/server/src/auth.rs | 102 +-
core/server/src/bootstrap.rs | 114 +-
core/server/src/dispatch.rs | 1247 ++++++++++++++++++--
core/server/src/dispatch/authz.rs | 56 +-
core/server/src/http/state.rs | 80 +-
core/server/src/partition_reconciler.rs | 19 +-
core/server/src/responses.rs | 93 +-
core/server/src/server_error.rs | 13 +
core/server/src/session_manager.rs | 2 +-
core/server_common/src/consensus_message.rs | 240 +++-
core/shard/src/lib.rs | 349 +++++-
core/shard/src/router.rs | 117 +-
core/simulator/src/deps.rs | 17 +-
core/simulator/src/executor/mod.rs | 47 +-
core/simulator/src/lib.rs | 241 ++++
examples/node/package-lock.json | 12 +-
examples/node/package.json | 2 +-
examples/python/pyproject.toml | 4 +-
examples/python/uv.lock | 78 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 4 +-
foreign/cpp/tests/e2e/client.cpp | 18 +-
.../StepDefinitions/LeaderRedirectionSteps.cs | 25 +-
.../ClusterRedirectionTests.cs | 20 +-
.../IggyTlsConnectionTests.cs | 7 +-
.../Implementations/TcpMessageStream.Vsr.cs | 6 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 20 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/go/client/tcp/tcp_connect_test.go | 123 +-
foreign/go/client/tcp/tcp_core.go | 56 +-
foreign/go/client/tcp/tcp_core_review_test.go | 20 +-
foreign/go/client/tcp/tcp_session_management.go | 74 +-
foreign/go/contracts/version.go | 2 +-
foreign/go/internal/util/leader_aware.go | 115 +-
foreign/go/internal/util/leader_aware_test.go | 44 +
foreign/go/tests/e2e_test.go | 11 +-
foreign/java/gradle/libs.versions.toml | 2 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 60 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 9 +-
.../client/async/AsyncConnectionPoolAuthTest.java | 9 +-
.../tcp/AsyncIggyTcpClientLoginRoutingTest.java | 13 +-
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 25 +-
foreign/node/package-lock.json | 58 +-
foreign/node/package.json | 4 +-
foreign/node/src/client/client.socket.test.ts | 275 ++++-
foreign/node/src/client/client.socket.ts | 166 ++-
foreign/python/Cargo.toml | 4 +-
foreign/python/pyproject.toml | 10 +-
foreign/python/uv.lock | 74 +-
scripts/ci/sync-rustc-version.sh | 8 +-
web/package-lock.json | 136 +--
web/package.json | 6 +-
127 files changed, 6256 insertions(+), 1486 deletions(-)
create mode 100644 core/consensus/src/fatal.rs
create mode 100644 core/integration/tests/cluster/register_forwarding.rs
