This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch vsr-cleanup
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard 981ad3794 fix: address review comments
omit 90f10ebd5 Merge branch 'master' into vsr-cleanup
omit 86d27cc94 refactor(consensus): fold the duplicated view-change entry
into one method
omit 5404b01a9 feat(consensus): stamp when a request parks in the queue
omit 4494711ac fix(consensus): arm the prepare timeout only while prepares
are in flight
omit e3eed36c4 refactor(consensus): scope pipeline access behind named
operations
omit 739723ed5 test(simulator): cover the pump realloc under a live
partition borrow
omit 287944893 perf(shard): route the classified bag so frames parse once
per hop
omit 7c780bfbf fix(consensus): hand back the op when a metadata WAL append
fails
omit ac970d59c refactor(server-ng): build payload replies through one
framing helper
omit c0254155e perf(metadata): decode ops off the buffer instead of copying
the body
omit 9f8e64aa5 feat(metadata): version the snapshot format with a release
stamp
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 80dee4c2a feat(metadata): version the snapshot format with a release
stamp
add 0fbfe8177 perf(metadata): decode ops off the buffer instead of copying
the body
add 11412ac4c refactor(server-ng): build payload replies through one
framing helper
add b88a5c0fc fix(consensus): hand back the op when a metadata WAL append
fails
add 935d13d29 perf(shard): route the classified bag so frames parse once
per hop
add b7f2600d0 test(simulator): cover the pump realloc under a live
partition borrow
add 648596bec refactor(consensus): scope pipeline access behind named
operations
add bb4cdbf7c fix(consensus): arm the prepare timeout only while prepares
are in flight
add e19c68692 feat(consensus): stamp when a request parks in the queue
add f25d4a37e refactor(consensus): fold the duplicated view-change entry
into one method
add 3902a827b fix: address review comments
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (981ad3794)
\
N -- N -- N refs/heads/vsr-cleanup (3902a827b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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 | 60 +-
Cargo.toml | 10 +-
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/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/src/impls/metadata.rs | 19 +-
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 | 81 +-
core/server/src/dispatch.rs | 1240 ++++++++++++++++++--
core/server/src/dispatch/authz.rs | 56 +-
core/server/src/http/state.rs | 80 +-
core/server/src/server_error.rs | 13 +
core/server/src/session_manager.rs | 2 +-
core/server_common/src/consensus_message.rs | 96 +-
core/shard/src/lib.rs | 242 +++-
core/shard/src/router.rs | 5 +-
core/simulator/src/deps.rs | 17 +-
core/simulator/src/executor/mod.rs | 47 +-
core/simulator/src/lib.rs | 129 ++
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 +-
109 files changed, 4427 insertions(+), 908 deletions(-)
create mode 100644 core/integration/tests/cluster/register_forwarding.rs
