This is an automated email from the ASF dual-hosted git repository. hgruszecki pushed a commit to branch migrate-cpp-client in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 7bed2ec4d9c19eb5514834fca3bdc73c3114ddda Merge: 387c907d 50fd0af0 Author: Hubert Gruszecki <[email protected]> AuthorDate: Sat May 10 23:49:31 2025 +0200 Merge branch 'master' into migrate-cpp-client core/bench/Cargo.toml | 2 +- core/bench/dashboard/frontend/Cargo.toml | 2 +- .../frontend/src/components/app_content.rs | 8 +- .../frontend/src/components/chart/plot_trend.rs | 2 +- .../frontend/src/components/chart/single_chart.rs | 2 +- .../frontend/src/components/chart/trend_chart.rs | 2 +- .../frontend/src/components/layout/main_content.rs | 2 +- .../frontend/src/components/layout/sidebar.rs | 4 +- .../frontend/src/components/layout/topbar.rs | 2 +- .../src/components/selectors/benchmark_selector.rs | 2 +- .../src/components/selectors/hardware_selector.rs | 2 +- .../src/components/selectors/view_mode_selector.rs | 2 +- core/bench/dashboard/server/Cargo.toml | 2 +- core/bench/dashboard/server/Dockerfile | 2 +- core/bench/dashboard/server/src/args.rs | 2 +- core/bench/dashboard/server/src/github/client.rs | 4 +- core/bench/dashboard/server/src/handlers.rs | 4 +- core/bench/dashboard/server/src/main.rs | 5 +- core/bench/dashboard/shared/Cargo.toml | 2 +- core/bench/report/Cargo.toml | 2 +- core/bench/report/src/plotting/chart.rs | 2 +- core/bench/runner/Cargo.toml | 2 +- .../bench/runner/src/app/local_benchmark_runner.rs | 2 +- core/bench/runner/src/main.rs | 2 +- core/bench/src/actors/consumer.rs | 9 +- core/bench/src/actors/producer.rs | 2 +- core/bench/src/actors/producing_consumer.rs | 29 +++--- core/bench/src/analytics/metrics/group.rs | 2 +- core/bench/src/analytics/metrics/individual.rs | 2 +- .../time_series/calculators/throughput.rs | 2 +- .../src/args/kinds/balanced/consumer_group.rs | 2 +- core/bench/src/args/kinds/balanced/producer.rs | 2 +- .../kinds/balanced/producer_and_consumer_group.rs | 2 +- .../args/kinds/end_to_end/producing_consumer.rs | 2 +- .../kinds/end_to_end/producing_consumer_group.rs | 2 +- core/bench/src/args/kinds/pinned/consumer.rs | 2 +- core/bench/src/args/kinds/pinned/producer.rs | 2 +- .../src/args/kinds/pinned/producer_and_consumer.rs | 2 +- .../src/benchmarks/balanced_consumer_group.rs | 4 +- core/bench/src/benchmarks/balanced_producer.rs | 4 +- .../balanced_producer_and_consumer_group.rs | 4 +- core/bench/src/benchmarks/benchmark.rs | 2 +- core/bench/src/benchmarks/common.rs | 6 +- .../benchmarks/end_to_end_producing_consumer.rs | 4 +- core/bench/src/benchmarks/pinned_producer.rs | 4 +- .../src/benchmarks/pinned_producer_and_consumer.rs | 4 +- core/bench/src/main.rs | 2 +- core/bench/src/runner.rs | 2 +- core/bench/src/utils/batch_generator.rs | 8 +- core/bench/src/utils/finish_condition.rs | 2 +- core/bench/src/utils/rate_limiter.rs | 2 +- core/bench/src/utils/server_starter.rs | 8 +- core/binary_protocol/Cargo.toml | 2 +- .../src/cli/binary_client/get_client.rs | 6 +- .../src/cli/binary_client/get_clients.rs | 4 +- .../create_consumer_group.rs | 6 +- .../delete_consumer_group.rs | 6 +- .../binary_consumer_groups/get_consumer_group.rs | 8 +- .../binary_consumer_groups/get_consumer_groups.rs | 6 +- .../binary_consumer_offsets/get_consumer_offset.rs | 4 +- .../binary_consumer_offsets/set_consumer_offset.rs | 6 +- .../src/cli/binary_context/common.rs | 2 +- .../src/cli/binary_context/get_contexts.rs | 4 +- .../src/cli/binary_context/use_context.rs | 4 +- .../src/cli/binary_message/flush_messages.rs | 4 +- .../src/cli/binary_message/poll_messages.rs | 4 +- .../src/cli/binary_message/send_messages.rs | 4 +- .../src/cli/binary_partitions/create_partitions.rs | 6 +- .../src/cli/binary_partitions/delete_partitions.rs | 6 +- .../create_personal_access_token.rs | 6 +- .../delete_personal_access_tokens.rs | 4 +- .../get_personal_access_tokens.rs | 4 +- .../src/cli/binary_segments/delete_segments.rs | 6 +- .../src/cli/binary_streams/create_stream.rs | 4 +- .../src/cli/binary_streams/delete_stream.rs | 6 +- .../src/cli/binary_streams/get_stream.rs | 6 +- .../src/cli/binary_streams/get_streams.rs | 4 +- .../src/cli/binary_streams/purge_stream.rs | 6 +- .../src/cli/binary_streams/update_stream.rs | 6 +- .../binary_protocol/src/cli/binary_system/login.rs | 4 +- .../src/cli/binary_system/logout.rs | 4 +- core/binary_protocol/src/cli/binary_system/me.rs | 4 +- core/binary_protocol/src/cli/binary_system/ping.rs | 6 +- .../src/cli/binary_system/snapshot.rs | 4 +- .../binary_protocol/src/cli/binary_system/stats.rs | 4 +- .../src/cli/binary_topics/create_topic.rs | 4 +- .../src/cli/binary_topics/delete_topic.rs | 6 +- .../src/cli/binary_topics/get_topic.rs | 6 +- .../src/cli/binary_topics/get_topics.rs | 4 +- .../src/cli/binary_topics/purge_topic.rs | 6 +- .../src/cli/binary_topics/update_topic.rs | 4 +- .../src/cli/binary_users/change_password.rs | 6 +- .../src/cli/binary_users/create_user.rs | 6 +- .../src/cli/binary_users/delete_user.rs | 6 +- .../src/cli/binary_users/get_user.rs | 6 +- .../src/cli/binary_users/get_users.rs | 4 +- .../src/cli/binary_users/update_permissions.rs | 4 +- .../src/cli/binary_users/update_user.rs | 6 +- .../src/client/binary_clients/binary_client.rs | 2 +- .../src/client/binary_consumer_offsets/mod.rs | 2 +- .../src/client/binary_messages/mod.rs | 4 +- .../src/client/binary_segments/mod.rs | 2 +- core/cli/Cargo.toml | 2 +- core/cli/src/args/mod.rs | 2 +- core/cli/src/args/user.rs | 2 +- core/cli/src/credentials.rs | 10 +- core/cli/src/main.rs | 5 +- core/common/Cargo.toml | 2 +- .../consumer_groups/create_consumer_group.rs | 4 +- .../consumer_groups/delete_consumer_group.rs | 2 +- .../commands/consumer_groups/get_consumer_group.rs | 2 +- .../consumer_groups/get_consumer_groups.rs | 2 +- .../consumer_groups/join_consumer_group.rs | 2 +- .../consumer_groups/leave_consumer_group.rs | 2 +- .../consumer_offsets/delete_consumer_offset.rs | 2 +- .../consumer_offsets/get_consumer_offset.rs | 2 +- .../consumer_offsets/store_consumer_offset.rs | 2 +- .../src/commands/messages/flush_unsaved_buffer.rs | 9 +- core/common/src/commands/messages/poll_messages.rs | 6 +- core/common/src/commands/messages/send_messages.rs | 8 +- .../src/commands/partitions/create_partitions.rs | 4 +- .../src/commands/partitions/delete_partitions.rs | 2 +- .../create_personal_access_token.rs | 6 +- .../delete_personal_access_token.rs | 4 +- .../get_personal_access_tokens.rs | 2 +- .../login_with_personal_access_token.rs | 4 +- .../src/commands/segments/delete_segments.rs | 2 +- core/common/src/commands/streams/create_stream.rs | 4 +- core/common/src/commands/streams/delete_stream.rs | 2 +- core/common/src/commands/streams/get_stream.rs | 2 +- core/common/src/commands/streams/get_streams.rs | 2 +- core/common/src/commands/streams/purge_stream.rs | 2 +- core/common/src/commands/streams/update_stream.rs | 2 +- core/common/src/commands/system/get_client.rs | 2 +- core/common/src/commands/system/get_clients.rs | 2 +- core/common/src/commands/system/get_me.rs | 2 +- core/common/src/commands/system/get_snapshot.rs | 2 +- core/common/src/commands/system/get_stats.rs | 2 +- core/common/src/commands/system/ping.rs | 2 +- core/common/src/commands/topics/create_topic.rs | 8 +- core/common/src/commands/topics/delete_topic.rs | 2 +- core/common/src/commands/topics/get_topic.rs | 2 +- core/common/src/commands/topics/get_topics.rs | 2 +- core/common/src/commands/topics/purge_topic.rs | 2 +- core/common/src/commands/topics/update_topic.rs | 6 +- core/common/src/commands/users/change_password.rs | 4 +- core/common/src/commands/users/create_user.rs | 4 +- core/common/src/commands/users/delete_user.rs | 2 +- core/common/src/commands/users/get_user.rs | 2 +- core/common/src/commands/users/get_users.rs | 2 +- core/common/src/commands/users/login_user.rs | 2 +- core/common/src/commands/users/logout_user.rs | 2 +- .../src/commands/users/update_permissions.rs | 2 +- core/common/src/commands/users/update_user.rs | 2 +- core/common/src/error/iggy_error.rs | 30 +++--- core/common/src/traits/partitioner.rs | 2 +- core/common/src/types/command/mod.rs | 2 +- .../src/types/compression/compression_algorithm.rs | 2 +- core/common/src/types/consumer/consumer_kind.rs | 4 +- core/common/src/types/consumer/mod.rs | 4 +- core/common/src/types/identifier/mod.rs | 4 +- core/common/src/types/message/iggy_message.rs | 10 +- core/common/src/types/message/indexes.rs | 2 +- core/common/src/types/message/message_header.rs | 2 +- .../src/types/message/message_header_view.rs | 10 +- core/common/src/types/message/message_view.rs | 6 +- core/common/src/types/message/messages_batch.rs | 4 +- core/common/src/types/message/mod.rs | 10 +- core/common/src/types/message/partitioning.rs | 2 +- core/common/src/types/message/polled_messages.rs | 2 +- core/common/src/types/message/polling_strategy.rs | 4 +- core/common/src/types/message/user_headers.rs | 2 +- .../src/types/permissions/permissions_global.rs | 4 +- core/common/src/types/topic/mod.rs | 4 +- core/common/src/types/user/user_info.rs | 2 +- core/common/src/utils/crypto.rs | 2 +- core/common/src/utils/duration.rs | 2 +- core/common/src/utils/expiry.rs | 4 +- core/common/src/utils/text.rs | 2 +- core/common/src/utils/timestamp.rs | 2 +- core/common/src/utils/topic_size.rs | 2 +- core/examples/Cargo.toml | 2 +- core/examples/src/multi-tenant/consumer/main.rs | 18 +++- core/examples/src/multi-tenant/producer/main.rs | 7 +- core/examples/src/new-sdk/consumer/main.rs | 14 ++- core/examples/src/shared/messages_generator.rs | 2 +- core/examples/src/shared/system.rs | 10 +- core/integration/Cargo.toml | 2 +- core/integration/src/test_server.rs | 4 +- core/integration/tests/archiver/s3.rs | 2 +- core/integration/tests/bench/mod.rs | 2 +- .../tests/cli/client/test_client_help_command.rs | 2 +- .../tests/cli/client/test_client_list_command.rs | 2 +- core/integration/tests/cli/common/mod.rs | 4 +- .../test_consumer_group_create_command.rs | 17 +++- .../test_consumer_group_delete_command.rs | 10 +- .../test_consumer_group_get_command.rs | 4 +- .../test_consumer_group_help_command.rs | 2 +- .../test_consumer_group_list_command.rs | 4 +- .../test_consumer_offset_get_command.rs | 9 +- .../test_consumer_offset_set_command.rs | 4 +- core/integration/tests/cli/context/common.rs | 2 +- .../tests/cli/context/test_context_list_command.rs | 2 +- .../tests/cli/context/test_context_use_command.rs | 2 +- .../tests/cli/general/test_help_command.rs | 2 +- .../tests/cli/general/test_overview_command.rs | 2 +- .../cli/message/test_message_flush_command.rs | 8 +- .../tests/cli/message/test_message_help_command.rs | 2 +- .../tests/cli/message/test_message_poll_command.rs | 10 +- .../message/test_message_poll_to_file_command.rs | 6 +- .../tests/cli/message/test_message_send_command.rs | 10 +- .../cli/partition/test_partition_create_command.rs | 10 +- .../cli/partition/test_partition_delete_command.rs | 10 +- .../cli/partition/test_partition_help_command.rs | 2 +- .../test_pat_create_command.rs | 10 +- .../test_pat_delete_command.rs | 6 +- .../personal_access_token/test_pat_help_command.rs | 2 +- .../personal_access_token/test_pat_list_command.rs | 2 +- .../tests/cli/stream/test_stream_delete_command.rs | 2 +- .../tests/cli/stream/test_stream_get_command.rs | 2 +- .../tests/cli/stream/test_stream_help_command.rs | 2 +- .../tests/cli/stream/test_stream_list_command.rs | 2 +- .../tests/cli/stream/test_stream_purge_command.rs | 2 +- .../tests/cli/stream/test_stream_update_command.rs | 12 ++- .../tests/cli/system/test_ping_command.rs | 2 +- .../tests/cli/system/test_stats_command.rs | 2 +- .../tests/cli/topic/test_topic_create_command.rs | 2 +- .../tests/cli/topic/test_topic_delete_command.rs | 10 +- .../tests/cli/topic/test_topic_get_command.rs | 4 +- .../tests/cli/topic/test_topic_help_command.rs | 2 +- .../tests/cli/topic/test_topic_list_command.rs | 4 +- .../tests/cli/topic/test_topic_purge_command.rs | 10 +- .../tests/cli/topic/test_topic_update_command.rs | 10 +- .../tests/cli/user/test_login_options.rs | 2 +- .../tests/cli/user/test_user_create_command.rs | 2 +- .../tests/cli/user/test_user_delete_command.rs | 2 +- .../tests/cli/user/test_user_get_command.rs | 2 +- .../tests/cli/user/test_user_help_command.rs | 2 +- .../tests/cli/user/test_user_list_command.rs | 2 +- .../tests/cli/user/test_user_name_command.rs | 8 +- .../tests/cli/user/test_user_password_command.rs | 5 +- .../cli/user/test_user_permissions_command.rs | 5 +- .../tests/cli/user/test_user_status_command.rs | 15 ++- core/integration/tests/config_provider/mod.rs | 46 +++++---- .../data_integrity/verify_after_server_restart.rs | 2 +- core/integration/tests/examples/mod.rs | 2 +- core/integration/tests/mod.rs | 2 +- .../scenarios/consumer_group_join_scenario.rs | 7 +- ...h_multiple_clients_polling_messages_scenario.rs | 10 +- ...with_single_client_polling_messages_scenario.rs | 10 +- .../server/scenarios/create_message_payload.rs | 14 +-- .../server/scenarios/message_headers_scenario.rs | 18 ++-- .../server/scenarios/message_size_scenario.rs | 10 +- core/integration/tests/server/scenarios/mod.rs | 2 +- .../scenarios/stream_size_validation_scenario.rs | 4 +- .../tests/server/scenarios/system_scenario.rs | 8 +- .../tests/server/scenarios/user_scenario.rs | 6 +- core/integration/tests/state/file.rs | 2 +- core/integration/tests/state/system.rs | 2 +- core/integration/tests/streaming/get_by_offset.rs | 8 +- .../tests/streaming/get_by_timestamp.rs | 8 +- core/integration/tests/streaming/messages.rs | 2 +- core/integration/tests/streaming/partition.rs | 2 +- core/integration/tests/streaming/segment.rs | 24 +++-- core/integration/tests/streaming/topic.rs | 2 +- core/integration/tests/streaming/topic_messages.rs | 2 +- core/sdk/Cargo.toml | 2 +- core/sdk/src/clients/consumer.rs | 85 +++++++++++----- core/sdk/src/clients/producer.rs | 8 +- core/sdk/src/http/binary_consumer_groups.rs | 2 +- core/sdk/src/http/binary_personal_access_tokens.rs | 4 +- core/sdk/src/http/binary_system.rs | 2 +- core/sdk/src/http/http_client.rs | 6 +- core/sdk/src/prelude.rs | 31 +++--- core/sdk/src/quic/quick_client.rs | 12 ++- .../src/stream_builder/build/build_stream_topic.rs | 6 +- core/sdk/src/stream_builder/iggy_stream.rs | 2 +- .../sdk/src/stream_builder/iggy_stream_consumer.rs | 2 +- .../sdk/src/stream_builder/iggy_stream_producer.rs | 2 +- core/sdk/src/tcp/tcp_client.rs | 12 ++- core/sdk/src/tcp/tcp_connection_stream.rs | 2 +- core/server/Cargo.toml | 2 +- .../create_consumer_group_handler.rs | 2 +- .../delete_consumer_group_handler.rs | 2 +- .../consumer_groups/get_consumer_group_handler.rs | 2 +- .../consumer_groups/get_consumer_groups_handler.rs | 2 +- .../consumer_groups/join_consumer_group_handler.rs | 2 +- .../leave_consumer_group_handler.rs | 2 +- .../delete_consumer_offset_handler.rs | 2 +- .../get_consumer_offset_handler.rs | 2 +- .../store_consumer_offset_handler.rs | 2 +- .../handlers/messages/send_messages_handler.rs | 2 +- .../partitions/create_partitions_handler.rs | 2 +- .../partitions/delete_partitions_handler.rs | 2 +- .../create_personal_access_token_handler.rs | 2 +- .../delete_personal_access_token_handler.rs | 2 +- .../get_personal_access_tokens_handler.rs | 2 +- .../login_with_personal_access_token_handler.rs | 2 +- .../handlers/segments/delete_segments_handler.rs | 2 +- .../handlers/streams/create_stream_handler.rs | 2 +- .../handlers/streams/delete_stream_handler.rs | 2 +- .../binary/handlers/streams/get_stream_handler.rs | 2 +- .../binary/handlers/streams/get_streams_handler.rs | 2 +- .../handlers/streams/purge_stream_handler.rs | 2 +- .../handlers/streams/update_stream_handler.rs | 2 +- .../binary/handlers/system/get_client_handler.rs | 2 +- .../binary/handlers/system/get_clients_handler.rs | 2 +- .../src/binary/handlers/system/get_me_handler.rs | 2 +- .../src/binary/handlers/system/get_snapshot.rs | 2 +- .../binary/handlers/system/get_stats_handler.rs | 2 +- .../src/binary/handlers/system/ping_handler.rs | 4 +- .../binary/handlers/topics/create_topic_handler.rs | 2 +- .../binary/handlers/topics/delete_topic_handler.rs | 2 +- .../binary/handlers/topics/get_topic_handler.rs | 2 +- .../binary/handlers/topics/get_topics_handler.rs | 2 +- .../binary/handlers/topics/purge_topic_handler.rs | 2 +- .../binary/handlers/topics/update_topic_handler.rs | 2 +- .../handlers/users/change_password_handler.rs | 2 +- .../binary/handlers/users/create_user_handler.rs | 2 +- .../binary/handlers/users/delete_user_handler.rs | 2 +- .../src/binary/handlers/users/get_user_handler.rs | 2 +- .../src/binary/handlers/users/get_users_handler.rs | 2 +- .../binary/handlers/users/login_user_handler.rs | 2 +- .../binary/handlers/users/logout_user_handler.rs | 2 +- .../handlers/users/update_permissions_handler.rs | 2 +- .../binary/handlers/users/update_user_handler.rs | 2 +- core/server/src/build.rs | 4 +- .../commands/clean_personal_access_tokens.rs | 4 +- .../src/channels/commands/maintain_messages.rs | 22 +++-- core/server/src/channels/commands/print_sysinfo.rs | 26 ++--- core/server/src/channels/commands/save_messages.rs | 4 +- .../src/channels/commands/verify_heartbeats.rs | 8 +- .../src/compat/index_rebuilding/index_rebuilder.rs | 2 +- core/server/src/configs/config_provider.rs | 8 +- core/server/src/configs/displays.rs | 108 +++++++++++++-------- core/server/src/configs/http.rs | 2 +- core/server/src/configs/quic.rs | 2 +- core/server/src/configs/server.rs | 4 +- core/server/src/configs/system.rs | 2 +- core/server/src/configs/tcp.rs | 2 +- core/server/src/configs/validators.rs | 6 +- core/server/src/http/consumer_groups.rs | 6 +- core/server/src/http/consumer_offsets.rs | 8 +- core/server/src/http/diagnostics.rs | 4 +- core/server/src/http/error.rs | 2 +- core/server/src/http/http_server.rs | 2 +- core/server/src/http/jwt/jwt_manager.rs | 8 +- core/server/src/http/jwt/storage.rs | 2 +- core/server/src/http/mapper.rs | 4 +- core/server/src/http/messages.rs | 2 +- core/server/src/http/partitions.rs | 6 +- core/server/src/http/personal_access_tokens.rs | 6 +- core/server/src/http/streams.rs | 6 +- core/server/src/http/system.rs | 8 +- core/server/src/http/topics.rs | 6 +- core/server/src/http/users.rs | 2 +- core/server/src/log/logger.rs | 18 ++-- core/server/src/main.rs | 2 +- core/server/src/quic/quic_server.rs | 2 +- core/server/src/state/command.rs | 8 +- core/server/src/state/entry.rs | 2 +- core/server/src/state/file.rs | 4 +- core/server/src/state/models.rs | 8 +- core/server/src/state/system.rs | 14 ++- .../server/src/streaming/clients/client_manager.rs | 4 +- .../src/streaming/partitions/consumer_offsets.rs | 32 +++--- core/server/src/streaming/partitions/messages.rs | 44 ++++----- core/server/src/streaming/partitions/partition.rs | 4 +- .../server/src/streaming/partitions/persistence.rs | 2 +- core/server/src/streaming/partitions/segments.rs | 2 +- core/server/src/streaming/partitions/storage.rs | 72 +++++++++++--- core/server/src/streaming/persistence/task.rs | 2 +- .../personal_access_token.rs | 2 +- .../src/streaming/segments/indexes/index_reader.rs | 24 ++--- .../src/streaming/segments/indexes/index_writer.rs | 4 +- .../src/streaming/segments/indexes/indexes_mut.rs | 2 +- .../streaming/segments/messages/messages_reader.rs | 20 ++-- .../streaming/segments/messages/messages_writer.rs | 4 +- .../streaming/segments/messages/persister_task.rs | 10 +- .../src/streaming/segments/messages_accumulator.rs | 11 +-- .../src/streaming/segments/reading_messages.rs | 5 +- core/server/src/streaming/segments/segment.rs | 30 +++--- .../streaming/segments/types/message_view_mut.rs | 2 +- .../streaming/segments/types/messages_batch_mut.rs | 31 +++--- .../src/streaming/segments/writing_messages.rs | 14 ++- core/server/src/streaming/storage.rs | 2 +- core/server/src/streaming/streams/persistence.rs | 2 +- core/server/src/streaming/streams/storage.rs | 26 +++-- core/server/src/streaming/streams/stream.rs | 2 +- core/server/src/streaming/streams/topics.rs | 4 +- core/server/src/streaming/systems/clients.rs | 6 +- .../src/streaming/systems/consumer_groups.rs | 4 +- .../src/streaming/systems/consumer_offsets.rs | 2 +- core/server/src/streaming/systems/info.rs | 8 +- core/server/src/streaming/systems/messages.rs | 11 ++- core/server/src/streaming/systems/partitions.rs | 2 +- .../streaming/systems/personal_access_tokens.rs | 6 +- core/server/src/streaming/systems/segments.rs | 4 +- core/server/src/streaming/systems/stats.rs | 2 +- core/server/src/streaming/systems/storage.rs | 4 +- core/server/src/streaming/systems/streams.rs | 14 ++- core/server/src/streaming/systems/system.rs | 2 +- core/server/src/streaming/systems/topics.rs | 2 +- core/server/src/streaming/systems/users.rs | 14 +-- core/server/src/streaming/topics/consumer_group.rs | 20 ++-- .../server/src/streaming/topics/consumer_groups.rs | 6 +- .../src/streaming/topics/consumer_offsets.rs | 44 ++++++--- core/server/src/streaming/topics/messages.rs | 16 ++- core/server/src/streaming/topics/partitions.rs | 2 +- core/server/src/streaming/topics/persistence.rs | 4 +- core/server/src/streaming/topics/storage.rs | 29 ++++-- core/server/src/streaming/topics/topic.rs | 2 +- core/server/src/streaming/users/user.rs | 2 +- core/server/src/streaming/utils/file.rs | 2 +- core/server/src/streaming/utils/memory_pool.rs | 5 +- core/server/src/streaming/utils/mod.rs | 2 +- core/server/src/streaming/utils/pooled_buffer.rs | 2 +- core/server/src/tcp/tcp_listener.rs | 8 +- core/server/src/tcp/tcp_tls_listener.rs | 8 +- core/tools/Cargo.toml | 2 +- 420 files changed, 1358 insertions(+), 1058 deletions(-)
