This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch migrate-cpp-client
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 387c907d Two more files missing license headers
add 50fd0af0 chore(repo): update Rust edition to 2024 across multiple
Cargo.toml files (#1772)
new 7bed2ec4 Merge branch 'master' into migrate-cpp-client
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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(-)
