You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2025/05/10 11:28:33 UTC
(iggy) branch validation-impr updated (f41d6815 -> 3e226ca1)
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch validation-impr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from f41d6815 Merge branch 'master' into validation-impr
add eec28c5e refactor(sdk): split Rust SDK into smaller packages (#1755)
add 5b891879 chore(server): print more detailed error log when connection fails (#1764)
add 24646055 chore(repo): refactor Cargo.toml files to use workspace dependencies (#1763)
add 3e226ca1 Merge branch 'master' into validation-impr
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-check-common.yml | 79 +--
= | 0
Cargo.lock | 741 ++++++++++---------
Cargo.toml | 119 ++++
core/bench/Cargo.toml | 40 +-
core/bench/report/Cargo.toml | 22 +-
core/bench/src/analytics/metrics/individual.rs | 2 +-
core/bench/src/analytics/report_builder.rs | 5 +-
core/bench/src/analytics/time_series/calculator.rs | 2 +-
.../analytics/time_series/calculators/latency.rs | 2 +-
.../src/analytics/time_series/calculators/mod.rs | 2 +-
.../time_series/calculators/throughput.rs | 2 +-
core/bench/src/args/common.rs | 4 +-
core/bench/src/args/kind.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 +-
core/bench/src/args/props.rs | 2 +-
.../src/benchmarks/balanced_consumer_group.rs | 18 +
core/bench/src/benchmarks/balanced_producer.rs | 18 +
.../balanced_producer_and_consumer_group.rs | 18 +
core/bench/src/benchmarks/benchmark.rs | 10 +-
core/bench/src/benchmarks/common.rs | 18 +
.../benchmarks/end_to_end_producing_consumer.rs | 18 +
.../end_to_end_producing_consumer_group.rs | 18 +
core/bench/src/benchmarks/pinned_consumer.rs | 20 +-
core/bench/src/benchmarks/pinned_producer.rs | 22 +-
core/bench/src/main.rs | 2 +-
core/bench/src/plot.rs | 2 +-
core/bench/src/runner.rs | 2 +-
core/bench/src/utils/rate_limiter.rs | 2 +-
core/binary_protocol/Cargo.toml | 46 ++
.../src/cli/binary_client}/get_client.rs | 6 +-
.../src/cli/binary_client}/get_clients.rs | 6 +-
.../src/cli/binary_client}/mod.rs | 0
.../create_consumer_group.rs | 8 +-
.../delete_consumer_group.rs | 8 +-
.../binary_consumer_groups}/get_consumer_group.rs | 8 +-
.../binary_consumer_groups}/get_consumer_groups.rs | 8 +-
.../src/cli/binary_consumer_groups}/mod.rs | 0
.../get_consumer_offset.rs | 9 +-
.../src/cli/binary_consumer_offsets}/mod.rs | 0
.../set_consumer_offset.rs | 10 +-
.../src/cli/binary_context}/common.rs | 2 +-
.../src/cli/binary_context}/get_contexts.rs | 4 +-
.../src/cli/binary_context}/mod.rs | 0
.../src/cli/binary_context}/use_context.rs | 4 +-
.../src/cli/binary_message}/flush_messages.rs | 6 +-
.../src/cli/binary_message}/mod.rs | 0
.../src/cli/binary_message}/poll_messages.rs | 16 +-
.../src/cli/binary_message}/send_messages.rs | 12 +-
.../cli/binary_partitions}/create_partitions.rs | 8 +-
.../cli/binary_partitions}/delete_partitions.rs | 8 +-
.../src/cli/binary_partitions}/mod.rs | 0
.../create_personal_access_token.rs | 8 +-
.../delete_personal_access_tokens.rs | 6 +-
.../get_personal_access_tokens.rs | 6 +-
.../src/cli/binary_personal_access_tokens}/mod.rs | 0
.../src/cli/binary_segments}/delete_segments.rs | 8 +-
.../src/cli/binary_segments}/mod.rs | 0
.../src/cli/binary_streams}/create_stream.rs | 6 +-
.../src/cli/binary_streams}/delete_stream.rs | 8 +-
.../src/cli/binary_streams}/get_stream.rs | 8 +-
.../src/cli/binary_streams}/get_streams.rs | 6 +-
.../src/cli/binary_streams}/mod.rs | 0
.../src/cli/binary_streams}/purge_stream.rs | 8 +-
.../src/cli/binary_streams}/update_stream.rs | 8 +-
.../src/cli/binary_system}/login.rs | 8 +-
.../src/cli/binary_system}/logout.rs | 6 +-
.../src/cli/binary_system}/me.rs | 6 +-
.../src/cli/binary_system}/mod.rs | 0
.../src/cli/binary_system}/ping.rs | 6 +-
.../src/cli/binary_system}/session.rs | 0
.../src/cli/binary_system}/snapshot.rs | 8 +-
.../src/cli/binary_system}/stats.rs | 6 +-
.../src/cli/binary_topics}/create_topic.rs | 13 +-
.../src/cli/binary_topics}/delete_topic.rs | 8 +-
.../src/cli/binary_topics}/get_topic.rs | 10 +-
.../src/cli/binary_topics}/get_topics.rs | 9 +-
.../src/cli/binary_topics}/mod.rs | 0
.../src/cli/binary_topics}/purge_topic.rs | 8 +-
.../src/cli/binary_topics}/update_topic.rs | 13 +-
.../src/cli/binary_users}/change_password.rs | 6 +-
.../src/cli/binary_users}/create_user.rs | 10 +-
.../src/cli/binary_users}/delete_user.rs | 8 +-
.../src/cli/binary_users/get_user.rs | 95 +++
.../src/cli/binary_users}/get_users.rs | 6 +-
.../src/cli/binary_users}/mod.rs | 0
.../src/cli/binary_users}/update_permissions.rs | 9 +-
.../src/cli/binary_users}/update_user.rs | 10 +-
.../src => binary_protocol/src/cli}/cli_command.rs | 2 +-
core/{sdk => binary_protocol}/src/cli/mod.rs | 25 +-
.../src/cli/utils/login_session_expiry.rs | 2 +-
core/{sdk => binary_protocol}/src/cli/utils/mod.rs | 0
.../src/client/binary_clients}/binary_client.rs | 4 +-
.../src/client/binary_clients/client.rs | 59 ++
.../client/binary_clients/consumer_group_client.rs | 79 +++
.../binary_clients/consumer_offset_client.rs | 56 ++
.../src/client/binary_clients/message_client.rs | 61 ++
.../src/client/binary_clients/mod.rs | 42 ++
.../src/client/binary_clients/partition_client.rs} | 48 +-
.../binary_clients/personal_access_token_client.rs | 43 ++
.../src/client/binary_clients/segment_client.rs} | 32 +-
.../src/client/binary_clients/stream_client.rs | 53 ++
.../src/client/binary_clients/system_client.rs | 55 ++
.../src/client/binary_clients/topic_client.rs | 84 +++
.../src/client/binary_clients/user_client.rs | 79 +++
.../src/client/binary_consumer_groups/mod.rs} | 23 +-
.../src/client/binary_consumer_offsets/mod.rs} | 19 +-
.../src/client/binary_messages/mod.rs} | 22 +-
.../src/client/binary_partitions/mod.rs} | 13 +-
.../client/binary_personal_access_tokens/mod.rs} | 22 +-
.../src/client/binary_segments/mod.rs} | 12 +-
.../src/client/binary_streams/mod.rs} | 22 +-
.../src/client/binary_system/mod.rs} | 28 +-
.../src/client/binary_topics/mod.rs} | 27 +-
.../src/client/binary_transport/mod.rs} | 28 +-
.../src/client/binary_users/mod.rs} | 35 +-
core/binary_protocol/src/client/mod.rs | 12 +
.../src/args/mod.rs => binary_protocol/src/lib.rs} | 14 +-
.../src/utils/auth.rs} | 19 +-
.../binary => binary_protocol/src/utils}/mapper.rs | 25 +-
.../text => binary_protocol/src/utils}/mod.rs | 4 +-
core/cli/Cargo.toml | 35 +-
core/cli/src/args/common.rs | 16 +-
core/cli/src/args/consumer_group.rs | 2 +-
core/cli/src/args/consumer_offset.rs | 2 +-
core/cli/src/args/mod.rs | 4 +-
core/cli/src/args/partition.rs | 2 +-
core/cli/src/args/permissions/global.rs | 2 +-
core/cli/src/args/permissions/mod.rs | 5 +-
core/cli/src/args/permissions/stream.rs | 4 +-
core/cli/src/args/permissions/topic.rs | 2 +-
core/cli/src/args/personal_access_token.rs | 2 +-
core/cli/src/args/segment.rs | 2 +-
core/cli/src/args/stream.rs | 2 +-
core/cli/src/args/system.rs | 4 +-
core/cli/src/args/topic.rs | 8 +-
core/cli/src/args/user.rs | 2 +-
core/cli/src/credentials.rs | 14 +-
core/cli/src/error.rs | 2 +-
core/cli/src/logging.rs | 2 +-
core/cli/src/main.rs | 50 +-
core/common/Cargo.toml | 55 ++
.../consumer_groups/create_consumer_group.rs | 12 +-
.../consumer_groups/delete_consumer_group.rs | 10 +-
.../consumer_groups/get_consumer_group.rs | 10 +-
.../consumer_groups/get_consumer_groups.rs | 10 +-
.../consumer_groups/join_consumer_group.rs | 10 +-
.../consumer_groups/leave_consumer_group.rs | 10 +-
.../src/commands}/consumer_groups/mod.rs | 0
.../consumer_offsets/delete_consumer_offset.rs | 12 +-
.../consumer_offsets/get_consumer_offset.rs | 12 +-
.../src/commands}/consumer_offsets/mod.rs | 0
.../consumer_offsets/store_consumer_offset.rs | 12 +-
.../src/commands}/messages/flush_unsaved_buffer.rs | 11 +-
core/common/src/commands/messages/mod.rs | 3 +
.../src/commands}/messages/poll_messages.rs | 14 +-
.../src/commands}/messages/send_messages.rs | 33 +-
core/common/src/commands/mod.rs | 10 +
.../src/commands}/partitions/create_partitions.rs | 12 +-
.../src/commands}/partitions/delete_partitions.rs | 12 +-
.../src => common/src/commands}/partitions/mod.rs | 0
.../create_personal_access_token.rs | 8 +-
.../delete_personal_access_token.rs | 8 +-
.../get_personal_access_tokens.rs | 6 +-
.../login_with_personal_access_token.rs | 8 +-
.../src/commands}/personal_access_tokens/mod.rs | 0
.../src/commands}/segments/delete_segments.rs | 10 +-
.../src => common/src/commands}/segments/mod.rs | 0
.../src/commands}/streams/create_stream.rs | 8 +-
.../src/commands}/streams/delete_stream.rs | 8 +-
.../src/commands}/streams/get_stream.rs | 8 +-
.../src/commands}/streams/get_streams.rs | 6 +-
.../src => common/src/commands}/streams/mod.rs | 0
.../src/commands}/streams/purge_stream.rs | 8 +-
.../src/commands}/streams/update_stream.rs | 12 +-
.../src/commands}/system/get_client.rs | 6 +-
.../src/commands}/system/get_clients.rs | 6 +-
.../src => common/src/commands}/system/get_me.rs | 6 +-
.../src/commands}/system/get_snapshot.rs | 8 +-
.../src/commands}/system/get_stats.rs | 6 +-
.../{sdk/src => common/src/commands}/system/mod.rs | 0
.../src => common/src/commands}/system/ping.rs | 6 +-
.../src/commands}/topics/create_topic.rs | 14 +-
.../src/commands}/topics/delete_topic.rs | 10 +-
.../src/commands}/topics/get_topic.rs | 10 +-
.../src/commands}/topics/get_topics.rs | 8 +-
.../{sdk/src => common/src/commands}/topics/mod.rs | 0
.../src/commands}/topics/purge_topic.rs | 10 +-
.../src/commands}/topics/update_topic.rs | 14 +-
.../src/commands}/users/change_password.rs | 12 +-
.../src/commands}/users/create_user.rs | 14 +-
.../src => common/src/commands}/users/defaults.rs | 0
.../src/commands}/users/delete_user.rs | 8 +-
.../src => common/src/commands}/users/get_user.rs | 8 +-
.../src => common/src/commands}/users/get_users.rs | 6 +-
.../src/commands}/users/login_user.rs | 8 +-
.../src/commands}/users/logout_user.rs | 6 +-
core/{sdk/src => common/src/commands}/users/mod.rs | 0
.../src/commands}/users/update_permissions.rs | 14 +-
.../src/commands}/users/update_user.rs | 14 +-
core/{sdk/src => common/src/error}/client_error.rs | 2 +-
.../error.rs => common/src/error/iggy_error.rs} | 3 +-
core/common/src/error/mod.rs | 5 +
core/common/src/lib.rs | 71 ++
.../{sdk => common}/src/locking/fast_async_lock.rs | 0
core/{sdk => common}/src/locking/mod.rs | 0
core/{sdk => common}/src/locking/tokio_lock.rs | 0
.../src/traits}/bytes_serializable.rs | 2 +-
core/common/src/traits/mod.rs | 4 +
core/{sdk/src => common/src/traits}/partitioner.rs | 4 +-
.../src/utils => common/src/traits}/sizeable.rs | 2 +-
core/{sdk/src => common/src/traits}/validatable.rs | 0
.../src/args.rs => common/src/types/args/mod.rs} | 2 +-
.../src/types/client}/client_info.rs | 0
core/common/src/types/client/mod.rs | 1 +
.../src/types/client_state/mod.rs} | 23 +-
.../command.rs => common/src/types/command/mod.rs} | 4 +-
.../types}/compression/compression_algorithm.rs | 0
.../src => common/src/types}/compression/mod.rs | 0
.../types/configuration/auth_config/auto_login.rs | 7 +
.../configuration/auth_config/connection_string.rs | 200 ++++++
.../auth_config/connection_string_options.rs | 88 +++
.../types/configuration/auth_config/credentials.rs | 5 +
.../src/types/configuration/auth_config/mod.rs | 4 +
.../src/types/configuration/http_config}/config.rs | 0
.../src/types/configuration/http_config/mod.rs | 1 +
core/common/src/types/configuration/mod.rs | 4 +
.../src/types/configuration/quick_config/mod.rs | 3 +
.../quick_config/quic_client_config.rs | 77 ++
.../quick_config/quic_client_config_builder.rs} | 80 +--
.../quic_client_reconnection_config.rs | 55 ++
.../src/types/configuration/tcp_config/mod.rs | 3 +
.../configuration/tcp_config/tcp_client_config.rs | 71 ++
.../tcp_config/tcp_client_config_builder.rs | 78 ++
.../tcp_config/tcp_client_reconnection_config.rs} | 25 +-
.../src/types/confirmation/mod.rs} | 0
.../src/types/consumer}/consumer_group.rs | 0
.../src/types/consumer/consumer_kind.rs} | 6 +-
.../src/types/consumer}/consumer_offset_info.rs | 0
.../src/types/consumer/mod.rs} | 36 +-
.../src/types/diagnostic/diagnostic_event.rs} | 0
core/common/src/types/diagnostic/mod.rs | 1 +
.../src/types/identifier/mod.rs} | 6 +-
.../src/types/message/iggy_message.rs} | 18 +-
.../src/types/message}/index.rs | 0
.../src/types/message}/index_view.rs | 2 +-
.../src/types/message}/indexes.rs | 2 +-
.../src/types/message}/message_header.rs | 6 +-
.../src/types/message}/message_header_view.rs | 10 +-
.../src/types/message}/message_view.rs | 10 +-
.../src/types/message}/messages_batch.rs | 6 +-
.../messaging => common/src/types/message}/mod.rs | 17 +-
.../src/types/message}/partitioning.rs | 5 +-
.../src/types/message}/partitioning_kind.rs | 0
.../src/types/message}/polled_messages.rs | 3 +-
.../src/types/message}/polling_kind.rs | 0
.../src/types/message}/polling_strategy.rs | 4 +-
.../src/types/message}/user_headers.rs | 2 +-
core/common/src/types/mod.rs | 18 +
.../src/types/partition/mod.rs} | 0
core/common/src/types/permissions/mod.rs | 2 +
.../src/types/permissions/permissions_global.rs} | 112 ++-
.../types/permissions}/personal_access_token.rs | 0
.../src/types/snapshot/mod.rs} | 11 +-
.../stats.rs => common/src/types/stats/mod.rs} | 0
.../stream.rs => common/src/types/stream/mod.rs} | 3 +-
.../topic.rs => common/src/types/topic/mod.rs} | 4 +-
core/common/src/types/user/mod.rs | 3 +
.../src/types/user/user_identity_info.rs} | 2 +-
.../models => common/src/types/user}/user_info.rs | 4 +-
.../src/types/user}/user_status.rs | 0
core/{sdk => common}/src/utils/byte_size.rs | 4 +-
core/{sdk => common}/src/utils/checksum.rs | 2 +-
core/{sdk => common}/src/utils/crypto.rs | 4 +-
core/{sdk => common}/src/utils/duration.rs | 0
core/{sdk => common}/src/utils/expiry.rs | 0
core/common/src/utils/mod.rs | 9 +
.../src/utils/personal_access_token_expiry.rs | 0
core/{sdk => common}/src/utils/text.rs | 2 +-
core/{sdk => common}/src/utils/timestamp.rs | 4 +-
core/{sdk => common}/src/utils/topic_size.rs | 0
core/examples/Cargo.toml | 25 +-
core/examples/src/shared/args.rs | 8 +-
core/examples/src/shared/client.rs | 4 +-
core/examples/src/shared/messages.rs | 2 +-
core/examples/src/shared/messages_generator.rs | 2 +-
core/examples/src/shared/stream.rs | 2 +-
core/integration/Cargo.toml | 48 +-
core/integration/src/http_client.rs | 6 +-
core/integration/src/quic_client.rs | 8 +-
core/integration/src/tcp_client.rs | 20 +-
core/integration/src/test_server.rs | 12 +-
core/integration/tests/bench/http.rs | 2 +-
core/integration/tests/bench/mod.rs | 2 +-
core/integration/tests/bench/quic.rs | 2 +-
core/integration/tests/bench/tcp.rs | 2 +-
.../tests/cli/client/test_client_get_command.rs | 2 +-
.../tests/cli/client/test_client_list_command.rs | 2 +-
core/integration/tests/cli/common/command.rs | 2 +-
core/integration/tests/cli/common/mod.rs | 8 +-
.../test_consumer_group_create_command.rs | 4 +-
.../test_consumer_group_delete_command.rs | 6 +-
.../test_consumer_group_get_command.rs | 6 +-
.../test_consumer_group_list_command.rs | 6 +-
core/integration/tests/cli/context/common.rs | 2 +-
.../tests/cli/context/test_context_applied.rs | 47 +-
.../tests/cli/context/test_context_list_command.rs | 4 +-
.../tests/cli/context/test_context_use_command.rs | 4 +-
.../tests/cli/general/test_missing_credentials.rs | 2 +-
.../tests/cli/general/test_quiet_mode.rs | 2 +-
.../cli/message/test_message_flush_command.rs | 8 +-
.../cli/partition/test_partition_create_command.rs | 8 +-
.../cli/partition/test_partition_delete_command.rs | 6 +-
.../test_pat_create_command.rs | 2 +-
.../test_pat_delete_command.rs | 4 +-
.../personal_access_token/test_pat_list_command.rs | 4 +-
.../test_pat_login_options.rs | 4 +-
.../tests/cli/stream/test_stream_create_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_list_command.rs | 2 +-
.../tests/cli/stream/test_stream_update_command.rs | 2 +-
.../integration/tests/cli/system/test_login_cmd.rs | 6 +-
.../tests/cli/system/test_logout_cmd.rs | 4 +-
.../tests/cli/system/test_me_command.rs | 2 +-
.../tests/cli/system/test_ping_command.rs | 2 +-
.../tests/cli/system/test_snapshot_cmd.rs | 2 +-
.../tests/cli/system/test_stats_command.rs | 10 +-
.../tests/cli/topic/test_topic_create_command.rs | 10 +-
.../tests/cli/topic/test_topic_delete_command.rs | 6 +-
.../tests/cli/topic/test_topic_get_command.rs | 6 +-
.../tests/cli/topic/test_topic_list_command.rs | 6 +-
.../tests/cli/topic/test_topic_update_command.rs | 10 +-
core/integration/tests/cli/user/common.rs | 2 +-
.../tests/cli/user/test_login_options.rs | 4 +-
.../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 | 5 +-
.../tests/cli/user/test_user_list_command.rs | 4 +-
.../tests/cli/user/test_user_name_command.rs | 6 +-
.../tests/cli/user/test_user_password_command.rs | 6 +-
.../cli/user/test_user_permissions_command.rs | 10 +-
.../tests/cli/user/test_user_status_command.rs | 6 +-
.../data_integrity/verify_after_server_restart.rs | 6 +-
core/integration/tests/examples/mod.rs | 14 +-
.../scenarios/consumer_group_join_scenario.rs | 14 +-
core/integration/tests/server/scenarios/mod.rs | 8 +-
.../tests/server/scenarios/user_scenario.rs | 13 +-
core/integration/tests/state/file.rs | 6 +-
core/integration/tests/state/mod.rs | 2 +-
core/integration/tests/state/system.rs | 16 +-
.../integration/tests/streaming/consumer_offset.rs | 4 +-
.../tests/streaming/get_by_timestamp.rs | 2 +-
core/integration/tests/streaming/partition.rs | 6 +-
core/integration/tests/streaming/segment.rs | 12 +-
core/integration/tests/streaming/snapshot.rs | 2 +-
core/integration/tests/streaming/system.rs | 2 +-
core/sdk/Cargo.toml | 80 +--
core/sdk/src/binary/mod.rs | 96 ---
core/sdk/src/cli/users/get_user.rs | 205 ------
core/sdk/src/client.rs | 784 ---------------------
core/sdk/src/client_provider.rs | 23 +-
core/sdk/src/clients/binary_consumer_group.rs | 112 +++
core/sdk/src/clients/binary_consumer_offset.rs | 69 ++
core/sdk/src/clients/binary_message.rs | 108 +++
.../partitions.rs => clients/binary_partitions.rs} | 43 +-
.../src/clients/binary_personal_access_tokens.rs | 64 ++
.../{partitioner.rs => clients/binary_segments.rs} | 27 +-
core/sdk/src/clients/binary_streams.rs | 62 ++
core/sdk/src/clients/binary_system.rs | 65 ++
core/sdk/src/clients/binary_topics.rs | 120 ++++
core/sdk/src/clients/binary_users.rs | 104 +++
core/sdk/src/clients/client.rs | 605 +---------------
.../src/clients/{builder.rs => client_builder.rs} | 19 +-
core/sdk/src/clients/consumer.rs | 234 +-----
core/sdk/src/clients/consumer_builder.rs | 240 +++++++
core/sdk/src/clients/mod.rs | 17 +-
core/sdk/src/clients/producer.rs | 253 +------
core/sdk/src/clients/producer_builder.rs | 237 +++++++
core/sdk/src/consumer_ext/consumer_message_ext.rs | 2 +-
.../sdk/src/consumer_ext/consumer_message_trait.rs | 2 +-
core/sdk/src/consumer_ext/mod.rs | 2 +-
...onsumer_groups.rs => binary_consumer_groups.rs} | 14 +-
...sumer_offsets.rs => binary_consumer_offsets.rs} | 17 +-
.../src/http/{messages.rs => binary_messages.rs} | 17 +-
.../http/{partitions.rs => binary_partitions.rs} | 13 +-
..._tokens.rs => binary_personal_access_tokens.rs} | 18 +-
.../src/http/{segments.rs => binary_segments.rs} | 11 +-
.../sdk/src/http/{streams.rs => binary_streams.rs} | 16 +-
core/sdk/src/http/{system.rs => binary_system.rs} | 19 +-
core/sdk/src/http/{topics.rs => binary_topics.rs} | 18 +-
core/sdk/src/http/{users.rs => binary_users.rs} | 24 +-
core/sdk/src/http/{client.rs => http_client.rs} | 19 +-
core/sdk/src/http/{config.rs => http_config.rs} | 0
core/sdk/src/http/{mod.rs => http_transport.rs} | 38 +-
core/sdk/src/http/mod.rs | 83 +--
core/sdk/src/lib.rs | 32 -
core/sdk/src/messages/mod.rs | 35 -
core/sdk/src/models/mod.rs | 32 -
core/sdk/src/models/snapshot.rs | 28 -
core/sdk/src/prelude.rs | 72 +-
core/sdk/src/quic/mod.rs | 5 +-
core/sdk/src/quic/{client.rs => quick_client.rs} | 80 +--
core/sdk/src/quic/{config.rs => quick_config.rs} | 4 +-
core/sdk/src/quic/skip_server_verification.rs | 49 ++
.../src/stream_builder/build/build_iggy_client.rs | 6 +-
.../stream_builder/build/build_iggy_consumer.rs | 3 +-
.../stream_builder/build/build_iggy_producer.rs | 4 +-
.../src/stream_builder/build/build_stream_topic.rs | 12 +-
.../stream_builder/config/config_iggy_consumer.rs | 9 +-
.../stream_builder/config/config_iggy_producer.rs | 6 +-
.../stream_builder/config/config_iggy_stream.rs | 4 +-
core/sdk/src/stream_builder/iggy_stream.rs | 3 +-
.../sdk/src/stream_builder/iggy_stream_consumer.rs | 3 +-
.../sdk/src/stream_builder/iggy_stream_producer.rs | 3 +-
core/sdk/src/tcp/config.rs | 153 ----
core/sdk/src/tcp/mod.rs | 7 +-
core/sdk/src/tcp/{client.rs => tcp_client.rs} | 206 +-----
core/sdk/src/tcp/tcp_connection_stream.rs | 87 +++
core/sdk/src/tcp/tcp_connection_stream_kind.rs | 57 ++
.../{binary/binary_client.rs => tcp/tcp_stream.rs} | 11 +-
core/sdk/src/tcp/tcp_tls_connection_stream.rs | 84 +++
core/sdk/src/utils/mod.rs | 28 -
core/server/Cargo.toml | 112 ++-
core/server/src/binary/command.rs | 87 ++-
.../create_consumer_group_handler.rs | 6 +-
.../delete_consumer_group_handler.rs | 6 +-
.../consumer_groups/get_consumer_group_handler.rs | 6 +-
.../consumer_groups/get_consumer_groups_handler.rs | 6 +-
.../consumer_groups/join_consumer_group_handler.rs | 6 +-
.../leave_consumer_group_handler.rs | 6 +-
.../delete_consumer_offset_handler.rs | 6 +-
.../get_consumer_offset_handler.rs | 6 +-
.../store_consumer_offset_handler.rs | 6 +-
.../messages/flush_unsaved_buffer_handler.rs | 4 +-
.../handlers/messages/poll_messages_handler.rs | 4 +-
.../handlers/messages/send_messages_handler.rs | 11 +-
.../partitions/create_partitions_handler.rs | 6 +-
.../partitions/delete_partitions_handler.rs | 6 +-
.../create_personal_access_token_handler.rs | 6 +-
.../delete_personal_access_token_handler.rs | 6 +-
.../get_personal_access_tokens_handler.rs | 6 +-
.../login_with_personal_access_token_handler.rs | 6 +-
.../handlers/segments/delete_segments_handler.rs | 4 +-
.../handlers/streams/create_stream_handler.rs | 6 +-
.../handlers/streams/delete_stream_handler.rs | 6 +-
.../binary/handlers/streams/get_stream_handler.rs | 6 +-
.../binary/handlers/streams/get_streams_handler.rs | 6 +-
.../handlers/streams/purge_stream_handler.rs | 6 +-
.../handlers/streams/update_stream_handler.rs | 6 +-
.../binary/handlers/system/get_client_handler.rs | 8 +-
.../binary/handlers/system/get_clients_handler.rs | 6 +-
.../src/binary/handlers/system/get_me_handler.rs | 8 +-
.../src/binary/handlers/system/get_snapshot.rs | 6 +-
.../binary/handlers/system/get_stats_handler.rs | 6 +-
.../src/binary/handlers/system/ping_handler.rs | 10 +-
.../binary/handlers/topics/create_topic_handler.rs | 6 +-
.../binary/handlers/topics/delete_topic_handler.rs | 6 +-
.../binary/handlers/topics/get_topic_handler.rs | 6 +-
.../binary/handlers/topics/get_topics_handler.rs | 6 +-
.../binary/handlers/topics/purge_topic_handler.rs | 6 +-
.../binary/handlers/topics/update_topic_handler.rs | 6 +-
.../handlers/users/change_password_handler.rs | 6 +-
.../binary/handlers/users/create_user_handler.rs | 6 +-
.../binary/handlers/users/delete_user_handler.rs | 6 +-
.../src/binary/handlers/users/get_user_handler.rs | 6 +-
.../src/binary/handlers/users/get_users_handler.rs | 6 +-
.../binary/handlers/users/login_user_handler.rs | 6 +-
.../binary/handlers/users/logout_user_handler.rs | 6 +-
.../handlers/users/update_permissions_handler.rs | 6 +-
.../binary/handlers/users/update_user_handler.rs | 6 +-
core/server/src/binary/handlers/utils.rs | 2 +-
core/server/src/binary/macros.rs | 2 +-
core/server/src/binary/mapper.rs | 8 +-
core/server/src/binary/sender.rs | 2 +-
core/server/src/channels/commands/archive_state.rs | 4 +-
.../commands/clean_personal_access_tokens.rs | 4 +-
.../src/channels/commands/maintain_messages.rs | 8 +-
core/server/src/channels/commands/print_sysinfo.rs | 2 +-
core/server/src/channels/commands/save_messages.rs | 2 +-
.../src/channels/commands/verify_heartbeats.rs | 6 +-
.../src/compat/index_rebuilding/index_rebuilder.rs | 2 +-
core/server/src/configs/defaults.rs | 4 +-
core/server/src/configs/http.rs | 8 +-
core/server/src/configs/quic.rs | 4 +-
core/server/src/configs/server.rs | 4 +-
core/server/src/configs/system.rs | 12 +-
core/server/src/configs/tcp.rs | 2 +-
core/server/src/configs/validators.rs | 8 +-
core/server/src/http/consumer_groups.rs | 10 +-
core/server/src/http/consumer_offsets.rs | 14 +-
core/server/src/http/error.rs | 2 +-
core/server/src/http/jwt/cleaner.rs | 2 +-
core/server/src/http/jwt/json_web_token.rs | 2 +-
core/server/src/http/jwt/jwt_manager.rs | 14 +-
core/server/src/http/jwt/storage.rs | 2 +-
core/server/src/http/mapper.rs | 60 +-
core/server/src/http/messages.rs | 9 +-
core/server/src/http/partitions.rs | 8 +-
core/server/src/http/personal_access_tokens.rs | 12 +-
core/server/src/http/streams.rs | 14 +-
core/server/src/http/system.rs | 10 +-
core/server/src/http/topics.rs | 14 +-
core/server/src/http/users.rs | 20 +-
core/server/src/quic/listener.rs | 2 +-
core/server/src/quic/quic_sender.rs | 2 +-
core/server/src/server_error.rs | 2 +-
core/server/src/state/command.rs | 36 +-
core/server/src/state/entry.rs | 9 +-
core/server/src/state/file.rs | 10 +-
core/server/src/state/mod.rs | 2 +-
core/server/src/state/models.rs | 18 +-
core/server/src/state/system.rs | 14 +-
.../server/src/streaming/clients/client_manager.rs | 10 +-
.../deduplication/message_deduplicator.rs | 2 +-
core/server/src/streaming/local_sizeable.rs | 2 +-
.../src/streaming/partitions/consumer_offsets.rs | 4 +-
core/server/src/streaming/partitions/messages.rs | 4 +-
core/server/src/streaming/partitions/partition.rs | 18 +-
.../server/src/streaming/partitions/persistence.rs | 2 +-
core/server/src/streaming/partitions/segments.rs | 4 +-
core/server/src/streaming/partitions/storage.rs | 4 +-
core/server/src/streaming/persistence/persister.rs | 2 +-
core/server/src/streaming/persistence/task.rs | 2 +-
.../personal_access_token.rs | 12 +-
core/server/src/streaming/polling_consumer.rs | 4 +-
.../src/streaming/segments/indexes/index_reader.rs | 3 +-
.../src/streaming/segments/indexes/index_writer.rs | 4 +-
.../src/streaming/segments/indexes/indexes_mut.rs | 2 +-
.../streaming/segments/messages/messages_reader.rs | 6 +-
.../streaming/segments/messages/messages_writer.rs | 2 +-
core/server/src/streaming/segments/messages/mod.rs | 2 +-
.../src/streaming/segments/reading_messages.rs | 2 +-
core/server/src/streaming/segments/segment.rs | 12 +-
.../segments/types/message_header_view_mut.rs | 8 +-
.../streaming/segments/types/message_view_mut.rs | 5 +-
.../streaming/segments/types/messages_batch_mut.rs | 7 +-
.../streaming/segments/types/messages_batch_set.rs | 3 +-
.../src/streaming/segments/writing_messages.rs | 4 +-
core/server/src/streaming/session.rs | 2 +-
core/server/src/streaming/storage.rs | 4 +-
core/server/src/streaming/streams/persistence.rs | 2 +-
core/server/src/streaming/streams/storage.rs | 4 +-
core/server/src/streaming/streams/stream.rs | 4 +-
core/server/src/streaming/streams/topics.rs | 14 +-
core/server/src/streaming/systems/clients.rs | 8 +-
.../src/streaming/systems/consumer_groups.rs | 6 +-
.../src/streaming/systems/consumer_offsets.rs | 5 +-
core/server/src/streaming/systems/info.rs | 2 +-
core/server/src/streaming/systems/messages.rs | 9 +-
core/server/src/streaming/systems/partitions.rs | 4 +-
.../streaming/systems/personal_access_tokens.rs | 6 +-
core/server/src/streaming/systems/segments.rs | 6 +-
core/server/src/streaming/systems/snapshot/mod.rs | 5 +-
core/server/src/streaming/systems/stats.rs | 6 +-
core/server/src/streaming/systems/storage.rs | 2 +-
core/server/src/streaming/systems/streams.rs | 7 +-
core/server/src/streaming/systems/system.rs | 8 +-
core/server/src/streaming/systems/topics.rs | 8 +-
core/server/src/streaming/systems/users.rs | 14 +-
core/server/src/streaming/topics/consumer_group.rs | 2 +-
.../server/src/streaming/topics/consumer_groups.rs | 10 +-
.../src/streaming/topics/consumer_offsets.rs | 7 +-
core/server/src/streaming/topics/messages.rs | 15 +-
core/server/src/streaming/topics/partitions.rs | 6 +-
core/server/src/streaming/topics/persistence.rs | 4 +-
core/server/src/streaming/topics/segments.rs | 2 +-
core/server/src/streaming/topics/storage.rs | 6 +-
core/server/src/streaming/topics/topic.rs | 17 +-
core/server/src/streaming/users/permissioner.rs | 4 +-
.../users/permissioner_rules/consumer_groups.rs | 2 +-
.../users/permissioner_rules/consumer_offsets.rs | 2 +-
.../streaming/users/permissioner_rules/messages.rs | 2 +-
.../users/permissioner_rules/partitions.rs | 2 +-
.../streaming/users/permissioner_rules/segments.rs | 2 +-
.../streaming/users/permissioner_rules/streams.rs | 2 +-
.../streaming/users/permissioner_rules/system.rs | 2 +-
.../streaming/users/permissioner_rules/topics.rs | 2 +-
.../streaming/users/permissioner_rules/users.rs | 2 +-
core/server/src/streaming/users/user.rs | 8 +-
core/server/src/streaming/utils/memory_pool.rs | 2 +-
core/server/src/tcp/connection_handler.rs | 2 +-
core/server/src/tcp/sender.rs | 2 +-
core/server/src/tcp/tcp_sender.rs | 2 +-
core/server/src/tcp/tcp_socket.rs | 2 +-
core/server/src/tcp/tcp_tls_sender.rs | 2 +-
core/server/src/versioning.rs | 2 +-
core/tools/Cargo.toml | 14 +-
core/tools/src/data-seeder/main.rs | 4 +-
596 files changed, 5830 insertions(+), 5405 deletions(-)
create mode 100644 =
create mode 100644 core/binary_protocol/Cargo.toml
rename core/{sdk/src/cli/client => binary_protocol/src/cli/binary_client}/get_client.rs (96%)
rename core/{sdk/src/cli/client => binary_protocol/src/cli/binary_client}/get_clients.rs (96%)
rename core/{sdk/src/cli/client => binary_protocol/src/cli/binary_client}/mod.rs (100%)
rename core/{sdk/src/cli/consumer_group => binary_protocol/src/cli/binary_consumer_groups}/create_consumer_group.rs (94%)
rename core/{sdk/src/cli/consumer_group => binary_protocol/src/cli/binary_consumer_groups}/delete_consumer_group.rs (93%)
rename core/{sdk/src/cli/consumer_group => binary_protocol/src/cli/binary_consumer_groups}/get_consumer_group.rs (95%)
rename core/{sdk/src/cli/consumer_group => binary_protocol/src/cli/binary_consumer_groups}/get_consumer_groups.rs (95%)
rename core/{sdk/src/cli/consumer_group => binary_protocol/src/cli/binary_consumer_groups}/mod.rs (100%)
rename core/{sdk/src/cli/consumer_offset => binary_protocol/src/cli/binary_consumer_offsets}/get_consumer_offset.rs (95%)
rename core/{sdk/src/cli/consumer_offset => binary_protocol/src/cli/binary_consumer_offsets}/mod.rs (100%)
rename core/{sdk/src/cli/consumer_offset => binary_protocol/src/cli/binary_consumer_offsets}/set_consumer_offset.rs (93%)
rename core/{sdk/src/cli/context => binary_protocol/src/cli/binary_context}/common.rs (99%)
rename core/{sdk/src/cli/context => binary_protocol/src/cli/binary_context}/get_contexts.rs (97%)
rename core/{sdk/src/cli/context => binary_protocol/src/cli/binary_context}/mod.rs (100%)
rename core/{sdk/src/cli/context => binary_protocol/src/cli/binary_context}/use_context.rs (96%)
rename core/{sdk/src/cli/message => binary_protocol/src/cli/binary_message}/flush_messages.rs (95%)
rename core/{sdk/src/cli/message => binary_protocol/src/cli/binary_message}/mod.rs (100%)
rename core/{sdk/src/cli/message => binary_protocol/src/cli/binary_message}/poll_messages.rs (95%)
rename core/{sdk/src/cli/message => binary_protocol/src/cli/binary_message}/send_messages.rs (95%)
rename core/{sdk/src/cli/partitions => binary_protocol/src/cli/binary_partitions}/create_partitions.rs (94%)
rename core/{sdk/src/cli/partitions => binary_protocol/src/cli/binary_partitions}/delete_partitions.rs (94%)
rename core/{sdk/src/cli/partitions => binary_protocol/src/cli/binary_partitions}/mod.rs (100%)
rename core/{sdk/src/cli/personal_access_tokens => binary_protocol/src/cli/binary_personal_access_tokens}/create_personal_access_token.rs (94%)
rename core/{sdk/src/cli/personal_access_tokens => binary_protocol/src/cli/binary_personal_access_tokens}/delete_personal_access_tokens.rs (93%)
rename core/{sdk/src/cli/personal_access_tokens => binary_protocol/src/cli/binary_personal_access_tokens}/get_personal_access_tokens.rs (95%)
rename core/{sdk/src/cli/personal_access_tokens => binary_protocol/src/cli/binary_personal_access_tokens}/mod.rs (100%)
rename core/{sdk/src/cli/segments => binary_protocol/src/cli/binary_segments}/delete_segments.rs (95%)
rename core/{sdk/src/cli/segments => binary_protocol/src/cli/binary_segments}/mod.rs (100%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/create_stream.rs (94%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/delete_stream.rs (91%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/get_stream.rs (94%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/get_streams.rs (96%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/mod.rs (100%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/purge_stream.rs (91%)
rename core/{sdk/src/cli/streams => binary_protocol/src/cli/binary_streams}/update_stream.rs (92%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/login.rs (95%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/logout.rs (93%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/me.rs (94%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/mod.rs (100%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/ping.rs (98%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/session.rs (100%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/snapshot.rs (94%)
rename core/{sdk/src/cli/system => binary_protocol/src/cli/binary_system}/stats.rs (98%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/create_topic.rs (91%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/delete_topic.rs (92%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/get_topic.rs (94%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/get_topics.rs (96%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/mod.rs (100%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/purge_topic.rs (92%)
rename core/{sdk/src/cli/topics => binary_protocol/src/cli/binary_topics}/update_topic.rs (91%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/change_password.rs (96%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/create_user.rs (91%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/delete_user.rs (91%)
create mode 100644 core/binary_protocol/src/cli/binary_users/get_user.rs
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/get_users.rs (96%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/mod.rs (100%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/update_permissions.rs (90%)
rename core/{sdk/src/cli/users => binary_protocol/src/cli/binary_users}/update_user.rs (93%)
copy core/{sdk/src => binary_protocol/src/cli}/cli_command.rs (97%)
rename core/{sdk => binary_protocol}/src/cli/mod.rs (70%)
rename core/{sdk => binary_protocol}/src/cli/utils/login_session_expiry.rs (95%)
rename core/{sdk => binary_protocol}/src/cli/utils/mod.rs (100%)
copy core/{sdk/src/binary => binary_protocol/src/client/binary_clients}/binary_client.rs (92%)
create mode 100644 core/binary_protocol/src/client/binary_clients/client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/consumer_group_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/consumer_offset_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/message_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/mod.rs
copy core/{sdk/src/binary/partitions.rs => binary_protocol/src/client/binary_clients/partition_client.rs} (52%)
create mode 100644 core/binary_protocol/src/client/binary_clients/personal_access_token_client.rs
copy core/{sdk/src/binary/segments.rs => binary_protocol/src/client/binary_clients/segment_client.rs} (59%)
create mode 100644 core/binary_protocol/src/client/binary_clients/stream_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/system_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/topic_client.rs
create mode 100644 core/binary_protocol/src/client/binary_clients/user_client.rs
rename core/{sdk/src/binary/consumer_groups.rs => binary_protocol/src/client/binary_consumer_groups/mod.rs} (84%)
rename core/{sdk/src/binary/consumer_offsets.rs => binary_protocol/src/client/binary_consumer_offsets/mod.rs} (83%)
rename core/{sdk/src/binary/messages.rs => binary_protocol/src/client/binary_messages/mod.rs} (80%)
copy core/{sdk/src/binary/partitions.rs => binary_protocol/src/client/binary_partitions/mod.rs} (83%)
rename core/{sdk/src/binary/personal_access_tokens.rs => binary_protocol/src/client/binary_personal_access_tokens/mod.rs} (74%)
rename core/{sdk/src/binary/segments.rs => binary_protocol/src/client/binary_segments/mod.rs} (84%)
rename core/{sdk/src/binary/streams.rs => binary_protocol/src/client/binary_streams/mod.rs} (84%)
rename core/{sdk/src/binary/system.rs => binary_protocol/src/client/binary_system/mod.rs} (79%)
rename core/{sdk/src/binary/topics.rs => binary_protocol/src/client/binary_topics/mod.rs} (85%)
rename core/{sdk/src/cli_command.rs => binary_protocol/src/client/binary_transport/mod.rs} (56%)
rename core/{sdk/src/binary/users.rs => binary_protocol/src/client/binary_users/mod.rs} (84%)
create mode 100644 core/binary_protocol/src/client/mod.rs
copy core/{bench/src/args/mod.rs => binary_protocol/src/lib.rs} (82%)
copy core/{server/src/streaming/streams/partitions.rs => binary_protocol/src/utils/auth.rs} (60%)
rename core/{sdk/src/binary => binary_protocol/src/utils}/mapper.rs (96%)
copy core/{bench/report/src/plotting/text => binary_protocol/src/utils}/mod.rs (94%)
create mode 100644 core/common/Cargo.toml
rename core/{sdk/src => common/src/commands}/consumer_groups/create_consumer_group.rs (96%)
rename core/{sdk/src => common/src/commands}/consumer_groups/delete_consumer_group.rs (95%)
rename core/{sdk/src => common/src/commands}/consumer_groups/get_consumer_group.rs (95%)
rename core/{sdk/src => common/src/commands}/consumer_groups/get_consumer_groups.rs (94%)
rename core/{sdk/src => common/src/commands}/consumer_groups/join_consumer_group.rs (95%)
rename core/{sdk/src => common/src/commands}/consumer_groups/leave_consumer_group.rs (95%)
rename core/{sdk/src => common/src/commands}/consumer_groups/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/consumer_offsets/delete_consumer_offset.rs (96%)
rename core/{sdk/src => common/src/commands}/consumer_offsets/get_consumer_offset.rs (96%)
rename core/{sdk/src => common/src/commands}/consumer_offsets/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/consumer_offsets/store_consumer_offset.rs (96%)
rename core/{sdk/src => common/src/commands}/messages/flush_unsaved_buffer.rs (92%)
create mode 100644 core/common/src/commands/messages/mod.rs
rename core/{sdk/src => common/src/commands}/messages/poll_messages.rs (96%)
rename core/{sdk/src => common/src/commands}/messages/send_messages.rs (94%)
create mode 100644 core/common/src/commands/mod.rs
rename core/{sdk/src => common/src/commands}/partitions/create_partitions.rs (95%)
rename core/{sdk/src => common/src/commands}/partitions/delete_partitions.rs (95%)
rename core/{sdk/src => common/src/commands}/partitions/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/personal_access_tokens/create_personal_access_token.rs (96%)
rename core/{sdk/src => common/src/commands}/personal_access_tokens/delete_personal_access_token.rs (95%)
rename core/{sdk/src => common/src/commands}/personal_access_tokens/get_personal_access_tokens.rs (94%)
rename core/{sdk/src => common/src/commands}/personal_access_tokens/login_with_personal_access_token.rs (95%)
rename core/{sdk/src => common/src/commands}/personal_access_tokens/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/segments/delete_segments.rs (96%)
rename core/{sdk/src => common/src/commands}/segments/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/streams/create_stream.rs (96%)
rename core/{sdk/src => common/src/commands}/streams/delete_stream.rs (94%)
rename core/{sdk/src => common/src/commands}/streams/get_stream.rs (94%)
rename core/{sdk/src => common/src/commands}/streams/get_streams.rs (94%)
rename core/{sdk/src => common/src/commands}/streams/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/streams/purge_stream.rs (94%)
rename core/{sdk/src => common/src/commands}/streams/update_stream.rs (95%)
rename core/{sdk/src => common/src/commands}/system/get_client.rs (95%)
rename core/{sdk/src => common/src/commands}/system/get_clients.rs (94%)
rename core/{sdk/src => common/src/commands}/system/get_me.rs (94%)
rename core/{sdk/src => common/src/commands}/system/get_snapshot.rs (96%)
rename core/{sdk/src => common/src/commands}/system/get_stats.rs (94%)
rename core/{sdk/src => common/src/commands}/system/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/system/ping.rs (94%)
rename core/{sdk/src => common/src/commands}/topics/create_topic.rs (97%)
rename core/{sdk/src => common/src/commands}/topics/delete_topic.rs (94%)
rename core/{sdk/src => common/src/commands}/topics/get_topic.rs (95%)
rename core/{sdk/src => common/src/commands}/topics/get_topics.rs (94%)
rename core/{sdk/src => common/src/commands}/topics/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/topics/purge_topic.rs (95%)
rename core/{sdk/src => common/src/commands}/topics/update_topic.rs (97%)
rename core/{sdk/src => common/src/commands}/users/change_password.rs (96%)
rename core/{sdk/src => common/src/commands}/users/create_user.rs (96%)
rename core/{sdk/src => common/src/commands}/users/defaults.rs (100%)
rename core/{sdk/src => common/src/commands}/users/delete_user.rs (94%)
rename core/{sdk/src => common/src/commands}/users/get_user.rs (94%)
rename core/{sdk/src => common/src/commands}/users/get_users.rs (94%)
rename core/{sdk/src => common/src/commands}/users/login_user.rs (98%)
rename core/{sdk/src => common/src/commands}/users/logout_user.rs (94%)
rename core/{sdk/src => common/src/commands}/users/mod.rs (100%)
rename core/{sdk/src => common/src/commands}/users/update_permissions.rs (94%)
rename core/{sdk/src => common/src/commands}/users/update_user.rs (95%)
rename core/{sdk/src => common/src/error}/client_error.rs (97%)
rename core/{sdk/src/error.rs => common/src/error/iggy_error.rs} (99%)
create mode 100644 core/common/src/error/mod.rs
create mode 100644 core/common/src/lib.rs
rename core/{sdk => common}/src/locking/fast_async_lock.rs (100%)
rename core/{sdk => common}/src/locking/mod.rs (100%)
rename core/{sdk => common}/src/locking/tokio_lock.rs (100%)
rename core/{sdk/src => common/src/traits}/bytes_serializable.rs (98%)
create mode 100644 core/common/src/traits/mod.rs
copy core/{sdk/src => common/src/traits}/partitioner.rs (95%)
rename core/{sdk/src/utils => common/src/traits}/sizeable.rs (96%)
rename core/{sdk/src => common/src/traits}/validatable.rs (100%)
rename core/{sdk/src/args.rs => common/src/types/args/mod.rs} (99%)
rename core/{sdk/src/models => common/src/types/client}/client_info.rs (100%)
create mode 100644 core/common/src/types/client/mod.rs
copy core/{sdk/src/diagnostic.rs => common/src/types/client_state/mod.rs} (67%)
rename core/{sdk/src/command.rs => common/src/types/command/mod.rs} (98%)
rename core/{sdk/src => common/src/types}/compression/compression_algorithm.rs (100%)
rename core/{sdk/src => common/src/types}/compression/mod.rs (100%)
create mode 100644 core/common/src/types/configuration/auth_config/auto_login.rs
create mode 100644 core/common/src/types/configuration/auth_config/connection_string.rs
create mode 100644 core/common/src/types/configuration/auth_config/connection_string_options.rs
create mode 100644 core/common/src/types/configuration/auth_config/credentials.rs
create mode 100644 core/common/src/types/configuration/auth_config/mod.rs
copy core/{sdk/src/http => common/src/types/configuration/http_config}/config.rs (100%)
create mode 100644 core/common/src/types/configuration/http_config/mod.rs
create mode 100644 core/common/src/types/configuration/mod.rs
create mode 100644 core/common/src/types/configuration/quick_config/mod.rs
create mode 100644 core/common/src/types/configuration/quick_config/quic_client_config.rs
copy core/{sdk/src/quic/config.rs => common/src/types/configuration/quick_config/quic_client_config_builder.rs} (68%)
create mode 100644 core/common/src/types/configuration/quick_config/quic_client_reconnection_config.rs
create mode 100644 core/common/src/types/configuration/tcp_config/mod.rs
create mode 100644 core/common/src/types/configuration/tcp_config/tcp_client_config.rs
create mode 100644 core/common/src/types/configuration/tcp_config/tcp_client_config_builder.rs
copy core/{server/src/streaming/topics/segments.rs => common/src/types/configuration/tcp_config/tcp_client_reconnection_config.rs} (59%)
rename core/{sdk/src/confirmation.rs => common/src/types/confirmation/mod.rs} (100%)
rename core/{sdk/src/models => common/src/types/consumer}/consumer_group.rs (100%)
copy core/{sdk/src/consumer.rs => common/src/types/consumer/consumer_kind.rs} (97%)
rename core/{sdk/src/models => common/src/types/consumer}/consumer_offset_info.rs (100%)
rename core/{sdk/src/consumer.rs => common/src/types/consumer/mod.rs} (84%)
rename core/{sdk/src/diagnostic.rs => common/src/types/diagnostic/diagnostic_event.rs} (100%)
create mode 100644 core/common/src/types/diagnostic/mod.rs
rename core/{sdk/src/identifier.rs => common/src/types/identifier/mod.rs} (98%)
rename core/{sdk/src/models/messaging/message.rs => common/src/types/message/iggy_message.rs} (98%)
rename core/{sdk/src/models/messaging => common/src/types/message}/index.rs (100%)
rename core/{sdk/src/models/messaging => common/src/types/message}/index_view.rs (98%)
rename core/{sdk/src/models/messaging => common/src/types/message}/indexes.rs (99%)
rename core/{sdk/src/models/messaging => common/src/types/message}/message_header.rs (97%)
rename core/{sdk/src/models/messaging => common/src/types/message}/message_header_view.rs (91%)
rename core/{sdk/src/models/messaging => common/src/types/message}/message_view.rs (96%)
rename core/{sdk/src/models/messaging => common/src/types/message}/messages_batch.rs (98%)
rename core/{sdk/src/models/messaging => common/src/types/message}/mod.rs (72%)
rename core/{sdk/src/messages => common/src/types/message}/partitioning.rs (98%)
rename core/{sdk/src/messages => common/src/types/message}/partitioning_kind.rs (100%)
rename core/{sdk/src/messages => common/src/types/message}/polled_messages.rs (97%)
rename core/{sdk/src/messages => common/src/types/message}/polling_kind.rs (100%)
rename core/{sdk/src/messages => common/src/types/message}/polling_strategy.rs (98%)
rename core/{sdk/src/models/messaging => common/src/types/message}/user_headers.rs (99%)
create mode 100644 core/common/src/types/mod.rs
rename core/{sdk/src/models/partition.rs => common/src/types/partition/mod.rs} (100%)
create mode 100644 core/common/src/types/permissions/mod.rs
rename core/{sdk/src/models/permissions.rs => common/src/types/permissions/permissions_global.rs} (84%)
rename core/{sdk/src/models => common/src/types/permissions}/personal_access_token.rs (100%)
rename core/{sdk/src/snapshot.rs => common/src/types/snapshot/mod.rs} (97%)
rename core/{sdk/src/models/stats.rs => common/src/types/stats/mod.rs} (100%)
rename core/{sdk/src/models/stream.rs => common/src/types/stream/mod.rs} (96%)
rename core/{sdk/src/models/topic.rs => common/src/types/topic/mod.rs} (97%)
create mode 100644 core/common/src/types/user/mod.rs
rename core/{sdk/src/models/identity_info.rs => common/src/types/user/user_identity_info.rs} (98%)
rename core/{sdk/src/models => common/src/types/user}/user_info.rs (96%)
rename core/{sdk/src/models => common/src/types/user}/user_status.rs (100%)
rename core/{sdk => common}/src/utils/byte_size.rs (99%)
rename core/{sdk => common}/src/utils/checksum.rs (94%)
rename core/{sdk => common}/src/utils/crypto.rs (98%)
rename core/{sdk => common}/src/utils/duration.rs (100%)
rename core/{sdk => common}/src/utils/expiry.rs (100%)
create mode 100644 core/common/src/utils/mod.rs
rename core/{sdk => common}/src/utils/personal_access_token_expiry.rs (100%)
rename core/{sdk => common}/src/utils/text.rs (97%)
rename core/{sdk => common}/src/utils/timestamp.rs (98%)
rename core/{sdk => common}/src/utils/topic_size.rs (100%)
delete mode 100644 core/sdk/src/binary/mod.rs
delete mode 100644 core/sdk/src/cli/users/get_user.rs
delete mode 100644 core/sdk/src/client.rs
create mode 100644 core/sdk/src/clients/binary_consumer_group.rs
create mode 100644 core/sdk/src/clients/binary_consumer_offset.rs
create mode 100644 core/sdk/src/clients/binary_message.rs
rename core/sdk/src/{binary/partitions.rs => clients/binary_partitions.rs} (56%)
create mode 100644 core/sdk/src/clients/binary_personal_access_tokens.rs
rename core/sdk/src/{partitioner.rs => clients/binary_segments.rs} (62%)
create mode 100644 core/sdk/src/clients/binary_streams.rs
create mode 100644 core/sdk/src/clients/binary_system.rs
create mode 100644 core/sdk/src/clients/binary_topics.rs
create mode 100644 core/sdk/src/clients/binary_users.rs
rename core/sdk/src/clients/{builder.rs => client_builder.rs} (95%)
create mode 100644 core/sdk/src/clients/consumer_builder.rs
create mode 100644 core/sdk/src/clients/producer_builder.rs
rename core/sdk/src/http/{consumer_groups.rs => binary_consumer_groups.rs} (92%)
rename core/sdk/src/http/{consumer_offsets.rs => binary_consumer_offsets.rs} (88%)
rename core/sdk/src/http/{messages.rs => binary_messages.rs} (90%)
rename core/sdk/src/http/{partitions.rs => binary_partitions.rs} (87%)
rename core/sdk/src/http/{personal_access_tokens.rs => binary_personal_access_tokens.rs} (82%)
rename core/sdk/src/http/{segments.rs => binary_segments.rs} (88%)
rename core/sdk/src/http/{streams.rs => binary_streams.rs} (90%)
rename core/sdk/src/http/{system.rs => binary_system.rs} (87%)
rename core/sdk/src/http/{topics.rs => binary_topics.rs} (90%)
rename core/sdk/src/http/{users.rs => binary_users.rs} (89%)
rename core/sdk/src/http/{client.rs => http_client.rs} (95%)
rename core/sdk/src/http/{config.rs => http_config.rs} (100%)
copy core/sdk/src/http/{mod.rs => http_transport.rs} (59%)
delete mode 100644 core/sdk/src/messages/mod.rs
delete mode 100644 core/sdk/src/models/mod.rs
delete mode 100644 core/sdk/src/models/snapshot.rs
rename core/sdk/src/quic/{client.rs => quick_client.rs} (91%)
rename core/sdk/src/quic/{config.rs => quick_config.rs} (99%)
create mode 100644 core/sdk/src/quic/skip_server_verification.rs
delete mode 100644 core/sdk/src/tcp/config.rs
rename core/sdk/src/tcp/{client.rs => tcp_client.rs} (78%)
create mode 100644 core/sdk/src/tcp/tcp_connection_stream.rs
create mode 100644 core/sdk/src/tcp/tcp_connection_stream_kind.rs
rename core/sdk/src/{binary/binary_client.rs => tcp/tcp_stream.rs} (72%)
create mode 100644 core/sdk/src/tcp/tcp_tls_connection_stream.rs
delete mode 100644 core/sdk/src/utils/mod.rs