You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by pi...@apache.org on 2026/05/27 08:50:05 UTC
(iggy) branch connectors_agent updated (b54d2dd51 -> 478063119)
This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch connectors_agent
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b54d2dd51 Improve after review
add 116103b0b feat(sdk): implement vsr header framing (#3254)
add 478063119 Merge branch 'master' into connectors_agent
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 3 +
core/binary_protocol/src/consensus/operation.rs | 27 +-
core/binary_protocol/src/dispatch.rs | 4 +-
core/binary_protocol/src/lib.rs | 1 +
core/binary_protocol/src/namespace.rs | 80 ++
.../src/requests/users/login_register.rs | 58 +-
.../src/requests/users/login_register_with_pat.rs | 38 +-
core/common/Cargo.toml | 3 +
core/common/src/error/iggy_error.rs | 7 +
core/common/src/lib.rs | 2 +
core/common/src/traits/binary_client.rs | 11 +-
.../traits/binary_impls/personal_access_tokens.rs | 62 +-
core/common/src/traits/binary_impls/users.rs | 66 +-
core/common/src/traits/binary_transport.rs | 22 +
.../common/src/types/personal_access_tokens/mod.rs | 22 +-
.../configs/src/configs_impl/typed_env_provider.rs | 3 +
core/consensus/src/client_table.rs | 26 +
core/consensus/src/impls.rs | 31 +-
core/consensus/src/observability.rs | 2 +
core/harness_derive/src/attrs.rs | 17 +
core/harness_derive/src/codegen.rs | 4 +
core/integration/Cargo.toml | 1 +
core/integration/src/harness/config/server.rs | 2 +
core/integration/src/harness/handle/server.rs | 76 +-
.../src/harness/orchestrator/builder.rs | 25 +-
.../src/harness/orchestrator/harness.rs | 53 +
core/integration/src/harness/port_reserver.rs | 8 +
core/integration/tests/mod.rs | 8 +
core/integration/tests/sdk/hello_world.rs | 71 +
core/integration/tests/sdk/mod.rs | 2 +
core/message_bus/src/client_listener/quic.rs | 39 +-
core/message_bus/src/client_listener/tcp_tls.rs | 9 +-
core/message_bus/src/client_listener/wss.rs | 9 +-
core/message_bus/src/lib.rs | 26 +-
core/message_bus/src/replica/io.rs | 8 +-
core/message_bus/src/replica/listener.rs | 10 +-
core/message_bus/src/socket_opts.rs | 69 +-
core/message_bus/src/transports/quic.rs | 2 +
core/message_bus/tests/quic_client_roundtrip.rs | 4 +-
core/message_bus/tests/tcp_tls_client_listener.rs | 6 +-
core/message_bus/tests/wss_client_listener.rs | 6 +-
core/metadata/src/impls/metadata.rs | 215 ++-
core/metadata/src/stm/consumer_group.rs | 22 +-
core/metadata/src/stm/mod.rs | 16 +-
core/metadata/src/stm/stream.rs | 58 +-
core/metadata/src/stm/user.rs | 291 +++-
core/sdk/Cargo.toml | 5 +
core/sdk/src/lib.rs | 2 +
core/sdk/src/quic/quic_client.rs | 261 +++-
core/sdk/src/tcp/tcp_client.rs | 276 +++-
core/sdk/src/tcp/tcp_connection_stream.rs | 24 +
core/sdk/src/tcp/tcp_connection_stream_kind.rs | 10 +
core/sdk/src/tcp/tcp_tls_connection_stream.rs | 24 +
core/sdk/src/vsr.rs | 496 +++++++
core/sdk/src/websocket/websocket_client.rs | 241 +++-
core/server-ng/Cargo.toml | 1 +
core/server-ng/src/bootstrap.rs | 1425 +++++++++++++++++++-
core/server-ng/src/login_register.rs | 37 +-
core/server-ng/src/server_error.rs | 19 +
core/server-ng/src/session_manager.rs | 91 +-
core/server/src/bootstrap.rs | 14 +-
core/server_common/src/sharding/namespace.rs | 60 +-
core/simulator/src/client.rs | 11 +-
63 files changed, 4053 insertions(+), 469 deletions(-)
create mode 100644 core/binary_protocol/src/namespace.rs
create mode 100644 core/integration/tests/sdk/hello_world.rs
create mode 100644 core/sdk/src/vsr.rs