You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gi...@apache.org on 2025/11/10 12:28:39 UTC
(iggy) branch dependabot/npm_and_yarn/web/sveltekit-superforms-2.27.4 updated (cace2cf9e -> 66eed87f5)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/npm_and_yarn/web/sveltekit-superforms-2.27.4
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit cace2cf9e chore(deps-dev): bump sveltekit-superforms from 2.27.1 to 2.27.4 in /web
add f7390aea4 fix(docs): update README for running iggy-server with defaults (#2277)
add 3ab721d4e feat(proc): Implement Processor Infrastructure/Libraries (for flink to start with) (#2275)
add ab5dd2c38 feat(csharp): add consumer and publisher clients (#2259)
add 7ef307c47 chore(rust): update server dependencies, improve TCP TLS client domain resolver (#2292)
add 33fca8d45 style(csharp): format dotnet code and enable `dotnet format` in CI (#2290)
add 886e11027 feat(js): add getClusterMetadata command (#2187)
add 995551caa chore(docs): clarify root credentials behavior and lifecycle (#2312)
add 8ee56a971 feat(connectors/flink): add flink processor (#2300)
add 3d15e9177 fix(helm): use proper service for UI ingress (#2313)
add 9ae08f93b fix(server): Fix overriding of config from env vars (#2314)
add e0322b2bf refactor(connectors): split connectors configs from the runtime config (#2317)
add 4fcfefbf6 feat(io_uring): implement thread per core io_uring (#2299)
add 1e133e5e8 chore(repo): bump all packages versions, mark as edge (#2322)
add 6251f4a9e chore(io_uring): replace compio-ws with tungstenite config in common crate (#2324)
add 66eed87f5 chore(deps-dev): bump sveltekit-superforms from 2.27.1 to 2.27.4 in /web
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 (cace2cf9e)
\
N -- N -- N refs/heads/dependabot/npm_and_yarn/web/sveltekit-superforms-2.27.4 (66eed87f5)
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 | 5 +-
.github/actions/node-npm/pre-merge/action.yml | 2 +
.gitignore | 2 +-
Cargo.lock | 2419 ++++++++++----------
Cargo.toml | 59 +-
DEPENDENCIES.md | 446 ++--
README.md | 6 +-
bdd/docker-compose.yml | 19 +-
bdd/go/tests/basic_messaging_test.go | 51 +-
bdd/go/tests/tcp_test/consumers_feature_create.go | 36 +-
bdd/go/tests/tcp_test/consumers_steps.go | 10 +-
bdd/go/tests/tcp_test/messages_feature_send.go | 15 -
bdd/go/tests/tcp_test/offset_feature_delete.go | 2 +-
bdd/go/tests/tcp_test/session_feature_login.go | 4 +-
bdd/go/tests/tcp_test/stream_feature_create.go | 49 +-
bdd/go/tests/tcp_test/stream_feature_get_by_id.go | 20 +-
bdd/go/tests/tcp_test/stream_steps.go | 8 +-
bdd/go/tests/tcp_test/topic_feature_create.go | 40 +-
bdd/go/tests/tcp_test/topic_steps.go | 10 +-
bdd/python/tests/test_basic_messaging.py | 43 +-
bdd/rust/tests/steps/streams.rs | 16 +-
bdd/rust/tests/steps/topics.rs | 16 +-
bdd/scenarios/basic_messaging.feature | 14 +-
core/ai/mcp/Cargo.toml | 4 +-
core/ai/mcp/Dockerfile | 2 +-
core/ai/mcp/src/service/mod.rs | 9 +-
core/ai/mcp/src/service/requests.rs | 12 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 6 +-
core/bench/report/src/types/transport.rs | 3 +
.../bench/src/actors/consumer/client/high_level.rs | 9 +-
core/bench/src/actors/consumer/client/interface.rs | 2 +-
core/bench/src/actors/consumer/client/low_level.rs | 17 +-
.../actors/consumer/typed_benchmark_consumer.rs | 2 +-
core/bench/src/actors/producer/client/interface.rs | 2 +-
core/bench/src/actors/producer/client/low_level.rs | 8 +-
.../actors/producer/typed_benchmark_producer.rs | 2 +-
.../typed_banchmark_producing_consumer.rs | 4 +-
core/bench/src/args/common.rs | 12 +-
core/bench/src/args/defaults.rs | 3 +-
core/bench/src/args/transport.rs | 42 +
core/bench/src/benchmarks/benchmark.rs | 30 +-
core/bench/src/benchmarks/common.rs | 52 +-
core/bench/src/utils/client_factory.rs | 4 +
core/bench/src/utils/mod.rs | 1 +
core/bench/src/utils/server_starter.rs | 18 +
core/binary_protocol/Cargo.toml | 2 +-
.../create_consumer_group.rs | 15 +-
.../src/cli/binary_streams/create_stream.rs | 11 +-
.../src/cli/binary_topics/create_topic.rs | 31 +-
.../client/binary_clients/consumer_group_client.rs | 1 -
.../src/client/binary_clients/stream_client.rs | 6 +-
.../src/client/binary_clients/topic_client.rs | 1 -
.../src/client/binary_consumer_groups/mod.rs | 2 -
.../src/client/binary_streams/mod.rs | 7 +-
.../src/client/binary_topics/mod.rs | 2 -
core/binary_protocol/src/utils/mapper.rs | 2 +-
core/cli/Cargo.toml | 4 +-
core/cli/src/args/consumer_offset.rs | 4 +-
core/cli/src/args/message.rs | 4 +-
core/cli/src/args/permissions/mod.rs | 2 +-
core/cli/src/args/permissions/stream.rs | 4 +-
core/cli/src/args/permissions/topic.rs | 4 +-
core/cli/src/main.rs | 6 +-
core/common/Cargo.toml | 5 +-
core/common/src/certificates.rs | 1 +
.../consumer_groups/create_consumer_group.rs | 47 +-
.../consumer_offsets/delete_consumer_offset.rs | 37 +-
.../consumer_offsets/get_consumer_offset.rs | 37 +-
.../consumer_offsets/store_consumer_offset.rs | 41 +-
core/common/src/commands/messages/poll_messages.rs | 46 +-
core/common/src/commands/streams/create_stream.rs | 41 +-
core/common/src/commands/topics/create_topic.rs | 61 +-
core/common/src/commands/users/defaults.rs | 2 +-
core/common/src/error/iggy_error.rs | 86 +-
core/common/src/lib.rs | 5 +-
core/common/src/locking/fast_async_lock.rs | 4 +-
core/common/src/locking/mod.rs | 10 +-
core/common/src/locking/tokio_lock.rs | 7 +-
core/common/src/types/args/mod.rs | 89 +-
.../configuration/auth_config/connection_string.rs | 6 +-
core/common/src/types/configuration/mod.rs | 1 +
.../configuration/tcp_config/tcp_client_config.rs | 3 +-
.../tcp_config/tcp_client_config_builder.rs | 3 +-
core/common/src/types/configuration/transport.rs | 6 +
.../types/configuration/websocket_config}/mod.rs | 12 +-
.../websocket_config/websocket_client_config.rs | 192 ++
.../websocket_client_config_builder.rs | 158 ++
.../websocket_client_reconnection_config.rs} | 48 +-
.../websocket_connection_string_options.rs | 209 ++
core/common/src/types/confirmation/mod.rs | 54 -
core/common/src/types/identifier/mod.rs | 9 +-
core/common/src/types/mod.rs | 1 -
.../src/types/permissions/permissions_global.rs | 12 +-
core/common/src/utils/crypto.rs | 8 +-
core/common/src/utils/mod.rs | 1 +
core/configs/server.toml | 85 +-
core/connectors/README.md | 4 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/Dockerfile | 2 +-
core/connectors/runtime/README.md | 9 +-
core/connectors/runtime/config.toml | 3 +
.../runtime/{ => example_config}/config.toml | 3 +
.../connectors/quickwit.toml} | 93 +-
.../runtime/example_config/connectors/random.toml} | 39 +-
.../runtime/example_config/connectors/stdout.toml} | 32 +-
core/connectors/runtime/src/configs.rs | 171 +-
core/connectors/runtime/src/context.rs | 24 +-
core/connectors/runtime/src/error.rs | 2 +
core/connectors/runtime/src/main.rs | 25 +-
core/connectors/runtime/src/sink.rs | 6 +-
core/connectors/runtime/src/source.rs | 8 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/README.md | 35 +-
core/connectors/sinks/README.md | 25 +-
core/connectors/sources/README.md | 25 +-
core/integration/Cargo.toml | 9 +-
core/integration/src/bench_utils.rs | 1 +
core/integration/src/lib.rs | 3 +
core/integration/src/quic_client.rs | 2 +
core/integration/src/test_mcp_server.rs | 94 +-
core/integration/src/test_server.rs | 151 +-
.../src/{quic_client.rs => websocket_client.rs} | 22 +-
core/integration/tests/archiver/disk.rs | 129 --
core/integration/tests/archiver/mod.rs | 59 -
core/integration/tests/archiver/s3.rs | 38 -
.../tests/cli/client/test_client_get_command.rs | 2 +-
core/integration/tests/cli/common/mod.rs | 6 +-
.../test_consumer_group_create_command.rs | 17 +-
.../test_consumer_group_delete_command.rs | 12 +-
.../test_consumer_group_get_command.rs | 14 +-
.../test_consumer_group_list_command.rs | 194 +-
.../test_consumer_offset_get_command.rs | 163 +-
.../test_consumer_offset_set_command.rs | 11 +-
.../tests/cli/context/test_context_applied.rs | 9 +-
.../tests/cli/general/test_help_command.rs | 17 +-
.../cli/message/test_message_flush_command.rs | 128 +-
.../tests/cli/message/test_message_poll_command.rs | 164 +-
.../message/test_message_poll_to_file_command.rs | 87 +-
.../tests/cli/message/test_message_send_command.rs | 256 +--
.../message/test_message_send_from_file_command.rs | 140 +-
.../cli/partition/test_partition_create_command.rs | 94 +-
.../cli/partition/test_partition_delete_command.rs | 103 +-
.../tests/cli/stream/test_stream_create_command.rs | 27 +-
.../tests/cli/stream/test_stream_delete_command.rs | 16 +-
.../tests/cli/stream/test_stream_get_command.rs | 24 +-
.../tests/cli/stream/test_stream_list_command.rs | 14 +-
.../tests/cli/stream/test_stream_purge_command.rs | 29 +-
.../tests/cli/stream/test_stream_update_command.rs | 25 +-
.../tests/cli/system/test_me_command.rs | 5 +
.../tests/cli/system/test_snapshot_cmd.rs | 2 +-
.../tests/cli/system/test_stats_command.rs | 12 +-
.../tests/cli/topic/test_topic_create_command.rs | 45 +-
.../tests/cli/topic/test_topic_delete_command.rs | 35 +-
.../tests/cli/topic/test_topic_get_command.rs | 39 +-
.../tests/cli/topic/test_topic_list_command.rs | 29 +-
.../tests/cli/topic/test_topic_purge_command.rs | 49 +-
.../tests/cli/topic/test_topic_update_command.rs | 120 +-
.../tests/cli/user/test_user_create_command.rs | 6 +-
.../tests/cli/user/test_user_delete_command.rs | 4 +-
.../tests/cli/user/test_user_get_command.rs | 8 +-
.../cli/user/test_user_permissions_command.rs | 8 +-
core/integration/tests/config_provider/mod.rs | 43 +-
core/integration/tests/connectors/mod.rs | 3 +-
.../data_integrity/verify_after_server_restart.rs | 156 +-
core/integration/tests/mcp/mod.rs | 27 +-
core/integration/tests/mod.rs | 1 -
core/integration/tests/sdk/producer/background.rs | 30 +-
core/integration/tests/sdk/producer/mod.rs | 14 +-
core/integration/tests/server/cg.rs | 3 +-
.../tests/server/concurrent_addition.rs | 128 ++
core/integration/tests/server/general.rs | 18 +-
core/integration/tests/server/mod.rs | 25 +-
.../tests/server/scenarios/concurrent_scenario.rs | 765 +++++++
.../scenarios/consumer_group_join_scenario.rs | 66 +-
...h_multiple_clients_polling_messages_scenario.rs | 69 +-
...with_single_client_polling_messages_scenario.rs | 48 +-
.../server/scenarios/create_message_payload.rs | 20 +-
.../server/scenarios/delete_segments_scenario.rs | 46 +-
.../tests/server/scenarios/encryption_scenario.rs | 50 +-
.../server/scenarios/message_headers_scenario.rs | 19 +-
.../server/scenarios/message_size_scenario.rs | 20 +-
core/integration/tests/server/scenarios/mod.rs | 28 +-
.../scenarios/stream_size_validation_scenario.rs | 3 +-
.../tests/server/scenarios/system_scenario.rs | 255 +--
.../tests/server/scenarios/tcp_tls_scenario.rs | 26 +-
.../tests/server/scenarios/user_scenario.rs | 12 +-
...p_tls_scenario.rs => websocket_tls_scenario.rs} | 37 +-
core/integration/tests/server/specific.rs | 49 +-
core/integration/tests/state/file.rs | 25 +-
core/integration/tests/state/mod.rs | 20 +-
core/integration/tests/state/system.rs | 36 +-
.../tests/streaming/common/test_setup.rs | 92 +-
.../integration/tests/streaming/consumer_offset.rs | 83 -
core/integration/tests/streaming/get_by_offset.rs | 144 +-
.../tests/streaming/get_by_timestamp.rs | 97 +-
core/integration/tests/streaming/messages.rs | 164 --
core/integration/tests/streaming/mod.rs | 132 +-
core/integration/tests/streaming/partition.rs | 226 --
core/integration/tests/streaming/segment.rs | 704 ------
core/integration/tests/streaming/snapshot.rs | 6 +-
core/integration/tests/streaming/stream.rs | 189 --
core/integration/tests/streaming/system.rs | 134 --
core/integration/tests/streaming/topic.rs | 270 ---
core/integration/tests/streaming/topic_messages.rs | 247 --
core/sdk/Cargo.toml | 4 +-
core/sdk/src/client_provider.rs | 49 +-
core/sdk/src/client_wrappers/binary_client.rs | 4 +
.../src/client_wrappers/binary_cluster_client.rs | 1 +
.../binary_consumer_group_client.rs | 40 +-
.../binary_consumer_offset_client.rs | 15 +
.../src/client_wrappers/binary_message_client.rs | 23 +
.../src/client_wrappers/binary_partition_client.rs | 10 +
.../binary_personal_access_token_client.rs | 8 +
.../src/client_wrappers/binary_segment_client.rs | 5 +
.../src/client_wrappers/binary_stream_client.rs | 20 +-
.../src/client_wrappers/binary_system_client.rs | 7 +
.../sdk/src/client_wrappers/binary_topic_client.rs | 35 +-
core/sdk/src/client_wrappers/binary_user_client.rs | 19 +
core/sdk/src/client_wrappers/client_wrapper.rs | 2 +
core/sdk/src/clients/binary_cluster.rs | 4 +-
core/sdk/src/clients/binary_consumer_group.rs | 8 +-
core/sdk/src/clients/binary_consumer_offset.rs | 2 +-
core/sdk/src/clients/binary_message.rs | 2 +-
core/sdk/src/clients/binary_partitions.rs | 2 +-
.../src/clients/binary_personal_access_tokens.rs | 2 +-
core/sdk/src/clients/binary_segments.rs | 2 +-
core/sdk/src/clients/binary_streams.rs | 14 +-
core/sdk/src/clients/binary_system.rs | 2 +-
core/sdk/src/clients/binary_topics.rs | 4 +-
core/sdk/src/clients/binary_users.rs | 2 +-
core/sdk/src/clients/client.rs | 21 +-
core/sdk/src/clients/client_builder.rs | 73 +-
core/sdk/src/clients/consumer.rs | 31 +-
core/sdk/src/clients/consumer_builder.rs | 6 +-
core/sdk/src/clients/producer.rs | 13 +-
core/sdk/src/clients/producer_builder.rs | 6 +-
core/sdk/src/http/binary_consumer_groups.rs | 2 -
core/sdk/src/http/binary_streams.rs | 7 +-
core/sdk/src/http/binary_topics.rs | 2 -
core/sdk/src/http/http_client.rs | 6 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/prelude.rs | 4 +-
.../src/stream_builder/build/build_stream_topic.rs | 7 +-
core/sdk/src/tcp/tcp_client.rs | 17 +-
core/sdk/src/tcp/tcp_tls_connection_stream.rs | 2 +-
core/sdk/src/tcp/tcp_tls_verifier.rs | 13 +-
.../src/plotting => sdk/src/websocket}/mod.rs | 8 +-
core/sdk/src/websocket/websocket_client.rs | 665 ++++++
.../src/websocket/websocket_connection_stream.rs | 213 ++
.../websocket_stream.rs} | 11 +-
.../websocket_stream_kind.rs} | 33 +-
.../websocket/websocket_tls_connection_stream.rs | 218 ++
core/server/Cargo.toml | 49 +-
core/server/Dockerfile | 3 +-
core/server/server.http | 2 +-
core/server/src/archiver/disk.rs | 99 -
core/server/src/archiver/mod.rs | 136 --
core/server/src/archiver/s3.rs | 194 --
core/server/src/args.rs | 2 +-
core/server/src/binary/command.rs | 5 +-
.../cluster/get_cluster_metadata_handler.rs | 10 +-
.../create_consumer_group_handler.rs | 61 +-
.../delete_consumer_group_handler.rs | 73 +-
.../consumer_groups/get_consumer_group_handler.rs | 43 +-
.../consumer_groups/get_consumer_groups_handler.rs | 44 +-
.../consumer_groups/join_consumer_group_handler.rs | 15 +-
.../leave_consumer_group_handler.rs | 18 +-
.../delete_consumer_offset_handler.rs | 12 +-
.../get_consumer_offset_handler.rs | 10 +-
.../store_consumer_offset_handler.rs | 13 +-
.../messages/flush_unsaved_buffer_handler.rs | 24 +-
.../handlers/messages/poll_messages_handler.rs | 72 +-
.../handlers/messages/send_messages_handler.rs | 58 +-
.../partitions/create_partitions_handler.rs | 52 +-
.../partitions/delete_partitions_handler.rs | 45 +-
.../create_personal_access_token_handler.rs | 29 +-
.../delete_personal_access_token_handler.rs | 25 +-
.../get_personal_access_tokens_handler.rs | 15 +-
.../login_with_personal_access_token_handler.rs | 13 +-
.../handlers/segments/delete_segments_handler.rs | 92 +-
.../handlers/streams/create_stream_handler.rs | 123 +-
.../handlers/streams/delete_stream_handler.rs | 98 +-
.../binary/handlers/streams/get_stream_handler.rs | 40 +-
.../binary/handlers/streams/get_streams_handler.rs | 29 +-
.../handlers/streams/purge_stream_handler.rs | 26 +-
.../handlers/streams/update_stream_handler.rs | 32 +-
.../binary/handlers/system/get_client_handler.rs | 10 +-
.../binary/handlers/system/get_clients_handler.rs | 19 +-
.../src/binary/handlers/system/get_me_handler.rs | 15 +-
.../src/binary/handlers/system/get_snapshot.rs | 8 +-
.../binary/handlers/system/get_stats_handler.rs | 54 +-
.../src/binary/handlers/system/ping_handler.rs | 11 +-
.../binary/handlers/topics/create_topic_handler.rs | 192 +-
.../binary/handlers/topics/delete_topic_handler.rs | 114 +-
.../binary/handlers/topics/get_topic_handler.rs | 44 +-
.../binary/handlers/topics/get_topics_handler.rs | 35 +-
.../binary/handlers/topics/purge_topic_handler.rs | 27 +-
.../binary/handlers/topics/update_topic_handler.rs | 157 +-
.../handlers/users/change_password_handler.rs | 31 +-
.../binary/handlers/users/create_user_handler.rs | 170 +-
.../binary/handlers/users/delete_user_handler.rs | 108 +-
.../src/binary/handlers/users/get_user_handler.rs | 11 +-
.../src/binary/handlers/users/get_users_handler.rs | 20 +-
.../binary/handlers/users/login_user_handler.rs | 30 +-
.../binary/handlers/users/logout_user_handler.rs | 22 +-
.../handlers/users/update_permissions_handler.rs | 26 +-
.../binary/handlers/users/update_user_handler.rs | 32 +-
core/server/src/binary/handlers/utils.rs | 15 +-
core/server/src/binary/mapper.rs | 205 +-
core/server/src/binary/sender.rs | 61 +-
core/server/src/bootstrap.rs | 726 ++++++
core/server/src/channels/commands/archive_state.rs | 139 --
.../commands/clean_personal_access_tokens.rs | 137 --
.../src/channels/commands/maintain_messages.rs | 555 -----
core/server/src/channels/commands/mod.rs | 24 -
core/server/src/channels/commands/print_sysinfo.rs | 123 -
core/server/src/channels/commands/save_messages.rs | 118 -
.../src/channels/commands/verify_heartbeats.rs | 150 --
core/server/src/channels/handler.rs | 46 -
core/server/src/channels/mod.rs | 21 -
core/server/src/channels/server_command.rs | 40 -
.../src/compat/index_rebuilding/index_rebuilder.rs | 49 +-
core/server/src/configs/cluster.rs | 3 +-
core/server/src/configs/config_provider.rs | 442 ++++
core/server/src/configs/defaults.rs | 94 +-
core/server/src/configs/displays.rs | 68 +-
core/server/src/configs/mod.rs | 3 +
core/server/src/configs/quic.rs | 9 +
core/server/src/configs/server.rs | 141 +-
core/server/src/configs/sharding.rs | 116 +
core/server/src/configs/system.rs | 101 +-
core/server/src/configs/validators.rs | 164 +-
core/server/src/configs/websocket.rs | 107 +
core/server/src/http/consumer_groups.rs | 287 ++-
core/server/src/http/consumer_offsets.rs | 36 +-
core/server/src/http/diagnostics.rs | 7 +-
core/server/src/http/error.rs | 5 -
core/server/src/http/http_server.rs | 150 +-
core/server/src/http/http_shard_wrapper.rs | 311 +++
core/server/src/http/jwt/cleaner.rs | 41 -
core/server/src/http/jwt/json_web_token.rs | 2 +-
core/server/src/http/jwt/jwt_manager.rs | 20 +-
core/server/src/http/jwt/middleware.rs | 12 +-
core/server/src/http/jwt/mod.rs | 1 -
core/server/src/http/jwt/storage.rs | 63 +-
core/server/src/http/mapper.rs | 282 ++-
core/server/src/http/messages.rs | 87 +-
core/server/src/http/metrics.rs | 2 +-
core/server/src/http/mod.rs | 10 +-
core/server/src/http/partitions.rs | 119 +-
core/server/src/http/personal_access_tokens.rs | 87 +-
core/server/src/http/shared.rs | 4 +-
core/server/src/http/streams.rs | 356 +--
core/server/src/http/system.rs | 70 +-
core/server/src/http/topics.rs | 481 ++--
core/server/src/http/users.rs | 386 +++-
core/server/src/io/fs_locks.rs | 51 +
core/server/src/io/fs_utils.rs | 105 +
.../src/types/client => server/src/io}/mod.rs | 4 +-
core/server/src/io/storage.rs | 148 ++
core/server/src/lib.rs | 20 +-
core/server/src/log/logger.rs | 8 +-
core/server/src/log/mod.rs | 6 +-
core/server/src/log/runtime.rs | 105 +
core/server/src/log/tokio_console.rs | 53 -
core/server/src/main.rs | 457 +++-
core/server/src/quic/listener.rs | 171 +-
core/server/src/quic/mod.rs | 1 +
core/server/src/quic/quic_sender.rs | 41 +-
core/server/src/quic/quic_server.rs | 168 +-
core/server/src/quic/quic_socket.rs | 66 +
core/server/src/server_error.rs | 45 +-
core/server/src/shard/builder.rs | 176 ++
core/server/src/shard/communication.rs | 206 ++
core/server/src/shard/handlers.rs | 516 +++++
core/server/src/shard/mod.rs | 318 +++
core/server/src/shard/namespace.rs | 121 +
.../{streaming/systems => shard/system}/clients.rs | 65 +-
.../cluster/mod.rs => shard/system/cluster.rs} | 27 +-
core/server/src/shard/system/consumer_groups.rs | 299 +++
core/server/src/shard/system/consumer_offsets.rs | 329 +++
.../{streaming/systems => shard/system}/info.rs | 54 -
core/server/src/shard/system/messages.rs | 479 ++++
.../src/{streaming/systems => shard/system}/mod.rs | 4 +-
core/server/src/shard/system/partitions.rs | 328 +++
.../system}/personal_access_tokens.rs | 152 +-
core/server/src/shard/system/segments.rs | 115 +
.../systems => shard/system}/snapshot/mod.rs | 138 +-
.../systems => shard/system}/snapshot/procdump.rs | 18 +-
core/server/src/shard/system/stats.rs | 136 ++
.../{streaming/systems => shard/system}/storage.rs | 40 +-
core/server/src/shard/system/streams.rs | 221 ++
core/server/src/shard/system/topics.rs | 356 +++
core/server/src/shard/system/users.rs | 452 ++++
core/server/src/shard/system/utils.rs | 188 ++
.../server/src/shard/task_registry/builders.rs | 32 +-
.../src/shard/task_registry/builders/continuous.rs | 109 +
.../src/shard/task_registry/builders/oneshot.rs | 120 +
.../src/shard/task_registry/builders/periodic.rs | 135 ++
.../src/shard/task_registry}/mod.rs | 8 +-
core/server/src/shard/task_registry/registry.rs | 598 +++++
core/server/src/shard/task_registry/shutdown.rs | 233 ++
.../tasks/continuous/http_server.rs} | 40 +-
.../src/shard/tasks/continuous/message_pump.rs | 75 +
.../src/shard/tasks/continuous}/mod.rs | 17 +-
.../tasks/continuous/quic_server.rs} | 33 +-
.../tasks/continuous/tcp_server.rs} | 33 +-
.../shard/tasks/continuous/websocket_server.rs} | 30 +-
.../text => server/src/shard/tasks}/mod.rs | 5 +-
.../src/shard/tasks/oneshot/config_writer.rs | 126 +
.../server/src/shard/tasks/oneshot/mod.rs | 4 +-
.../src/shard/tasks/periodic/heartbeat_verifier.rs | 87 +
.../src/shard/tasks/periodic/jwt_token_cleaner.rs | 61 +
.../src/shard/tasks/periodic/message_cleaner.rs | 392 ++++
.../src/shard/tasks/periodic/message_saver.rs | 124 +
.../partitions.rs => shard/tasks/periodic/mod.rs} | 23 +-
.../periodic/personal_access_token_cleaner.rs | 76 +
.../src/shard/tasks/periodic/sysinfo_printer.rs | 94 +
core/server/src/shard/transmission/connector.rs | 107 +
core/server/src/shard/transmission/event.rs | 138 ++
core/server/src/shard/transmission/frame.rs | 71 +
.../src/shard/transmission/id.rs} | 34 +-
core/server/src/shard/transmission/message.rs | 142 ++
.../text => server/src/shard/transmission}/mod.rs | 7 +-
core/server/src/slab/consumer_groups.rs | 173 ++
core/server/src/slab/helpers.rs | 70 +
core/server/src/slab/mod.rs | 43 +
core/server/src/slab/partitions.rs | 243 ++
core/server/src/slab/streams.rs | 1456 ++++++++++++
core/server/src/slab/topics.rs | 279 +++
core/server/src/slab/traits_ext.rs | 117 +
core/server/src/slab/users.rs | 207 ++
core/server/src/state/file.rs | 143 +-
core/server/src/state/mod.rs | 53 +-
core/server/src/state/models.rs | 44 +-
core/server/src/state/system.rs | 112 +-
.../server/src/streaming/clients/client_manager.rs | 241 +-
.../deduplication/message_deduplicator.rs | 53 +-
core/server/src/streaming/diagnostics/metrics.rs | 79 +-
core/server/src/streaming/local_sizeable.rs | 31 -
core/server/src/streaming/mod.rs | 6 +-
.../src/streaming/partitions/consumer_offset.rs | 68 +
.../src/streaming/partitions/consumer_offsets.rs | 214 --
core/server/src/streaming/partitions/helpers.rs | 542 +++++
core/server/src/streaming/partitions/journal.rs | 135 ++
core/server/src/streaming/partitions/log.rs | 176 ++
core/server/src/streaming/partitions/messages.rs | 766 -------
core/server/src/streaming/partitions/mod.rs | 7 +-
core/server/src/streaming/partitions/partition.rs | 686 +++---
.../server/src/streaming/partitions/persistence.rs | 114 -
core/server/src/streaming/partitions/segments.rs | 17 +-
core/server/src/streaming/partitions/storage.rs | 677 ++----
core/server/src/streaming/persistence/mod.rs | 1 -
core/server/src/streaming/persistence/persister.rs | 106 +-
core/server/src/streaming/persistence/task.rs | 133 --
core/server/src/streaming/polling_consumer.rs | 16 +-
.../src/streaming/segments/indexes/index_reader.rs | 68 +-
.../src/streaming/segments/indexes/index_writer.rs | 59 +-
.../src/streaming/segments/indexes/indexes_mut.rs | 9 +-
.../src/streaming/segments/memory_journal.rs | 2 +-
.../streaming/segments/messages/messages_reader.rs | 71 +-
.../streaming/segments/messages/messages_writer.rs | 138 +-
core/server/src/streaming/segments/messages/mod.rs | 41 +-
.../streaming/segments/messages/persister_task.rs | 215 --
.../src/streaming/segments/messages_accumulator.rs | 196 --
core/server/src/streaming/segments/mod.rs | 8 +-
.../src/streaming/segments/reading_messages.rs | 382 ----
core/server/src/streaming/segments/segment.rs | 573 +----
core/server/src/streaming/segments/storage.rs | 113 +
.../streaming/segments/types/messages_batch_mut.rs | 7 +-
.../streaming/segments/types/messages_batch_set.rs | 8 -
.../src/streaming/segments/writing_messages.rs | 182 --
core/server/src/streaming/session.rs | 46 +-
core/server/src/streaming/stats/mod.rs | 349 +++
core/server/src/streaming/storage.rs | 178 +-
core/server/src/streaming/streams/helpers.rs | 107 +
core/server/src/streaming/streams/messages.rs | 26 -
core/server/src/streaming/streams/mod.rs | 6 +-
core/server/src/streaming/streams/persistence.rs | 82 -
core/server/src/streaming/streams/segments.rs | 26 -
core/server/src/streaming/streams/storage.rs | 271 +--
core/server/src/streaming/streams/stream.rs | 310 ++-
core/server/src/streaming/streams/topics.rs | 338 ---
.../src/streaming/systems/consumer_groups.rs | 321 ---
.../src/streaming/systems/consumer_offsets.rs | 104 -
core/server/src/streaming/systems/messages.rs | 266 ---
core/server/src/streaming/systems/partitions.rs | 113 -
core/server/src/streaming/systems/segments.rs | 105 -
core/server/src/streaming/systems/stats.rs | 113 -
core/server/src/streaming/systems/streams.rs | 522 -----
core/server/src/streaming/systems/system.rs | 286 ---
core/server/src/streaming/systems/topics.rs | 302 ---
core/server/src/streaming/systems/users.rs | 531 -----
core/server/src/streaming/topics/consumer_group.rs | 438 ++--
.../server/src/streaming/topics/consumer_groups.rs | 426 ----
.../src/streaming/topics/consumer_offsets.rs | 144 --
core/server/src/streaming/topics/helpers.rs | 316 +++
core/server/src/streaming/topics/messages.rs | 361 ---
core/server/src/streaming/topics/mod.rs | 7 +-
core/server/src/streaming/topics/partitions.rs | 131 --
core/server/src/streaming/topics/persistence.rs | 71 -
core/server/src/streaming/topics/segments.rs | 31 -
core/server/src/streaming/topics/storage.rs | 358 +--
core/server/src/streaming/topics/topic.rs | 625 ++---
.../server/src/streaming/traits.rs | 40 +-
core/server/src/streaming/users/permissioner.rs | 6 +-
.../users/permissioner_rules/consumer_groups.rs | 24 +-
.../users/permissioner_rules/consumer_offsets.rs | 12 +-
.../streaming/users/permissioner_rules/messages.rs | 8 +-
.../users/permissioner_rules/partitions.rs | 8 +-
.../streaming/users/permissioner_rules/segments.rs | 4 +-
.../streaming/users/permissioner_rules/streams.rs | 10 +-
.../streaming/users/permissioner_rules/topics.rs | 30 +-
core/server/src/streaming/users/user.rs | 4 +-
core/server/src/streaming/utils/file.rs | 17 +-
core/server/src/streaming/utils/head_tail_buf.rs | 55 -
core/server/src/streaming/utils/memory_pool.rs | 47 +-
core/server/src/streaming/utils/mod.rs | 2 +-
core/server/src/streaming/utils/pooled_buffer.rs | 43 +-
core/server/src/streaming/utils/ptr.rs | 70 +
core/server/src/tcp/connection_handler.rs | 76 +-
core/server/src/tcp/mod.rs | 2 +-
core/server/src/tcp/sender.rs | 66 +-
core/server/src/tcp/tcp_listener.rs | 194 +-
core/server/src/tcp/tcp_sender.rs | 13 +-
core/server/src/tcp/tcp_server.rs | 42 +-
core/server/src/tcp/tcp_socket.rs | 32 +-
core/server/src/tcp/tcp_tls_listener.rs | 273 ++-
core/server/src/tcp/tcp_tls_sender.rs | 44 +-
core/server/src/versioning.rs | 102 +-
core/server/src/websocket/connection_handler.rs | 161 ++
.../src/github => server/src/websocket}/mod.rs | 10 +-
core/server/src/websocket/websocket_listener.rs | 185 ++
core/server/src/websocket/websocket_sender.rs | 200 ++
core/server/src/websocket/websocket_server.rs | 60 +
.../server/src/websocket/websocket_tls_listener.rs | 270 +++
core/server/src/websocket/websocket_tls_sender.rs | 186 ++
core/tools/src/data-seeder/seeder.rs | 65 +-
docker-compose.yml | 10 +-
{foreign => examples}/csharp/.editorconfig | 2 +-
examples/csharp/Iggy_SDK.Examples.sln | 17 +
.../csharp/Iggy_SDK.Examples.sln.DotSettings | 8 +-
.../Iggy_SDK.Examples.Basic.Consumer/Program.cs | 19 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 1 +
.../Iggy_SDK.Examples.Basic.Producer/Program.cs | 27 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 30 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 47 +-
.../src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs | 14 +-
.../src/Iggy_SDK.Examples.Shared/Messages.cs | 30 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 36 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 46 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 36 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 1 +
.../Program.cs | 17 +-
.../Utils.cs | 46 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj} | 14 +-
.../Iggy_SDK.Examples.NewSdk.Consumer/Program.cs | 60 +
.../Iggy_SDK.Examples.NewSdk.Consumer}/Utils.cs | 81 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj} | 3 +-
.../Iggy_SDK.Examples.NewSdk.Producer}/Program.cs | 34 +-
.../Iggy_SDK.Examples.NewSdk.Producer}/Utils.cs | 81 +-
examples/go/getting-started/consumer/main.go | 8 +-
examples/go/getting-started/producer/main.go | 15 +-
examples/rust/src/getting-started/consumer/main.rs | 6 +-
examples/rust/src/getting-started/producer/main.rs | 76 +-
examples/rust/src/multi-tenant/consumer/main.rs | 4 +-
examples/rust/src/multi-tenant/producer/main.rs | 4 +-
examples/rust/src/shared/args.rs | 68 +-
examples/rust/src/shared/system.rs | 3 +-
foreign/csharp/.editorconfig | 2 +-
foreign/csharp/Benchmarks/Program.cs | 33 +-
foreign/csharp/Benchmarks/SendMessage.cs | 10 +-
foreign/csharp/DEPENDENCIES.md | 12 +-
foreign/csharp/Directory.Packages.props | 12 +-
.../Iggy_SDK.Tests.BDD/Context/TestContext.cs | 2 +-
.../csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs | 2 +-
.../BasicMessagingOperationsSteps.cs | 64 +-
.../ConsumerGroupTests.cs | 7 +-
.../FetchMessagesTests.cs | 138 +-
.../Fixtures/FetchMessagesFixture.cs | 90 +-
.../Fixtures/FlushMessageFixture.cs | 20 +-
.../Fixtures/IggyServerFixture.cs | 21 +-
.../Fixtures/OffsetFixtures.cs | 20 +-
.../Fixtures/PartitionsFixture.cs | 2 +-
.../Fixtures/PollMessagesFixture.cs | 80 -
.../Fixtures/SendMessageFixture.cs | 2 +-
.../FlushMessagesTests.cs | 5 +-
.../IggyConsumerTests.cs | 838 +++++++
.../IggyPublisherTests.cs | 607 +++++
.../Iggy_SDK.Tests.Integration.csproj | 2 +-
.../Iggy_SDK.Tests.Integration/OffsetTests.cs | 44 +-
.../Iggy_SDK.Tests.Integration/PartitionsTests.cs | 1 +
.../PersonalAccessTokenTests.cs | 3 +-
.../PollMessagesTests.cs | 62 -
.../SendMessagesTests.cs | 69 +-
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 176 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 31 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 153 +-
.../Iggy_SDK.Tests.Integration/UsersTests.cs | 17 +-
...amConfigurator.cs => IggyClientConfigurator.cs} | 19 +-
.../Configuration/MessageBatchingSettings.cs | 2 +-
.../Configuration/MessagePollingSettings.cs | 2 +-
.../Configuration/MessageStreamConfigurator.cs | 49 -
.../Iggy_SDK/Configuration/TlsConfiguration.cs | 4 +-
.../Iggy_SDK/ConnectionStream/IConnectionStream.cs | 2 +-
.../ConnectionStream/TcpConnectionStream.cs | 8 +-
.../ConnectionStream/TcpTslConnectionStream.cs | 2 +-
.../AutoCommitMode.cs} | 31 +-
.../ConsumerErrorEventArgs.cs} | 32 +-
foreign/csharp/Iggy_SDK/Consumers/IDeserializer.cs | 54 +
.../Iggy_SDK/Consumers/IggyConsumer.Logging.cs | 107 +
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 400 ++++
.../Iggy_SDK/Consumers/IggyConsumerBuilder.cs | 316 +++
.../Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs | 141 ++
.../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 152 ++
.../csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs | 107 +
.../MessageStatus.cs} | 27 +-
.../csharp/Iggy_SDK/Consumers/ReceivedMessage.cs | 63 +
.../csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs | 2 +-
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/Permissions.cs | 2 +-
.../Contracts/Auth/PersonalAccessTokenResponse.cs | 2 +-
.../Contracts/Auth/RawPersonalAccessToken.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs | 2 +-
.../Iggy_SDK/Contracts/ConsumerGroupMembers.cs | 2 +-
.../Iggy_SDK/Contracts/ConsumerGroupResponse.cs | 2 +-
.../Contracts/Http/Auth/ChangePasswordRequest.cs | 2 +-
.../Http/Auth/CreatePersonalAccessTokenRequest.cs | 2 +-
.../Contracts/Http/Auth/CreateUserRequest.cs | 2 +-
.../Contracts/Http/Auth/LoginUserRequest.cs | 2 +-
.../Auth/LoginWIthPersonalAccessTokenRequest.cs | 2 +-
.../Http/Auth/UpdateUserPermissionsRequest.cs | 2 +-
.../Contracts/Http/Auth/UpdateUserRequest.cs | 2 +-
.../Contracts/Http/CreateConsumerGroupRequest.cs | 2 +-
.../Contracts/Http/CreatePartitionsRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/CreateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/CreateTopicRequest.cs | 7 +-
.../Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs | 2 +-
.../Iggy_SDK/Contracts/MessageFetchRequest.cs | 4 +-
.../csharp/Iggy_SDK/Contracts/MessageResponse.cs | 6 +-
.../Iggy_SDK/Contracts/MessageResponseGeneric.cs | 4 +-
.../Iggy_SDK/Contracts/MessageSendRequest.cs | 2 +-
.../Contracts/MessageSendRequestGeneric.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/OffsetResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/PartitionResponse.cs | 2 +-
.../Iggy_SDK/Contracts/PollMessagesRequest.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/PolledMessages.cs | 4 +-
.../Iggy_SDK/Contracts/PolledMessagesGeneric.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/StreamResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 112 +-
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs | 2 +-
.../Iggy_SDK/Encryption/AesMessageEncryptor.cs | 128 ++
.../Encryption/IMessageEncryptor.cs} | 35 +-
.../csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/MessageState.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/Protocol.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SnapshotCompression.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SystemSnapshotType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/UserStatus.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs | 2 +-
.../Exceptions/ConsumerGroupNotFoundException.cs | 18 +
...ption.cs => ConsumerNotInitializedException.cs} | 16 +-
.../Exceptions/FeatureUnavailableException.cs | 2 +-
...eption.cs => IggyInvalidStatusCodeException.cs} | 9 +-
.../Exceptions/InvalidBaseAdressException.cs | 4 +-
...tus.cs => InvalidConsumerGroupNameException.cs} | 6 +-
.../Exceptions/InvalidResponseException.cs | 2 +-
...tion.cs => PublisherNotInitializedException.cs} | 16 +-
...ableException.cs => StreamNotFoundException.cs} | 23 +-
.../Exceptions/TcpInvalidResponseException.cs | 2 +-
.../csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs | 2 +-
...ponseException.cs => TopicNotFoundException.cs} | 27 +-
foreign/csharp/Iggy_SDK/Extensions/Extensions.cs | 2 +-
.../IggyClientExtenstion.cs} | 45 +-
.../Iggy_SDK/Factory/HttpMessageStreamBuilder.cs | 78 -
.../csharp/Iggy_SDK/Factory/IggyClientFactory.cs | 79 +
.../Iggy_SDK/Factory/MessageStreamFactory.cs | 105 -
.../Iggy_SDK/Factory/TcpMessageStreamBuilder.cs | 78 -
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 2 +-
foreign/csharp/Iggy_SDK/Identifier.cs | 22 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs | 4 +-
.../csharp/Iggy_SDK/IggyClient/IIggyConsumer.cs | 30 +-
.../Iggy_SDK/IggyClient/IIggyConsumerGroup.cs | 4 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs | 2 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPartition.cs | 2 +-
.../IggyClient/IIggyPersonalAccessToken.cs | 2 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 22 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 4 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 7 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs | 2 +-
.../Implementations/HttpMessageStream.cs | 275 +--
.../IggyClient/Implementations/TcpMessageStream.cs | 288 +--
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 11 +-
.../JsonConverters/DateTimeOffsetConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/ExpiryConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/HeaderKeyConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/MessageConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/MessagesConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/SizeConverter.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Consumer.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/PollingStrategy.cs | 38 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 28 +-
foreign/csharp/Iggy_SDK/Messages/Message.cs | 8 +-
foreign/csharp/Iggy_SDK/Messages/MessageHeader.cs | 18 +-
.../MessagesDispatcher/HttpMessageInvoker.cs | 70 -
.../Iggy_SDK/MessagesDispatcher/IMessageInvoker.cs | 26 -
.../MessagesDispatcher/MessageSenderDispatcher.cs | 214 --
.../MessagesDispatcher/TcpMessageInvoker.cs | 88 -
.../BackgroundMessageProcessor.Logging.cs | 81 +
.../Publishers/BackgroundMessageProcessor.cs | 262 +++
foreign/csharp/Iggy_SDK/Publishers/ISerializer.cs | 54 +
.../Iggy_SDK/Publishers/IggyPublisher.Logging.cs | 139 ++
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 336 +++
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 425 ++++
.../Iggy_SDK/Publishers/IggyPublisherBuilderOfT.cs | 141 ++
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 257 +++
.../csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs | 116 +
.../Publishers/MessageBatchFailedEventArgs.cs | 60 +
.../Iggy_SDK/Publishers/PublisherErrorEventArgs.cs | 51 +
.../MessageRequestInterpolationHandler.cs | 26 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 77 +-
.../Iggy_SDK_Tests/ContractTests/TcpContract.cs | 1009 --------
foreign/csharp/Iggy_SDK_Tests/Usings.cs | 2 +-
.../UtilityTests/HeaderValueTests.cs | 2 +-
.../IdentifiersByteSerializationTests.cs | 2 +-
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs | 2 +-
.../Utils/DummyObj/DummyObjFactory.cs | 2 +-
.../Utils/Errors/ErrorModelFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs | 2 +-
.../Utils/Messages/MessageFactory.cs | 8 +-
.../csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs | 2 +-
.../SpecFlowTypes/ConsumerPollStreamTopicId.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs | 13 +-
.../Utils/Users/PermissionsFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Users/UsersFactory.cs | 2 +-
foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs | 2 +-
foreign/csharp/Shared/Envelope.cs | 2 +-
foreign/csharp/Shared/ISerializableMessage.cs | 2 +-
foreign/csharp/Shared/Orders.cs | 2 +-
.../go/benchmarks/send_messages_benchmark_test.go | 13 +-
.../binary_request_serializer.go | 160 +-
.../create_stream_serializer.go | 27 +-
.../create_stream_serializer_test.go | 10 -
.../create_topic_serializer.go | 11 +-
.../fetch_messages_request_serializer.go | 40 +-
.../fetch_messages_request_serializer_test.go | 1 +
.../binary_serialization/identifier_serializer.go | 8 +
.../send_messages_request_serializer.go | 31 +-
.../update_stream_serializer.go | 7 +-
foreign/go/contracts/consumer.go | 2 +-
foreign/go/contracts/consumer_groups.go | 1 -
foreign/go/contracts/identifier.go | 4 -
foreign/go/iggycli/client.go | 36 +-
foreign/go/samples/consumer/consumer.go | 23 +-
foreign/go/samples/producer/producer.go | 23 +-
foreign/go/tcp/tcp_consumer_group_managament.go | 6 +-
foreign/go/tcp/tcp_stream_managament.go | 7 +-
foreign/go/tcp/tcp_topic_managament.go | 7 +-
foreign/java/examples/build.gradle.kts | 2 +-
.../apache/iggy/async/AsyncConsumerExample.java | 9 +-
.../java/org/apache/iggy/async/AsyncProducer.java | 9 +-
.../org/apache/iggy/consumer/SimpleConsumer.java | 5 +-
.../org/apache/iggy/producer/SimpleProducer.java | 3 +-
.../iggy-connector-flink/docker-compose.yml | 273 +++
.../docker/Dockerfile.flink2_10-java21 | 11 +
.../iggy-connector-library/README.md | 72 +
.../iggy-connector-library/build.gradle.kts | 118 +
.../connector/config/IggyConnectionConfig.java | 228 ++
.../apache/iggy/connector/config/OffsetConfig.java | 153 ++
.../iggy/connector/error/ConnectorException.java | 94 +
.../iggy/connector/flink/sink/IggyCommittable.java | 129 ++
.../apache/iggy/connector/flink/sink/IggySink.java | 223 ++
.../iggy/connector/flink/sink/IggySinkBuilder.java | 220 ++
.../iggy/connector/flink/sink/IggySinkWriter.java | 303 +++
.../flink/source/IggyPartitionSplitReader.java | 257 +++
.../iggy/connector/flink/source/IggySource.java | 271 +++
.../connector/flink/source/IggySourceBuilder.java | 191 ++
.../flink/source/IggySourceEnumeratorState.java | 91 +
.../IggySourceEnumeratorStateSerializer.java | 100 +
.../connector/flink/source/IggySourceReader.java | 192 ++
.../connector/flink/source/IggySourceSplit.java | 163 ++
.../flink/source/IggySourceSplitEnumerator.java | 279 +++
.../flink/source/IggySourceSplitSerializer.java | 101 +
.../iggy/connector/partition/PartitionInfo.java | 123 +
.../serialization/DeserializationSchema.java | 63 +
.../serialization/JsonDeserializationSchema.java | 133 ++
.../serialization/JsonSerializationSchema.java | 169 ++
.../connector/serialization/RecordMetadata.java | 100 +
.../serialization/SerializationSchema.java | 65 +
.../serialization/StringDeserializationSchema.java | 87 +
.../connector/serialization/TypeDescriptor.java | 88 +
.../connector/config/IggyConnectionConfigTest.java | 221 ++
.../iggy/connector/config/OffsetConfigTest.java | 167 ++
.../connector/error/ConnectorExceptionTest.java | 168 ++
.../connector/partition/PartitionInfoTest.java | 157 ++
.../serialization/DeserializationSchemaTest.java | 171 ++
.../serialization/RecordMetadataTest.java | 151 ++
.../serialization/SerializationSchemaTest.java | 208 ++
.../serialization/TypeDescriptorTest.java | 178 ++
.../iggy-flink-examples/build.gradle.kts | 108 +
.../data-population-explanation.md | 279 +++
.../deploy-and-run-word-count-job.md | 258 +++
.../iggy/flink/example/MultiStreamJoinJob.java | 242 ++
.../iggy/flink/example/SendTestMessages.java | 73 +
.../iggy/flink/example/StreamTransformJob.java | 222 ++
.../apache/iggy/flink/example/WordCountJob.java | 166 ++
.../org/apache/iggy/flink/example/model/Alert.java | 107 +
.../iggy/flink/example/model/EnrichedActivity.java | 137 ++
.../iggy/flink/example/model/SensorReading.java | 98 +
.../iggy/flink/example/model/UserActivity.java | 98 +
.../iggy/flink/example/model/UserProfile.java | 97 +
.../apache/iggy/flink/example/model/WordCount.java | 75 +
.../flink/example/AsyncTcpMessagePollTest.java | 414 ++++
.../flink/example/AsyncTcpMessageSendTest.java | 308 +++
.../iggy/flink/example/SendTextDataTest.java | 139 ++
foreign/java/java-sdk/build.gradle.kts | 8 +-
.../apache/iggy/client/async/StreamsClient.java | 2 +-
.../org/apache/iggy/client/async/TopicsClient.java | 35 +-
.../client/async/tcp/AsyncBytesSerializer.java | 23 +
.../iggy/client/async/tcp/MessagesTcpClient.java | 25 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 5 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 4 +-
.../iggy/client/blocking/ConsumerGroupsClient.java | 6 +-
.../apache/iggy/client/blocking/StreamsClient.java | 2 +-
.../apache/iggy/client/blocking/TopicsClient.java | 3 -
.../blocking/http/ConsumerGroupsHttpClient.java | 7 +-
.../client/blocking/http/StreamsHttpClient.java | 6 +-
.../client/blocking/http/TopicsHttpClient.java | 5 +-
.../iggy/client/blocking/tcp/BytesSerializer.java | 13 +
.../blocking/tcp/ConsumerGroupsTcpClient.java | 5 +-
.../blocking/tcp/ConsumerOffsetTcpClient.java | 4 +-
.../client/blocking/tcp/MessagesTcpClient.java | 3 +-
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 5 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 5 +-
.../java/org/apache/iggy/TestConstants.java} | 12 +-
.../client/async/AsyncClientIntegrationTest.java | 228 +-
.../iggy/client/async/AsyncPollMessageTest.java | 147 +-
.../blocking/ConsumerGroupsClientBaseTest.java | 59 +-
.../blocking/ConsumerOffsetsClientBaseTest.java | 21 +-
.../iggy/client/blocking/IntegrationTest.java | 36 +-
.../client/blocking/MessagesClientBaseTest.java | 15 +-
.../client/blocking/PartitionsClientBaseTest.java | 12 +-
.../blocking/PersonalAccessTokensBaseTest.java | 2 +-
.../iggy/client/blocking/StreamClientBaseTest.java | 22 +-
.../iggy/client/blocking/TopicsClientBaseTest.java | 24 +-
.../iggy/client/blocking/UsersClientBaseTest.java | 4 +-
.../blocking/tcp/ConsumerGroupsTcpClientTest.java | 18 +-
foreign/java/settings.gradle.kts | 7 +
foreign/node/package-lock.json | 614 ++---
foreign/node/package.json | 2 +-
foreign/node/src/bdd/auth.ts | 2 +-
foreign/node/src/bdd/message.ts | 8 +-
foreign/node/src/bdd/stream.ts | 11 +-
foreign/node/src/bdd/topic.ts | 10 +-
foreign/node/src/client/client.connection.ts | 75 +-
foreign/node/src/client/client.socket.ts | 2 +-
foreign/node/src/debug-send.ts | 30 +-
foreign/node/src/debug.ts | 35 +-
.../e2e/{tcp.token.e2e.ts => tcp.cluster.e2e.ts} | 50 +-
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 76 +-
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 23 +-
foreign/node/src/e2e/tcp.send-message.e2e.ts | 93 +-
foreign/node/src/e2e/tcp.stream.e2e.ts | 13 +-
foreign/node/src/e2e/tcp.system.e2e.ts | 6 +-
foreign/node/src/e2e/tcp.topic.e2e.ts | 50 +-
foreign/node/src/examples/stream-file-to-topic.ts | 26 +-
foreign/node/src/examples/stream-topic-to-file.ts | 24 +-
foreign/node/src/stream/consumer-stream.ts | 14 +-
foreign/node/src/wire/cluster/cluster.type.ts | 91 +
foreign/node/src/wire/cluster/cluster.utils.ts | 151 ++
.../get-cluster-metadata.command.ts} | 13 +-
foreign/node/src/{stream => wire/cluster}/index.ts | 4 +-
foreign/node/src/wire/command-set.ts | 10 +
foreign/node/src/wire/command.code.ts | 1 +
foreign/node/src/wire/command.utils.ts | 7 -
.../consumer-group/create-group.command.test.ts | 7 +-
.../wire/consumer-group/create-group.command.ts | 9 +-
.../consumer-group/ensure-group.virtual.command.ts | 16 +-
foreign/node/src/wire/error.utils.ts | 21 +
.../node/src/wire/message/poll-messages.command.ts | 2 +-
foreign/node/src/wire/message/poll.utils.ts | 2 +-
.../node/src/wire/offset/delete-offset.command.ts | 2 +-
foreign/node/src/wire/offset/get-offset.command.ts | 8 +-
foreign/node/src/wire/offset/offset.utils.ts | 22 +-
.../node/src/wire/offset/store-offset.command.ts | 2 +-
.../src/wire/stream/create-stream.command.test.ts | 9 +-
.../node/src/wire/stream/create-stream.command.ts | 12 +-
.../wire/stream/ensure-stream.virtual.command.ts | 13 +-
foreign/node/src/wire/system/get-stats.command.ts | 2 +-
.../src/wire/topic/create-topic.command.test.ts | 5 +-
.../node/src/wire/topic/create-topic.command.ts | 24 +-
.../src/wire/topic/ensure-topic.virtual.command.ts | 14 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 7 +-
foreign/python/python_examples/consumer.py | 2 +-
foreign/python/python_examples/producer.py | 2 +-
foreign/python/src/client.rs | 9 +-
foreign/python/tests/test_iggy_sdk.py | 13 +-
helm/charts/iggy/templates/ingress.yaml | 4 +-
justfile | 3 -
scripts/run-csharp-examples-from-readme.sh | 2 +-
scripts/run-go-examples-from-readme.sh | 2 +-
scripts/run-rust-examples-from-readme.sh | 2 +-
web/package-lock.json | 18 +-
web/package.json | 2 +-
940 files changed, 46247 insertions(+), 26510 deletions(-)
copy core/{bench/dashboard/frontend/src/components => common/src/types/configuration/websocket_config}/mod.rs (82%)
create mode 100644 core/common/src/types/configuration/websocket_config/websocket_client_config.rs
create mode 100644 core/common/src/types/configuration/websocket_config/websocket_client_config_builder.rs
copy core/common/src/types/configuration/{quic_config/quic_client_reconnection_config.rs => websocket_config/websocket_client_reconnection_config.rs} (50%)
create mode 100644 core/common/src/types/configuration/websocket_config/websocket_connection_string_options.rs
delete mode 100644 core/common/src/types/confirmation/mod.rs
copy core/connectors/runtime/{ => example_config}/config.toml (95%)
rename core/connectors/runtime/{example_config.toml => example_config/connectors/quickwit.toml} (51%)
copy core/{integration/tests/connectors/postgres/postgres.toml => connectors/runtime/example_config/connectors/random.toml} (65%)
copy core/{integration/tests/connectors/postgres/postgres.toml => connectors/runtime/example_config/connectors/stdout.toml} (68%)
copy core/integration/src/{quic_client.rs => websocket_client.rs} (70%)
delete mode 100644 core/integration/tests/archiver/disk.rs
delete mode 100644 core/integration/tests/archiver/mod.rs
delete mode 100644 core/integration/tests/archiver/s3.rs
create mode 100644 core/integration/tests/server/concurrent_addition.rs
create mode 100644 core/integration/tests/server/scenarios/concurrent_scenario.rs
copy core/integration/tests/server/scenarios/{tcp_tls_scenario.rs => websocket_tls_scenario.rs} (70%)
delete mode 100644 core/integration/tests/streaming/consumer_offset.rs
delete mode 100644 core/integration/tests/streaming/messages.rs
delete mode 100644 core/integration/tests/streaming/partition.rs
delete mode 100644 core/integration/tests/streaming/segment.rs
delete mode 100644 core/integration/tests/streaming/stream.rs
delete mode 100644 core/integration/tests/streaming/system.rs
delete mode 100644 core/integration/tests/streaming/topic.rs
delete mode 100644 core/integration/tests/streaming/topic_messages.rs
copy core/{bench/report/src/plotting => sdk/src/websocket}/mod.rs (81%)
create mode 100644 core/sdk/src/websocket/websocket_client.rs
create mode 100644 core/sdk/src/websocket/websocket_connection_stream.rs
copy core/sdk/src/{tcp/tcp_stream.rs => websocket/websocket_stream.rs} (77%)
copy core/sdk/src/{tcp/tcp_connection_stream_kind.rs => websocket/websocket_stream_kind.rs} (59%)
create mode 100644 core/sdk/src/websocket/websocket_tls_connection_stream.rs
delete mode 100644 core/server/src/archiver/disk.rs
delete mode 100644 core/server/src/archiver/mod.rs
delete mode 100644 core/server/src/archiver/s3.rs
create mode 100644 core/server/src/bootstrap.rs
delete mode 100644 core/server/src/channels/commands/archive_state.rs
delete mode 100644 core/server/src/channels/commands/clean_personal_access_tokens.rs
delete mode 100644 core/server/src/channels/commands/maintain_messages.rs
delete mode 100644 core/server/src/channels/commands/mod.rs
delete mode 100644 core/server/src/channels/commands/print_sysinfo.rs
delete mode 100644 core/server/src/channels/commands/save_messages.rs
delete mode 100644 core/server/src/channels/commands/verify_heartbeats.rs
delete mode 100644 core/server/src/channels/handler.rs
delete mode 100644 core/server/src/channels/mod.rs
delete mode 100644 core/server/src/channels/server_command.rs
create mode 100644 core/server/src/configs/config_provider.rs
create mode 100644 core/server/src/configs/sharding.rs
create mode 100644 core/server/src/configs/websocket.rs
create mode 100644 core/server/src/http/http_shard_wrapper.rs
delete mode 100644 core/server/src/http/jwt/cleaner.rs
create mode 100644 core/server/src/io/fs_locks.rs
create mode 100644 core/server/src/io/fs_utils.rs
copy core/{common/src/types/client => server/src/io}/mod.rs (93%)
create mode 100644 core/server/src/io/storage.rs
create mode 100644 core/server/src/log/runtime.rs
delete mode 100644 core/server/src/log/tokio_console.rs
create mode 100644 core/server/src/quic/quic_socket.rs
create mode 100644 core/server/src/shard/builder.rs
create mode 100644 core/server/src/shard/communication.rs
create mode 100644 core/server/src/shard/handlers.rs
create mode 100644 core/server/src/shard/mod.rs
create mode 100644 core/server/src/shard/namespace.rs
rename core/server/src/{streaming/systems => shard/system}/clients.rs (59%)
copy core/server/src/{streaming/systems/cluster/mod.rs => shard/system/cluster.rs} (78%)
create mode 100644 core/server/src/shard/system/consumer_groups.rs
create mode 100644 core/server/src/shard/system/consumer_offsets.rs
rename core/server/src/{streaming/systems => shard/system}/info.rs (54%)
create mode 100644 core/server/src/shard/system/messages.rs
rename core/server/src/{streaming/systems => shard/system}/mod.rs (94%)
create mode 100644 core/server/src/shard/system/partitions.rs
rename core/server/src/{streaming/systems => shard/system}/personal_access_tokens.rs (56%)
create mode 100644 core/server/src/shard/system/segments.rs
rename core/server/src/{streaming/systems => shard/system}/snapshot/mod.rs (63%)
rename core/server/src/{streaming/systems => shard/system}/snapshot/procdump.rs (93%)
create mode 100644 core/server/src/shard/system/stats.rs
rename core/server/src/{streaming/systems => shard/system}/storage.rs (75%)
create mode 100644 core/server/src/shard/system/streams.rs
create mode 100644 core/server/src/shard/system/topics.rs
create mode 100644 core/server/src/shard/system/users.rs
create mode 100644 core/server/src/shard/system/utils.rs
copy foreign/cpp/tests/unit/serialization_test.cc => core/server/src/shard/task_registry/builders.rs (55%)
create mode 100644 core/server/src/shard/task_registry/builders/continuous.rs
create mode 100644 core/server/src/shard/task_registry/builders/oneshot.rs
create mode 100644 core/server/src/shard/task_registry/builders/periodic.rs
copy core/{bench/dashboard/server/src/github => server/src/shard/task_registry}/mod.rs (85%)
create mode 100644 core/server/src/shard/task_registry/registry.rs
create mode 100644 core/server/src/shard/task_registry/shutdown.rs
copy core/server/src/{streaming/users/permissioner_rules/system.rs => shard/tasks/continuous/http_server.rs} (52%)
create mode 100644 core/server/src/shard/tasks/continuous/message_pump.rs
copy core/{bench/src/analytics/time_series/processors => server/src/shard/tasks/continuous}/mod.rs (72%)
copy core/server/src/{binary/handlers/utils.rs => shard/tasks/continuous/quic_server.rs} (60%)
copy core/server/src/{streaming/users/permissioner_rules/partitions.rs => shard/tasks/continuous/tcp_server.rs} (60%)
copy core/{binary_protocol/src/utils/auth.rs => server/src/shard/tasks/continuous/websocket_server.rs} (59%)
copy core/{bench/report/src/plotting/text => server/src/shard/tasks}/mod.rs (93%)
create mode 100644 core/server/src/shard/tasks/oneshot/config_writer.rs
copy foreign/go/errors/errors.go => core/server/src/shard/tasks/oneshot/mod.rs (92%)
create mode 100644 core/server/src/shard/tasks/periodic/heartbeat_verifier.rs
create mode 100644 core/server/src/shard/tasks/periodic/jwt_token_cleaner.rs
create mode 100644 core/server/src/shard/tasks/periodic/message_cleaner.rs
create mode 100644 core/server/src/shard/tasks/periodic/message_saver.rs
rename core/server/src/{streaming/streams/partitions.rs => shard/tasks/periodic/mod.rs} (64%)
create mode 100644 core/server/src/shard/tasks/periodic/personal_access_token_cleaner.rs
create mode 100644 core/server/src/shard/tasks/periodic/sysinfo_printer.rs
create mode 100644 core/server/src/shard/transmission/connector.rs
create mode 100644 core/server/src/shard/transmission/event.rs
create mode 100644 core/server/src/shard/transmission/frame.rs
copy core/{binary_protocol/src/cli/cli_command.rs => server/src/shard/transmission/id.rs} (66%)
create mode 100644 core/server/src/shard/transmission/message.rs
copy core/{bench/report/src/plotting/text => server/src/shard/transmission}/mod.rs (91%)
create mode 100644 core/server/src/slab/consumer_groups.rs
create mode 100644 core/server/src/slab/helpers.rs
create mode 100644 core/server/src/slab/mod.rs
create mode 100644 core/server/src/slab/partitions.rs
create mode 100644 core/server/src/slab/streams.rs
create mode 100644 core/server/src/slab/topics.rs
create mode 100644 core/server/src/slab/traits_ext.rs
create mode 100644 core/server/src/slab/users.rs
delete mode 100644 core/server/src/streaming/local_sizeable.rs
create mode 100644 core/server/src/streaming/partitions/consumer_offset.rs
delete mode 100644 core/server/src/streaming/partitions/consumer_offsets.rs
create mode 100644 core/server/src/streaming/partitions/helpers.rs
create mode 100644 core/server/src/streaming/partitions/journal.rs
create mode 100644 core/server/src/streaming/partitions/log.rs
delete mode 100644 core/server/src/streaming/partitions/messages.rs
delete mode 100644 core/server/src/streaming/partitions/persistence.rs
delete mode 100644 core/server/src/streaming/persistence/task.rs
copy foreign/cpp/sdk/net/quic/address.h => core/server/src/streaming/segments/memory_journal.rs (98%)
delete mode 100644 core/server/src/streaming/segments/messages/persister_task.rs
delete mode 100644 core/server/src/streaming/segments/messages_accumulator.rs
delete mode 100644 core/server/src/streaming/segments/reading_messages.rs
create mode 100644 core/server/src/streaming/segments/storage.rs
delete mode 100644 core/server/src/streaming/segments/writing_messages.rs
create mode 100644 core/server/src/streaming/stats/mod.rs
create mode 100644 core/server/src/streaming/streams/helpers.rs
delete mode 100644 core/server/src/streaming/streams/messages.rs
delete mode 100644 core/server/src/streaming/streams/persistence.rs
delete mode 100644 core/server/src/streaming/streams/segments.rs
delete mode 100644 core/server/src/streaming/streams/topics.rs
delete mode 100644 core/server/src/streaming/systems/consumer_groups.rs
delete mode 100644 core/server/src/streaming/systems/consumer_offsets.rs
delete mode 100644 core/server/src/streaming/systems/messages.rs
delete mode 100644 core/server/src/streaming/systems/partitions.rs
delete mode 100644 core/server/src/streaming/systems/segments.rs
delete mode 100644 core/server/src/streaming/systems/stats.rs
delete mode 100644 core/server/src/streaming/systems/streams.rs
delete mode 100644 core/server/src/streaming/systems/system.rs
delete mode 100644 core/server/src/streaming/systems/topics.rs
delete mode 100644 core/server/src/streaming/systems/users.rs
delete mode 100644 core/server/src/streaming/topics/consumer_groups.rs
delete mode 100644 core/server/src/streaming/topics/consumer_offsets.rs
create mode 100644 core/server/src/streaming/topics/helpers.rs
delete mode 100644 core/server/src/streaming/topics/messages.rs
delete mode 100644 core/server/src/streaming/topics/partitions.rs
delete mode 100644 core/server/src/streaming/topics/persistence.rs
delete mode 100644 core/server/src/streaming/topics/segments.rs
copy foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs => core/server/src/streaming/traits.rs (55%)
delete mode 100644 core/server/src/streaming/utils/head_tail_buf.rs
create mode 100644 core/server/src/streaming/utils/ptr.rs
create mode 100644 core/server/src/websocket/connection_handler.rs
copy core/{bench/dashboard/server/src/github => server/src/websocket}/mod.rs (79%)
create mode 100644 core/server/src/websocket/websocket_listener.rs
create mode 100644 core/server/src/websocket/websocket_sender.rs
create mode 100644 core/server/src/websocket/websocket_server.rs
create mode 100644 core/server/src/websocket/websocket_tls_listener.rs
create mode 100644 core/server/src/websocket/websocket_tls_sender.rs
copy {foreign => examples}/csharp/.editorconfig (99%)
copy foreign/csharp/Iggy_SDK.sln.DotSettings => examples/csharp/Iggy_SDK.Examples.sln.DotSettings (99%)
copy examples/csharp/src/{MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj => NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Iggy_SDK.Examples.NewSdk.Consumer.csproj} (71%)
create mode 100644 examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Program.cs
copy examples/csharp/src/{MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer => NewSdk/Iggy_SDK.Examples.NewSdk.Consumer}/Utils.cs (59%)
copy examples/csharp/src/{MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj => NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Iggy_SDK.Examples.NewSdk.Producer.csproj} (91%)
copy examples/csharp/src/{MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer => NewSdk/Iggy_SDK.Examples.NewSdk.Producer}/Program.cs (51%)
copy examples/csharp/src/{MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer => NewSdk/Iggy_SDK.Examples.NewSdk.Producer}/Utils.cs (59%)
delete mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/Fixtures/PollMessagesFixture.cs
create mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/IggyConsumerTests.cs
create mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/IggyPublisherTests.cs
delete mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/PollMessagesTests.cs
rename foreign/csharp/Iggy_SDK/Configuration/{IMessageStreamConfigurator.cs => IggyClientConfigurator.cs} (62%)
delete mode 100644 foreign/csharp/Iggy_SDK/Configuration/MessageStreamConfigurator.cs
copy foreign/csharp/Iggy_SDK/{Configuration/MessageBatchingSettings.cs => Consumers/AutoCommitMode.cs} (63%)
copy foreign/csharp/Iggy_SDK/{Configuration/MessageBatchingSettings.cs => Consumers/ConsumerErrorEventArgs.cs} (51%)
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IDeserializer.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.Logging.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilder.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumerConfig.cs
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs
copy foreign/csharp/Iggy_SDK/{Enums/CompressionAlgorithm.cs => Consumers/MessageStatus.cs} (67%)
create mode 100644 foreign/csharp/Iggy_SDK/Consumers/ReceivedMessage.cs
create mode 100644 foreign/csharp/Iggy_SDK/Encryption/AesMessageEncryptor.cs
copy foreign/csharp/{Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs => Iggy_SDK/Encryption/IMessageEncryptor.cs} (53%)
create mode 100644 foreign/csharp/Iggy_SDK/Exceptions/ConsumerGroupNotFoundException.cs
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidResponseException.cs => ConsumerNotInitializedException.cs} (65%)
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidBaseAdressException.cs => IggyInvalidStatusCodeException.cs} (78%)
copy foreign/csharp/Iggy_SDK/Exceptions/{TcpInvalidStatus.cs => InvalidConsumerGroupNameException.cs} (86%)
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidResponseException.cs => PublisherNotInitializedException.cs} (65%)
copy foreign/csharp/Iggy_SDK/Exceptions/{FeatureUnavailableException.cs => StreamNotFoundException.cs} (58%)
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidResponseException.cs => TopicNotFoundException.cs} (51%)
copy foreign/csharp/Iggy_SDK/{Enums/IdKind.cs => Extensions/IggyClientExtenstion.cs} (50%)
delete mode 100644 foreign/csharp/Iggy_SDK/Factory/HttpMessageStreamBuilder.cs
create mode 100644 foreign/csharp/Iggy_SDK/Factory/IggyClientFactory.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Factory/MessageStreamFactory.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Factory/TcpMessageStreamBuilder.cs
delete mode 100644 foreign/csharp/Iggy_SDK/MessagesDispatcher/HttpMessageInvoker.cs
delete mode 100644 foreign/csharp/Iggy_SDK/MessagesDispatcher/IMessageInvoker.cs
delete mode 100644 foreign/csharp/Iggy_SDK/MessagesDispatcher/MessageSenderDispatcher.cs
delete mode 100644 foreign/csharp/Iggy_SDK/MessagesDispatcher/TcpMessageInvoker.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/BackgroundMessageProcessor.Logging.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/BackgroundMessageProcessor.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/ISerializer.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisher.Logging.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisher.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilder.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilderOfT.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisherConfig.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/MessageBatchFailedEventArgs.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/PublisherErrorEventArgs.cs
delete mode 100644 foreign/csharp/Iggy_SDK_Tests/ContractTests/TcpContract.cs
create mode 100644 foreign/java/external-processors/iggy-connector-flink/docker-compose.yml
create mode 100644 foreign/java/external-processors/iggy-connector-flink/docker/Dockerfile.flink2_10-java21
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/README.md
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/build.gradle.kts
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/config/IggyConnectionConfig.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/config/OffsetConfig.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/error/ConnectorException.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggyCommittable.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySink.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkBuilder.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkWriter.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggyPartitionSplitReader.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySource.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceBuilder.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorState.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorStateSerializer.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceReader.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplit.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitEnumerator.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitSerializer.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/partition/PartitionInfo.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/DeserializationSchema.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonDeserializationSchema.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonSerializationSchema.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/RecordMetadata.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/SerializationSchema.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/StringDeserializationSchema.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/TypeDescriptor.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/config/IggyConnectionConfigTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/config/OffsetConfigTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/error/ConnectorExceptionTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/partition/PartitionInfoTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/serialization/DeserializationSchemaTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/serialization/RecordMetadataTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/serialization/SerializationSchemaTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/serialization/TypeDescriptorTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/build.gradle.kts
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/data-population-explanation.md
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/deploy-and-run-word-count-job.md
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/MultiStreamJoinJob.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/SendTestMessages.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/StreamTransformJob.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/WordCountJob.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/Alert.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/EnrichedActivity.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/SensorReading.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserActivity.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserProfile.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/WordCount.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessagePollTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessageSendTest.java
create mode 100644 foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/SendTextDataTest.java
copy foreign/java/java-sdk/src/{main/java/org/apache/iggy/Iggy.java => test/java/org/apache/iggy/TestConstants.java} (73%)
copy foreign/node/src/e2e/{tcp.token.e2e.ts => tcp.cluster.e2e.ts} (60%)
create mode 100644 foreign/node/src/wire/cluster/cluster.type.ts
create mode 100644 foreign/node/src/wire/cluster/cluster.utils.ts
copy foreign/node/src/wire/{system/ping.command.ts => cluster/get-cluster-metadata.command.ts} (71%)
copy foreign/node/src/{stream => wire/cluster}/index.ts (90%)