This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/durable-protocol-and-sessions
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a621d9839 fix(sdk): require login after explicit disconnect
add 75c26b586 fix(consensus): close receipt recovery and retirement gaps
No new revisions were added by this update.
Summary of changes:
core/binary_protocol/src/codes.rs | 2 +-
.../src/consensus/consumer_session.rs | 23 +-
core/binary_protocol/src/consensus/header.rs | 4 +-
.../src/responses/messages/send_messages.rs | 2 +-
core/binary_protocol/src/version.rs | 91 ++----
core/common/src/error/iggy_error.rs | 4 +-
core/common/src/lib.rs | 1 +
core/common/src/traits/binary_impls/mod.rs | 2 +-
core/common/src/traits/binary_transport.rs | 9 +-
core/common/src/traits/mod.rs | 1 +
core/consensus/src/client_table.rs | 29 +-
core/consensus/src/impls.rs | 4 +-
core/consensus/src/lib.rs | 2 +-
core/integration/src/harness/handle/server.rs | 7 -
.../tests/cluster/client_table_adversarial.rs | 3 +-
.../tests/cluster/client_table_restart.rs | 3 +-
core/integration/tests/cluster/partition_dedup.rs | 69 ++++-
core/integration/tests/sdk/producer/mod.rs | 12 +
core/integration/tests/sdk/protocol_version.rs | 3 +-
core/integration/tests/server/raw_tcp.rs | 4 +-
core/message_bus/src/replica/auth.rs | 5 +-
core/message_bus/src/replica/handshake.rs | 4 +-
core/metadata/src/applied_frontier.rs | 24 +-
core/metadata/src/impls/metadata.rs | 5 +-
core/metadata/src/impls/recovery.rs | 17 +-
core/partitions/src/iggy_partition.rs | 312 ++++++++++++++-------
core/partitions/src/types.rs | 3 +-
core/sdk/src/clients/client.rs | 4 +-
core/sdk/src/clients/producer_builder.rs | 2 +-
core/sdk/src/poll_routing.rs | 18 +-
core/sdk/src/quic/quic_client.rs | 25 +-
core/sdk/src/session.rs | 11 +
.../stream_builder/config/config_iggy_producer.rs | 3 +-
core/sdk/src/tcp/tcp_client.rs | 91 ++++--
core/sdk/src/vsr.rs | 22 +-
core/sdk/src/websocket/websocket_client.rs | 15 +-
core/server/README.md | 2 +-
core/server/src/boot/mod.rs | 32 ++-
core/server/src/boot/threads.rs | 2 +-
core/server/src/consumer_group/lease.rs | 5 +-
core/server/src/consumer_group/liveness.rs | 47 ++++
core/server/src/dispatch/partition.rs | 2 +-
core/server/src/http/handlers.rs | 42 +--
core/server/src/http/session.rs | 8 +-
core/server/src/http/state.rs | 3 +
core/server/src/http/submit.rs | 8 +-
core/server/src/partition_helpers.rs | 92 +++++-
core/shard/src/lib.rs | 22 +-
core/shard/src/poll.rs | 29 +-
core/simulator/src/lib.rs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/LoginRegister.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 15 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 1 -
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 6 +-
.../VsrTests/EndpointFailoverTests.cs | 45 +++
foreign/csharp/Iggy_SDK_Tests/VsrTests/MockNode.cs | 2 +-
.../VsrTests/VsrProtocolDriftTests.cs | 33 ++-
foreign/csharp/README.md | 2 +-
foreign/go/client/tcp/tcp_core.go | 13 +
foreign/go/client/tcp/tcp_core_test.go | 28 ++
foreign/go/client/tcp/tcp_session_management.go | 25 +-
foreign/go/errors/errors.yaml | 12 +-
foreign/go/errors/errors_gen.go | 37 +--
foreign/go/internal/vsr/protocol_parity_test.go | 11 +-
foreign/go/internal/vsr/register.go | 23 +-
foreign/go/internal/vsr/register_test.go | 16 +-
foreign/java/README.md | 4 +-
.../iggy/client/async/tcp/vsr/VsrLoginCodec.java | 10 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 2 +-
.../AsyncIggyTcpClientEndpointFailoverTest.java | 2 +-
.../tcp/AsyncIggyTcpClientEventLoopGroupTest.java | 2 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 2 +-
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 2 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 2 +-
foreign/node/scripts/check-vsr-protocol.mjs | 16 +-
foreign/node/src/client/client.socket.test.ts | 93 ++++--
foreign/node/src/client/client.socket.ts | 24 +-
foreign/node/src/wire/error.code.ts | 2 +-
foreign/node/src/wire/vsr/index.ts | 13 +
foreign/node/src/wire/vsr/operation.test.ts | 3 +
foreign/node/src/wire/vsr/operation.ts | 7 +-
foreign/node/src/wire/vsr/register.ts | 4 +-
foreign/python/apache_iggy.pyi | 5 +-
foreign/python/src/client.rs | 5 +-
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 4 +-
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 20 +-
86 files changed, 1046 insertions(+), 583 deletions(-)
