This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/npm_and_yarn/web/vite-7.1.11
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 405c17ab3 chore(deps-dev): bump vite from 7.1.7 to 7.1.11 in /web
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 7b6efe705 chore(deps-dev): bump vite from 7.1.7 to 7.1.11 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 (405c17ab3)
\
N -- N -- N refs/heads/dependabot/npm_and_yarn/web/vite-7.1.11
(7b6efe705)
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 | 4 +
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 | 12 +-
web/package.json | 4 +-
940 files changed, 46244 insertions(+), 26507 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%)
