This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch server_perf_cut_extra_work
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 4730a1a5b Merge branch 'master' into server_perf_cut_extra_work
omit 142606d2d Merge branch 'master' into server_perf_cut_extra_work
omit fac23670e Merge branch 'master' into server_perf_cut_extra_work
omit a7b8288a7 fix(sdk): preserve group membership during primary polling
omit 889f55506 fix(ci): gate poll diagnostics test imports
omit 67374a9ce chore(server): raise replication queue and repair ring
defaults
omit ac2b7bf5d fix(cluster): preserve routed poll safety during recovery
omit 596080d31 fix(cluster): preserve group membership during auto-commit
polls
omit b6107eca4 test(cluster): reproduce auto-commit group membership loss
omit 2ac51bc5e fix
omit 15031836f Merge branch 'master' into server_perf_cut_extra_work
omit 73ad56cfb perf(server): reduce produce and poll overhead
add 26d721eee perf(server): reduce produce and poll overhead
add 9a99f0b18 fix
add 7ca36fba6 test(cluster): reproduce auto-commit group membership loss
add 19fb6141d fix(cluster): preserve group membership during auto-commit
polls
add 0dc3214e8 fix(cluster): preserve routed poll safety during recovery
add 22606fd0d chore(server): raise replication queue and repair ring
defaults
add 457257677 fix(ci): gate poll diagnostics test imports
add a520d2dae fix(sdk): preserve group membership during primary polling
add 61c16adc1 fix(integration): align server tests with primary polling
add 5f047adfb fix(cluster): preserve membership during offset writes
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 (4730a1a5b)
\
N -- N -- N refs/heads/server_perf_cut_extra_work (5f047adfb)
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:
core/binary_protocol/src/codes.rs | 3 +
core/binary_protocol/src/dispatch.rs | 2 +
.../src/responses/messages/poll_routing.rs | 4 +-
.../src/traits/binary_impls/consumer_offsets.rs | 4 +-
core/common/src/traits/binary_transport.rs | 18 +-
core/common/src/wire_conversions.rs | 15 +
core/consensus/src/client_table.rs | 2 +-
.../tests/cluster/partition_primary_routing.rs | 318 ++++++++++---
.../server/scenarios/authentication_scenario.rs | 51 ++-
.../tests/server/scenarios/system_scenario.rs | 39 +-
core/journal/src/partition_journal.rs | 40 +-
core/metadata/src/stm/stream.rs | 38 +-
core/partitions/src/iggy_partition.rs | 25 +-
core/partitions/src/persistence.rs | 5 +-
core/partitions/src/poll_plan.rs | 51 ++-
core/sdk/README.md | 11 +
core/sdk/src/leader_aware.rs | 15 +-
core/sdk/src/poll_routing.rs | 318 ++++++++++++-
core/sdk/src/quic/quic_client.rs | 68 ++-
core/sdk/src/tcp/tcp_client.rs | 151 +++---
core/sdk/src/websocket/websocket_client.rs | 68 ++-
core/server/README.md | 8 +
core/server/config.toml | 1 +
core/server/src/dispatch/authz.rs | 26 +-
core/server/src/dispatch/mod.rs | 31 +-
core/server/src/dispatch/partition.rs | 77 +++-
core/server/src/dispatch/reads.rs | 75 ++-
core/server/src/http/forward.rs | 116 ++++-
core/server/src/http/submit.rs | 2 +
core/server/src/responses.rs | 17 +-
core/server/src/session_manager.rs | 29 +-
core/shard/src/lib.rs | 21 +-
core/shard/src/poll.rs | 102 +++--
core/shard/src/poll/completion.rs | 6 +-
core/shard/src/poll/completion_tests.rs | 235 +++++++++-
core/shard/src/router.rs | 18 +-
.../TcpMessageStream.PollRouting.cs | 54 ++-
.../Implementations/TcpMessageStream.Vsr.cs | 8 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 3 +-
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 126 +++++
foreign/go/README.md | 15 +-
foreign/go/client/tcp/cluster.go | 1 +
foreign/go/client/tcp/tcp_core.go | 34 +-
foreign/go/client/tcp/tcp_messaging.go | 5 +
foreign/go/client/tcp/tcp_poll_routing.go | 126 ++---
foreign/go/client/tcp/tcp_poll_routing_test.go | 296 +++++++++++-
foreign/go/client/tcp/tcp_testing_test.go | 6 +-
foreign/go/internal/vsr/header.go | 3 +-
foreign/go/internal/vsr/header_test.go | 4 +-
foreign/go/tests/e2e_test.go | 20 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 63 ++-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 53 ++-
.../iggy/client/async/tcp/MessagesTcpClient.java | 39 +-
.../apache/iggy/client/async/tcp/PollRouter.java | 150 +++---
.../iggy/client/async/tcp/UsersTcpClient.java | 20 +-
.../client/async/tcp/vsr/VsrResponseHandler.java | 3 +-
.../org/apache/iggy/serde/BytesSerializer.java | 8 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 506 ++++++++++++++++++++-
.../async/tcp/vsr/VsrResponseHandlerTest.java | 18 +
foreign/node/src/client/client.connection.ts | 4 +-
foreign/node/src/client/client.socket.test.ts | 234 +++++++++-
foreign/node/src/client/client.socket.ts | 54 ++-
63 files changed, 3241 insertions(+), 626 deletions(-)
