You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by lz...@apache.org on 2026/08/11 14:53:08 UTC
(iggy) 01/01: Merge branch 'master' into dotnet-vsr-cleanup
This is an automated email from the ASF dual-hosted git repository.
lukaszzborek pushed a commit to branch dotnet-vsr-cleanup
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit ee5ad3bda5851d904b6c2cce35ae1c741f1abc24
Merge: b1340e1fb 9cfb2d93a
Author: Łukasz Zborek <lu...@gmail.com>
AuthorDate: Tue Aug 11 16:51:52 2026 +0200
Merge branch 'master' into dotnet-vsr-cleanup
.dockerignore | 1 -
.github/actions/cpp-bazel/pre-merge/action.yml | 6 +-
.github/actions/csharp-dotnet/pre-merge/action.yml | 8 +-
.github/actions/go/pre-merge/action.yml | 17 +-
.github/actions/java-gradle/pre-merge/action.yml | 8 +-
.github/actions/node-npm/pre-merge/action.yml | 10 +-
.github/actions/php/pre-merge/action.yml | 11 +-
.../actions/python-maturin/pre-merge/action.yml | 15 +-
.github/actions/rust/pre-merge/action.yml | 21 +-
.../utils/docker-build-test-server/action.yml | 105 -
.github/actions/utils/server-start/action.yml | 9 +-
.github/config/components.yml | 12 +-
.github/dependabot.yml | 1 -
.github/workflows/_test_bdd.yml | 54 +-
.github/workflows/_test_examples.yml | 11 +-
.github/workflows/coverage-baseline.yml | 32 +-
.github/workflows/pr-title.yml | 1 -
.github/workflows/pre-merge.yml | 2 +-
AGENTS.md | 4 +-
Cargo.lock | 70 +-
Cargo.toml | 2 -
Dockerfile | 3 +-
README.md | 10 +-
bdd/README.md | 15 +-
bdd/docker-compose.cluster.yml | 50 +-
bdd/docker-compose.server.yml | 8 +-
bdd/docker-compose.vsr.yml | 102 -
bdd/python/tests/test_basic_messaging.py | 3 +-
bdd/rust/Cargo.toml | 1 -
core/ai/mcp/Cargo.toml | 1 -
core/bench/Cargo.toml | 12 -
core/bench/src/analytics/report_builder.rs | 4 +-
core/bench/src/main.rs | 16 +-
core/binary_protocol/src/consensus/command.rs | 2 +-
core/binary_protocol/src/framing.rs | 4 +-
.../src/requests/users/login_register.rs | 6 +-
.../src/requests/users/login_register_with_pat.rs | 2 +-
.../src/responses/topics/create_topic.rs | 2 +-
.../src/responses/users/login_register.rs | 2 +-
core/cli/Cargo.toml | 1 -
core/common/Cargo.toml | 3 -
core/common/src/error/eviction.rs | 4 +-
core/common/src/lib.rs | 3 -
core/common/src/traits/binary_client.rs | 15 +-
.../src/traits/binary_impls/consumer_groups.rs | 2 -
core/common/src/traits/binary_impls/messages.rs | 16 -
core/common/src/traits/binary_impls/mod.rs | 7 +-
.../traits/binary_impls/personal_access_tokens.rs | 110 +-
core/common/src/traits/binary_impls/system.rs | 1 -
core/common/src/traits/binary_impls/users.rs | 108 +-
core/common/src/traits/binary_transport.rs | 5 -
core/common/src/traits/message_client.rs | 2 +-
core/configs/Cargo.toml | 1 -
.../src/{server_config => common}/cache_indexes.rs | 0
.../src/{server_config => common}/defaults.rs | 190 +-
.../src/{server_config => common}/displays.rs | 86 +-
core/configs/src/{server_config => common}/http.rs | 0
.../src/state => configs/src/common}/mod.rs | 19 +-
core/configs/src/common/server.rs | 144 +
.../src/{server_config => common}/system.rs | 11 +-
core/configs/src/common/validators.rs | 357 ++
core/configs/src/lib.rs | 11 +-
core/configs/src/server_config/cluster.rs | 2450 +++++++++-
core/configs/src/server_config/defaults.rs | 620 +--
core/configs/src/server_config/displays.rs | 311 +-
.../message_bus.rs | 38 +-
.../metadata.rs | 24 +-
core/configs/src/server_config/mod.rs | 14 +-
.../partition.rs | 22 +-
core/configs/src/server_config/quic.rs | 157 +-
core/configs/src/server_config/server.rs | 263 +-
core/configs/src/server_config/sharding.rs | 383 +-
core/configs/src/server_config/tcp.rs | 2 +
core/configs/src/server_config/validators.rs | 1268 +++--
core/configs/src/server_config/websocket.rs | 100 +-
core/configs/src/server_ng_config/cluster.rs | 2612 ----------
core/configs/src/server_ng_config/defaults.rs | 335 --
core/configs/src/server_ng_config/displays.rs | 189 -
core/configs/src/server_ng_config/mod.rs | 45 -
core/configs/src/server_ng_config/quic.rs | 222 -
core/configs/src/server_ng_config/server_ng.rs | 229 -
core/configs/src/server_ng_config/sharding.rs | 431 --
core/configs/src/server_ng_config/tcp.rs | 62 -
core/configs/src/server_ng_config/validators.rs | 852 ----
core/configs/src/server_ng_config/websocket.rs | 116 -
core/connectors/runtime/Cargo.toml | 3 -
core/consensus/src/client_table.rs | 2 +-
core/consensus/src/impls.rs | 4 +-
core/harness_derive/src/attrs.rs | 7 +-
core/harness_derive/src/codegen.rs | 4 +-
core/integration/Cargo.toml | 14 +-
core/integration/src/bench_utils.rs | 13 +-
core/integration/src/harness/config/resolve.rs | 35 +-
core/integration/src/harness/config/server.rs | 4 +-
core/integration/src/harness/handle/server.rs | 23 +-
.../src/harness/orchestrator/builder.rs | 13 +-
.../src/harness/orchestrator/harness.rs | 14 +-
.../cli/message/test_message_flush_command.rs | 14 +-
.../tests/cli/stream/test_stream_purge_command.rs | 2 +-
.../tests/cli/system/test_cli_session_scenario.rs | 4 +-
.../tests/cli/system/test_me_command.rs | 23 +-
.../tests/cli/topic/test_topic_purge_command.rs | 2 +-
.../tests/cluster/client_table_restart.rs | 2 -
.../tests/cluster/metadata_checkpoint_restart.rs | 4 +-
.../tests/cluster/metadata_state_transfer.rs | 2 -
.../cluster/multi_shard_partition_convergence.rs | 2 -
.../tests/cluster/partition_state_transfer.rs | 14 +-
core/integration/tests/config_provider/mod.rs | 2 +-
core/integration/tests/data_integrity/mod.rs | 13 +-
.../data_integrity/verify_after_server_restart.rs | 45 +-
.../verify_auto_commit_offset_replicates.rs | 10 +-
core/integration/tests/mod.rs | 17 +-
.../tests/sdk/consumer_group_membership.rs | 2 +-
core/integration/tests/sdk/hello_world.rs | 1 -
core/integration/tests/sdk/http_refresh.rs | 2 +-
core/integration/tests/sdk/mod.rs | 3 -
core/integration/tests/sdk/protocol_version.rs | 2 -
core/integration/tests/sdk/raw.rs | 11 -
core/integration/tests/sdk/send_confirmation.rs | 36 +-
core/integration/tests/server/a2a_jwt/jwt_tests.rs | 23 +-
.../tests/server/cluster_view_durability_vsr.rs | 4 +-
core/integration/tests/server/flush_vsr.rs | 4 +-
core/integration/tests/server/general.rs | 19 -
core/integration/tests/server/http_client.rs | 4 +-
core/integration/tests/server/http_rbac.rs | 4 +-
core/integration/tests/server/http_tls.rs | 8 +-
core/integration/tests/server/http_vsr.rs | 6 +-
core/integration/tests/server/legacy_login_vsr.rs | 4 +-
.../tests/server/login_credentials_vsr.rs | 4 +-
core/integration/tests/server/mod.rs | 33 +-
.../tests/server/partition_view_durability_vsr.rs | 4 +-
.../integration/tests/server/poll_semantics_vsr.rs | 4 +-
core/integration/tests/server/purge_delete.rs | 62 +-
core/integration/tests/server/purge_vsr.rs | 2 +-
.../server/scenarios/authentication_scenario.rs | 7 +-
.../tests/server/scenarios/bench_scenario.rs | 45 -
.../tests/server/scenarios/encryption_scenario.rs | 40 +-
core/integration/tests/server/scenarios/mod.rs | 6 +-
.../tests/server/scenarios/permissions_scenario.rs | 4 +-
.../server/scenarios/purge_delete_scenario.rs | 104 +-
.../scenarios/reconnect_after_restart_scenario.rs | 2 +-
.../scenarios/restart_offset_skip_scenario.rs | 14 +-
.../scenarios/stream_size_validation_scenario.rs | 13 +-
.../tests/server/scenarios/system_scenario.rs | 7 +-
core/integration/tests/server/specific.rs | 39 +-
core/integration/tests/server/stats_vsr.rs | 2 +-
.../tests/server/topic_admission_vsr.rs | 2 +-
core/integration/tests/state/file.rs | 164 -
core/integration/tests/state/mod.rs | 92 -
core/integration/tests/state/system.rs | 212 -
core/integration/tests/storage/consumer_offsets.rs | 179 -
core/integration/tests/storage/mod.rs | 18 -
core/journal/src/prepare_journal.rs | 4 +-
core/message_bus/src/client_listener/quic.rs | 2 +-
core/message_bus/src/config.rs | 50 +-
core/message_bus/src/installer/conn_info.rs | 2 +-
core/message_bus/src/installer/mod.rs | 2 +-
core/message_bus/src/installer/wss.rs | 2 +-
core/message_bus/src/lib.rs | 24 +-
core/message_bus/src/replica/io.rs | 4 +-
core/message_bus/src/transports/quic.rs | 2 +-
core/message_bus/src/transports/tls/mod.rs | 4 +-
core/message_bus/tests/ws_client_roundtrip.rs | 4 +-
core/metadata/Cargo.toml | 2 +-
core/metadata/src/impls/metadata.rs | 8 +-
core/metadata/src/stm/stream.rs | 2 +-
core/metadata/src/stm/user.rs | 4 +-
core/partitions/Cargo.toml | 2 +-
core/partitions/src/journal.rs | 4 +-
core/sdk/Cargo.toml | 3 -
core/sdk/src/http/http_client.rs | 2 +-
core/sdk/src/lib.rs | 2 -
core/sdk/src/quic/quic_client.rs | 149 +-
core/sdk/src/session.rs | 2 +-
core/sdk/src/tcp/tcp_client.rs | 341 +-
core/sdk/src/tcp/tcp_connection_stream.rs | 2 -
core/sdk/src/tcp/tcp_connection_stream_kind.rs | 2 -
core/sdk/src/tcp/tcp_tls_connection_stream.rs | 2 -
core/sdk/src/websocket/websocket_client.rs | 126 +-
core/server-ng/.dockerignore | 30 -
core/server-ng/Cargo.toml | 195 -
core/server-ng/Dockerfile | 179 -
core/server-ng/build.rs | 86 -
core/server-ng/config.toml | 1034 ----
core/server-ng/server.http | 369 --
core/server-ng/src/args.rs | 34 -
core/server-ng/src/bootstrap.rs | 4401 -----------------
core/server-ng/src/http/error.rs | 818 ----
core/server-ng/src/http/metrics.rs | 297 --
core/server-ng/src/lib.rs | 47 -
core/server-ng/src/main.rs | 89 -
core/server-ng/src/server_error.rs | 391 --
core/server/Cargo.toml | 104 +-
core/server/Dockerfile | 11 +-
core/server/README.md | 37 +-
core/server/config.toml | 493 +-
core/server/server.http | 35 +-
core/server/src/args.rs | 122 +-
core/{server-ng => server}/src/auth.rs | 0
core/server/src/binary/dispatch.rs | 456 --
.../cluster/get_cluster_metadata_handler.rs | 60 -
core/server/src/binary/handlers/cluster/mod.rs | 18 -
.../create_consumer_group_handler.rs | 67 -
.../delete_consumer_group_handler.rs | 56 -
.../consumer_groups/get_consumer_group_handler.rs | 78 -
.../consumer_groups/get_consumer_groups_handler.rs | 69 -
.../consumer_groups/join_consumer_group_handler.rs | 57 -
.../leave_consumer_group_handler.rs | 57 -
.../src/binary/handlers/consumer_groups/mod.rs | 25 -
.../delete_consumer_offset_handler.rs | 56 -
.../get_consumer_offset_handler.rs | 79 -
.../src/binary/handlers/consumer_offsets/mod.rs | 22 -
.../store_consumer_offset_handler.rs | 63 -
.../messages/flush_unsaved_buffer_handler.rs | 65 -
core/server/src/binary/handlers/messages/mod.rs | 22 -
.../handlers/messages/poll_messages_handler.rs | 87 -
.../handlers/messages/send_messages_handler.rs | 203 -
core/server/src/binary/handlers/mod.rs | 28 -
.../partitions/create_partitions_handler.rs | 61 -
.../partitions/delete_partitions_handler.rs | 60 -
core/server/src/binary/handlers/partitions/mod.rs | 21 -
.../create_personal_access_token_handler.rs | 73 -
.../delete_personal_access_token_handler.rs | 57 -
.../get_personal_access_tokens_handler.rs | 60 -
.../login_with_personal_access_token_handler.rs | 51 -
.../binary/handlers/personal_access_tokens/mod.rs | 23 -
.../handlers/segments/delete_segments_handler.rs | 76 -
core/server/src/binary/handlers/segments/mod.rs | 18 -
.../handlers/streams/create_stream_handler.rs | 67 -
.../handlers/streams/delete_stream_handler.rs | 56 -
.../binary/handlers/streams/get_stream_handler.rs | 121 -
.../binary/handlers/streams/get_streams_handler.rs | 62 -
core/server/src/binary/handlers/streams/mod.rs | 25 -
.../handlers/streams/purge_stream_handler.rs | 56 -
.../handlers/streams/update_stream_handler.rs | 56 -
.../binary/handlers/system/get_client_handler.rs | 54 -
.../binary/handlers/system/get_clients_handler.rs | 44 -
.../src/binary/handlers/system/get_me_handler.rs | 77 -
.../binary/handlers/system/get_snapshot_handler.rs | 53 -
.../binary/handlers/system/get_stats_handler.rs | 93 -
core/server/src/binary/handlers/system/mod.rs | 25 -
.../src/binary/handlers/system/ping_handler.rs | 41 -
.../binary/handlers/topics/create_topic_handler.rs | 103 -
.../binary/handlers/topics/delete_topic_handler.rs | 56 -
.../binary/handlers/topics/get_topic_handler.rs | 76 -
.../binary/handlers/topics/get_topics_handler.rs | 61 -
core/server/src/binary/handlers/topics/mod.rs | 25 -
.../binary/handlers/topics/purge_topic_handler.rs | 56 -
.../binary/handlers/topics/update_topic_handler.rs | 56 -
.../handlers/users/change_password_handler.rs | 66 -
.../binary/handlers/users/create_user_handler.rs | 83 -
.../binary/handlers/users/delete_user_handler.rs | 57 -
.../src/binary/handlers/users/get_user_handler.rs | 62 -
.../src/binary/handlers/users/get_users_handler.rs | 53 -
.../binary/handlers/users/login_user_handler.rs | 71 -
.../binary/handlers/users/logout_user_handler.rs | 44 -
core/server/src/binary/handlers/users/mod.rs | 28 -
.../handlers/users/update_permissions_handler.rs | 59 -
.../binary/handlers/users/update_user_handler.rs | 65 -
core/server/src/binary/mod.rs | 21 -
core/server/src/bootstrap.rs | 5047 ++++++++++++++++++--
core/{server-ng => server}/src/cluster_meta.rs | 4 +-
.../src/compat/index_rebuilding/index_rebuilder.rs | 118 -
core/server/src/compat/index_rebuilding/mod.rs | 18 -
core/server/src/compat/mod.rs | 18 -
core/{server-ng => server}/src/config_writer.rs | 19 +-
core/server/src/configs.rs | 21 -
core/{server-ng => server}/src/consumer_group.rs | 0
core/server/src/diagnostics.rs | 22 -
core/{server-ng => server}/src/dispatch.rs | 24 +-
core/{server-ng => server}/src/dispatch/authz.rs | 0
core/{server-ng => server}/src/http.rs | 22 +-
core/{server-ng => server}/src/http/admission.rs | 0
core/server/src/http/consumer_groups.rs | 176 -
core/server/src/http/consumer_offsets.rs | 150 -
core/server/src/http/diagnostics.rs | 68 -
core/server/src/http/error.rs | 780 ++-
core/{server-ng => server}/src/http/extractor.rs | 0
core/{server-ng => server}/src/http/forward.rs | 14 +-
core/{server-ng => server}/src/http/handlers.rs | 4 +-
core/server/src/http/http_server.rs | 399 --
core/server/src/http/http_shard_wrapper.rs | 232 -
core/{server-ng => server}/src/http/jwks.rs | 0
core/{server-ng => server}/src/http/jwt.rs | 8 +-
core/server/src/http/jwt/json_web_token.rs | 155 -
core/server/src/http/jwt/jwks.rs | 357 --
core/server/src/http/jwt/jwt_manager.rs | 457 --
core/server/src/http/jwt/middleware.rs | 105 -
core/server/src/http/jwt/mod.rs | 24 -
core/server/src/http/jwt/storage.rs | 149 -
core/server/src/http/mapper.rs | 329 --
core/server/src/http/messages.rs | 164 -
core/server/src/http/metrics.rs | 296 +-
core/server/src/http/mod.rs | 40 -
core/server/src/http/partitions.rs | 104 -
core/server/src/http/personal_access_tokens.rs | 148 -
core/{server-ng => server}/src/http/reads.rs | 4 +-
core/{server-ng => server}/src/http/reply.rs | 4 +-
core/server/src/http/segments.rs | 120 -
core/{server-ng => server}/src/http/session.rs | 2 +-
core/server/src/http/shared.rs | 33 -
core/{server-ng => server}/src/http/state.rs | 14 +-
core/server/src/http/streams.rs | 200 -
core/{server-ng => server}/src/http/submit.rs | 10 +-
core/server/src/http/system.rs | 168 -
core/{server-ng => server}/src/http/tls.rs | 24 +-
core/server/src/http/topics.rs | 263 -
core/server/src/http/users.rs | 331 --
core/server/src/http/web.rs | 83 -
core/{server-ng => server}/src/http/wire.rs | 0
core/server/src/io/mod.rs | 20 -
core/server/src/io/storage.rs | 171 -
core/server/src/lib.rs | 56 +-
core/{server-ng => server}/src/login_register.rs | 0
core/server/src/main.rs | 591 +--
core/server/src/metadata/absorb.rs | 500 --
core/server/src/metadata/consumer_group.rs | 315 --
core/server/src/metadata/consumer_group_member.rs | 58 -
core/server/src/metadata/inner.rs | 54 -
core/server/src/metadata/mod.rs | 71 -
core/server/src/metadata/ops.rs | 134 -
core/server/src/metadata/partition.rs | 39 -
core/server/src/metadata/reader.rs | 1920 --------
core/server/src/metadata/stream.rs | 64 -
core/server/src/metadata/topic.rs | 72 -
core/server/src/metadata/user.rs | 30 -
core/server/src/metadata/writer.rs | 617 ---
core/{server-ng => server}/src/offset_recovery.rs | 4 +-
.../{server-ng => server}/src/partition_helpers.rs | 58 +-
.../src/partition_reconciler.rs | 34 +-
core/{server-ng => server}/src/pat.rs | 0
.../src/personal_access_token_cleaner.rs | 6 +-
core/server/src/quic/listener.rs | 239 -
core/server/src/quic/mod.rs | 22 -
core/server/src/quic/quic_server.rs | 222 -
core/server/src/quic/quic_socket.rs | 66 -
core/{server-ng => server}/src/responses.rs | 4 +-
core/{server-ng => server}/src/segment_cleaner.rs | 6 +-
core/{server-ng => server}/src/segment_recovery.rs | 30 +-
core/server/src/sender/mod.rs | 257 -
core/server/src/sender/quic_sender.rs | 140 -
core/server/src/sender/tcp_sender.rs | 90 -
core/server/src/sender/tcp_tls_sender.rs | 96 -
core/server/src/sender/websocket_sender.rs | 206 -
core/server/src/sender/websocket_tls_sender.rs | 185 -
core/server/src/server_error.rs | 453 +-
core/{server-ng => server}/src/session_manager.rs | 4 +-
core/server/src/shard/builder.rs | 197 -
core/server/src/shard/communication.rs | 198 -
core/server/src/shard/execution.rs | 732 ---
core/server/src/shard/handlers.rs | 614 ---
core/server/src/shard/mod.rs | 482 --
core/server/src/shard/system/clients.rs | 92 -
core/server/src/shard/system/cluster.rs | 196 -
core/server/src/shard/system/consumer_groups.rs | 205 -
core/server/src/shard/system/consumer_offsets.rs | 489 --
core/server/src/shard/system/info.rs | 78 -
core/server/src/shard/system/messages.rs | 695 ---
core/server/src/shard/system/mod.rs | 35 -
core/server/src/shard/system/partitions.rs | 443 --
.../src/shard/system/personal_access_tokens.rs | 149 -
core/server/src/shard/system/segments.rs | 586 ---
core/server/src/shard/system/snapshot/mod.rs | 257 -
core/server/src/shard/system/snapshot/procdump.rs | 213 -
core/server/src/shard/system/stats.rs | 120 -
core/server/src/shard/system/storage.rs | 99 -
core/server/src/shard/system/streams.rs | 179 -
core/server/src/shard/system/topics.rs | 250 -
core/server/src/shard/system/users.rs | 301 --
core/server/src/shard/system/utils.rs | 255 -
core/server/src/shard/systemd.rs | 45 -
core/server/src/shard/task_registry/builders.rs | 42 -
.../src/shard/task_registry/builders/continuous.rs | 109 -
.../src/shard/task_registry/builders/oneshot.rs | 120 -
.../src/shard/task_registry/builders/periodic.rs | 135 -
core/server/src/shard/task_registry/mod.rs | 23 -
core/server/src/shard/task_registry/registry.rs | 732 ---
core/server/src/shard/task_registry/shutdown.rs | 232 -
.../src/shard/tasks/continuous/http_server.rs | 40 -
.../src/shard/tasks/continuous/message_pump.rs | 135 -
core/server/src/shard/tasks/continuous/mod.rs | 28 -
.../src/shard/tasks/continuous/quic_server.rs | 36 -
.../src/shard/tasks/continuous/tcp_server.rs | 36 -
.../src/shard/tasks/continuous/websocket_server.rs | 38 -
core/server/src/shard/tasks/mod.rs | 20 -
.../src/shard/tasks/oneshot/config_writer.rs | 142 -
core/server/src/shard/tasks/oneshot/mod.rs | 20 -
.../src/shard/tasks/periodic/heartbeat_verifier.rs | 86 -
.../src/shard/tasks/periodic/jwt_token_cleaner.rs | 60 -
.../src/shard/tasks/periodic/message_cleaner.rs | 120 -
.../src/shard/tasks/periodic/message_saver.rs | 71 -
core/server/src/shard/tasks/periodic/mod.rs | 36 -
.../periodic/personal_access_token_cleaner.rs | 85 -
.../src/shard/tasks/periodic/revocation_timeout.rs | 105 -
.../src/shard/tasks/periodic/sysinfo_printer.rs | 103 -
.../src/shard/tasks/periodic/systemd_watchdog.rs | 47 -
core/server/src/shard/transmission/connector.rs | 106 -
core/server/src/shard/transmission/event.rs | 70 -
core/server/src/shard/transmission/frame.rs | 116 -
core/server/src/shard/transmission/message.rs | 254 -
core/server/src/shard/transmission/mod.rs | 21 -
core/{server-ng => server}/src/snapshot.rs | 14 +-
.../{server-ng => server}/src/snapshot/procdump.rs | 0
core/server/src/state/command.rs | 268 --
core/server/src/state/entry.rs | 150 -
core/server/src/state/file.rs | 378 --
core/server/src/state/models.rs | 334 --
core/server/src/state/system.rs | 633 ---
.../server/src/streaming/clients/client_manager.rs | 233 -
core/server/src/streaming/clients/mod.rs | 18 -
core/server/src/streaming/deduplication/mod.rs | 18 -
core/server/src/streaming/diagnostics/metrics.rs | 149 -
core/server/src/streaming/diagnostics/mod.rs | 18 -
core/server/src/streaming/mod.rs | 31 -
.../streaming/partitions/consumer_group_offsets.rs | 18 -
.../src/streaming/partitions/consumer_offset.rs | 18 -
.../src/streaming/partitions/consumer_offsets.rs | 18 -
core/server/src/streaming/partitions/helpers.rs | 36 -
core/server/src/streaming/partitions/in_flight.rs | 18 -
core/server/src/streaming/partitions/journal.rs | 212 -
.../src/streaming/partitions/local_partition.rs | 98 -
.../src/streaming/partitions/local_partitions.rs | 213 -
core/server/src/streaming/partitions/log.rs | 207 -
core/server/src/streaming/partitions/mod.rs | 33 -
core/server/src/streaming/partitions/ops.rs | 730 ---
core/server/src/streaming/partitions/ops_tests.rs | 358 --
core/server/src/streaming/partitions/segments.rs | 123 -
core/server/src/streaming/partitions/storage.rs | 346 --
core/server/src/streaming/persistence/mod.rs | 20 -
core/server/src/streaming/persistence/persister.rs | 166 -
core/server/src/streaming/polling_consumer.rs | 129 -
.../src/streaming/segments/indexes/index_reader.rs | 19 -
.../src/streaming/segments/indexes/index_writer.rs | 18 -
core/server/src/streaming/segments/indexes/mod.rs | 22 -
.../src/streaming/segments/memory_journal.rs | 17 -
.../streaming/segments/messages/messages_reader.rs | 19 -
.../streaming/segments/messages/messages_writer.rs | 18 -
core/server/src/streaming/segments/messages/mod.rs | 21 -
core/server/src/streaming/segments/mod.rs | 34 -
core/server/src/streaming/segments/segment.rs | 18 -
core/server/src/streaming/segments/storage.rs | 50 -
core/server/src/streaming/segments/types/mod.rs | 19 -
core/server/src/streaming/session.rs | 105 -
core/server/src/streaming/stats/mod.rs | 18 -
core/server/src/streaming/storage.rs | 39 -
core/server/src/streaming/streams/mod.rs | 20 -
core/server/src/streaming/streams/storage.rs | 65 -
core/server/src/streaming/topics/helpers.rs | 33 -
core/server/src/streaming/topics/mod.rs | 21 -
core/server/src/streaming/topics/storage.rs | 82 -
core/server/src/streaming/users/mod.rs | 18 -
core/server/src/streaming/users/user.rs | 137 -
core/server/src/streaming/utils/address.rs | 75 -
core/server/src/streaming/utils/file.rs | 54 -
core/server/src/streaming/utils/mod.rs | 22 -
core/server/src/streaming/utils/ptr.rs | 70 -
core/server/src/systemd.rs | 80 +
core/server/src/tcp/connection_handler.rs | 184 -
core/server/src/tcp/mod.rs | 73 -
core/server/src/tcp/tcp_listener.rs | 171 -
core/server/src/tcp/tcp_server.rs | 56 -
core/server/src/tcp/tcp_socket.rs | 97 -
core/server/src/tcp/tcp_tls_listener.rs | 224 -
core/{server-ng => server}/src/users.rs | 0
core/{server-ng => server}/src/web.rs | 0
core/server/src/websocket/connection_handler.rs | 175 -
core/server/src/websocket/mod.rs | 64 -
core/server/src/websocket/websocket_listener.rs | 182 -
core/server/src/websocket/websocket_server.rs | 59 -
.../server/src/websocket/websocket_tls_listener.rs | 272 --
core/{server-ng => server}/src/wire.rs | 0
core/{server-ng => server}/tests/sdk_e2e.rs | 18 +-
core/server_common/src/indexes_mut.rs | 2 +-
core/shard/Cargo.toml | 2 +-
core/shard/src/lib.rs | 88 +-
core/shard/src/router.rs | 8 +-
core/simulator/Cargo.toml | 2 +-
core/simulator/src/lib.rs | 16 +-
core/simulator/src/replica.rs | 18 +-
core/simulator/src/workload/auditor.rs | 2 +-
.../src/workload/ops/store_consumer_offset.rs | 2 +-
.../src/workload/ops/store_consumer_offset_2.rs | 2 +-
examples/go/README.md | 9 +-
examples/java/README.md | 9 +-
examples/node/src/tcp-tls/consumer.ts | 4 +-
examples/node/src/tcp-tls/producer.ts | 4 +-
examples/rust/Cargo.toml | 3 -
foreign/cpp/Cargo.toml | 2 +-
.../Fixtures/IggyServerFixture.cs | 6 +-
.../Fixtures/VsrCluster.cs | 10 +-
.../Helpers/Eventually.cs | 2 +-
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 2 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 2 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 2 +-
foreign/csharp/README.md | 32 +-
foreign/go/README.md | 10 +-
foreign/go/tests/e2e_helpers_test.go | 5 +-
.../apache/iggy/client/BaseIntegrationTest.java | 3 +-
foreign/node/docker-compose.yml | 4 +-
foreign/node/src/e2e/tls.system.e2e.ts | 4 +-
foreign/php/Cargo.toml | 2 +-
foreign/php/README.md | 2 +-
foreign/php/docker-compose.test.yml | 8 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/docker-compose.test.yml | 8 +-
foreign/python/tests/test_tls.py | 8 +-
justfile | 17 -
scripts/check-backwards-compat.sh | 260 -
scripts/run-bdd-tests.sh | 52 +-
scripts/run-examples-from-readme.sh | 52 +-
scripts/utils.sh | 10 +-
511 files changed, 12187 insertions(+), 51220 deletions(-)