This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch two_halves
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c4e71b57a feat(server): implement TwoHalves buffer
add edf7adaf3 refactor(rust): empty binary_protocol crate by relocating
its contents (#2942)
add 2ea6d5bd1 feat(cpp): part of low-level bindings, their tests, and e2e
CI config (#2852)
add 0e435f0bd fix(cpp): Remove `--locked` option and delete cargo.lock
file (#2949)
add 18588f149 refactor(journal): refactor partition journal utilize
storage trait (#2909)
add 25dcd7634 refactor(repo): wrap credentials in SecretString to prevent
leaks (#2931)
add 681290767 refactor(java): unify blocking TCP client as wrapper over
async client (#2947)
add 003db4133 Merge branch 'master' into two_halves
No new revisions were added by this update.
Summary of changes:
.github/actions/cpp-bazel/pre-merge/action.yml | 23 +-
.github/config/components.yml | 2 +-
Cargo.lock | 46 +--
Cargo.toml | 2 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 2 +-
core/binary_protocol/Cargo.toml | 15 -
.../src/client/binary_clients/mod.rs | 44 ---
core/binary_protocol/src/client/mod.rs | 30 --
core/binary_protocol/src/lib.rs | 8 -
core/binary_protocol/src/utils/mod.rs | 20 --
core/cli/Cargo.toml | 15 +-
core/cli/src/args/common.rs | 18 +-
core/cli/src/args/mod.rs | 2 +-
core/cli/src/args/system.rs | 2 +-
.../src/commands}/binary_client/get_client.rs | 4 +-
.../src/commands}/binary_client/get_clients.rs | 4 +-
.../cli => cli/src/commands}/binary_client/mod.rs | 0
.../binary_cluster/get_cluster_metadata.rs | 4 +-
.../cli => cli/src/commands}/binary_cluster/mod.rs | 0
.../create_consumer_group.rs | 4 +-
.../delete_consumer_group.rs | 4 +-
.../binary_consumer_groups/get_consumer_group.rs | 4 +-
.../binary_consumer_groups/get_consumer_groups.rs | 4 +-
.../src/commands}/binary_consumer_groups/mod.rs | 0
.../binary_consumer_offsets/get_consumer_offset.rs | 4 +-
.../src/commands}/binary_consumer_offsets/mod.rs | 0
.../binary_consumer_offsets/set_consumer_offset.rs | 4 +-
.../src/commands}/binary_context/common.rs | 0
.../src/commands}/binary_context/get_contexts.rs | 4 +-
.../cli => cli/src/commands}/binary_context/mod.rs | 0
.../src/commands}/binary_context/use_context.rs | 4 +-
.../src/commands}/binary_message/flush_messages.rs | 4 +-
.../cli => cli/src/commands}/binary_message/mod.rs | 0
.../src/commands}/binary_message/poll_messages.rs | 4 +-
.../src/commands}/binary_message/send_messages.rs | 4 +-
.../binary_partitions/create_partitions.rs | 4 +-
.../binary_partitions/delete_partitions.rs | 4 +-
.../src/commands}/binary_partitions/mod.rs | 0
.../create_personal_access_token.rs | 11 +-
.../delete_personal_access_tokens.rs | 4 +-
.../get_personal_access_tokens.rs | 4 +-
.../commands}/binary_personal_access_tokens/mod.rs | 0
.../commands}/binary_segments/delete_segments.rs | 4 +-
.../src/commands}/binary_segments/mod.rs | 0
.../src/commands}/binary_streams/create_stream.rs | 4 +-
.../src/commands}/binary_streams/delete_stream.rs | 4 +-
.../src/commands}/binary_streams/get_stream.rs | 4 +-
.../src/commands}/binary_streams/get_streams.rs | 4 +-
.../cli => cli/src/commands}/binary_streams/mod.rs | 0
.../src/commands}/binary_streams/purge_stream.rs | 4 +-
.../src/commands}/binary_streams/update_stream.rs | 4 +-
.../src/commands}/binary_system/login.rs | 11 +-
.../src/commands}/binary_system/logout.rs | 6 +-
.../cli => cli/src/commands}/binary_system/me.rs | 4 +-
.../cli => cli/src/commands}/binary_system/mod.rs | 0
.../cli => cli/src/commands}/binary_system/ping.rs | 4 +-
.../src/commands}/binary_system/session.rs | 0
.../src/commands}/binary_system/snapshot.rs | 4 +-
.../src/commands}/binary_system/stats.rs | 4 +-
.../src/commands}/binary_topics/create_topic.rs | 4 +-
.../src/commands}/binary_topics/delete_topic.rs | 4 +-
.../src/commands}/binary_topics/get_topic.rs | 4 +-
.../src/commands}/binary_topics/get_topics.rs | 4 +-
.../cli => cli/src/commands}/binary_topics/mod.rs | 0
.../src/commands}/binary_topics/purge_topic.rs | 4 +-
.../src/commands}/binary_topics/update_topic.rs | 4 +-
.../src/commands}/binary_users/change_password.rs | 4 +-
.../src/commands}/binary_users/create_user.rs | 22 +-
.../src/commands}/binary_users/delete_user.rs | 4 +-
.../src/commands}/binary_users/get_user.rs | 4 +-
.../src/commands}/binary_users/get_users.rs | 4 +-
.../cli => cli/src/commands}/binary_users/mod.rs | 0
.../commands}/binary_users/update_permissions.rs | 4 +-
.../src/commands}/binary_users/update_user.rs | 4 +-
.../src/cli => cli/src/commands}/cli_command.rs | 2 +-
.../src/cli => cli/src/commands}/mod.rs | 0
.../src/commands}/utils/login_session_expiry.rs | 0
.../src/cli => cli/src/commands}/utils/mod.rs | 0
core/cli/src/credentials.rs | 47 ++-
{examples/rust => core/cli}/src/lib.rs | 2 +-
core/cli/src/logging.rs | 2 +-
core/cli/src/main.rs | 16 +-
core/common/Cargo.toml | 3 +
.../login_with_personal_access_token.rs | 44 ++-
core/common/src/commands/users/change_password.rs | 82 +++--
core/common/src/commands/users/create_user.rs | 59 ++-
core/common/src/commands/users/login_user.rs | 65 +++-
core/common/src/lib.rs | 15 +
.../auth.rs => common/src/traits/binary_auth.rs} | 7 +-
.../src/traits}/binary_client.rs | 3 +-
.../src/traits/binary_impls/cluster.rs} | 10 +-
.../src/traits/binary_impls/consumer_groups.rs} | 26 +-
.../src/traits/binary_impls/consumer_offsets.rs} | 17 +-
.../src/traits/binary_impls/messages.rs} | 8 +-
.../src/traits/binary_impls}/mod.rs | 15 +-
.../src/traits/binary_impls/partitions.rs} | 10 +-
.../traits/binary_impls/personal_access_tokens.rs} | 29 +-
.../src/traits/binary_impls/segments.rs} | 7 +-
.../src/traits/binary_impls/streams.rs} | 26 +-
.../src/traits/binary_impls/system.rs} | 30 +-
.../src/traits/binary_impls/topics.rs} | 29 +-
.../src/traits/binary_impls/users.rs} | 47 +--
.../src/traits/binary_mapper.rs} | 9 +-
.../src/traits/binary_transport.rs} | 2 +-
.../binary_clients => common/src/traits}/client.rs | 2 +-
.../src/traits}/cluster_client.rs | 2 +-
.../src/traits}/consumer_group_client.rs | 2 +-
.../src/traits}/consumer_offset_client.rs | 2 +-
.../src/traits}/message_client.rs | 4 +-
core/common/src/traits/mod.rs | 17 +
.../src/traits}/partition_client.rs | 2 +-
.../src/traits}/personal_access_token_client.rs | 4 +-
.../src/traits}/segment_client.rs | 2 +-
.../src/traits}/stream_client.rs | 2 +-
.../src/traits}/system_client.rs | 4 +-
.../src/traits}/topic_client.rs | 4 +-
.../src/traits}/user_client.rs | 4 +-
.../types/configuration/auth_config/auto_login.rs | 2 +-
.../configuration/auth_config/connection_string.rs | 44 +--
.../types/configuration/auth_config/credentials.rs | 25 +-
.../src/types/permissions/personal_access_token.rs | 16 +-
core/common/src/types/user/user_identity_info.rs | 17 +-
core/common/src/utils/mod.rs | 1 +
core/common/src/utils/serde_secret.rs | 106 ++++++
core/connectors/runtime/Cargo.toml | 1 +
core/connectors/runtime/src/api/auth.rs | 5 +-
core/connectors/runtime/src/api/config.rs | 28 +-
core/connectors/runtime/src/context.rs | 5 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 1 +
.../connectors/sinks/elasticsearch_sink/src/lib.rs | 7 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +
core/connectors/sinks/mongodb_sink/src/lib.rs | 10 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 1 +
core/connectors/sinks/postgres_sink/src/lib.rs | 10 +-
.../sources/elasticsearch_source/Cargo.toml | 1 +
.../sources/elasticsearch_source/src/lib.rs | 7 +-
core/connectors/sources/postgres_source/Cargo.toml | 1 +
core/connectors/sources/postgres_source/src/lib.rs | 10 +-
core/integration/Cargo.toml | 3 +-
core/integration/src/harness/seeds.rs | 6 +-
core/integration/tests/cli/context/common.rs | 2 +-
.../tests/cli/context/test_context_applied.rs | 2 +-
.../tests/cli/context/test_context_list_command.rs | 2 +-
.../tests/cli/context/test_context_use_command.rs | 2 +-
.../test_pat_login_options.rs | 7 +-
.../integration/tests/cli/system/test_login_cmd.rs | 2 +-
.../tests/cli/system/test_logout_cmd.rs | 2 +-
.../tests/cli/system/test_stats_command.rs | 2 +-
.../tests/cli/user/test_user_create_command.rs | 8 +-
.../connectors/elasticsearch/elasticsearch_sink.rs | 2 +-
.../elasticsearch/elasticsearch_source.rs | 2 +-
.../tests/connectors/iceberg/iceberg_sink.rs | 2 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 2 +-
.../tests/connectors/postgres/postgres_sink.rs | 2 +-
.../tests/connectors/postgres/postgres_source.rs | 2 +-
.../tests/connectors/postgres/restart.rs | 2 +-
.../tests/connectors/quickwit/quickwit_sink.rs | 2 +-
.../tests/connectors/random/random_source.rs | 2 +-
.../tests/connectors/stdout/stdout_sink.rs | 2 +-
core/integration/tests/mcp/mod.rs | 3 +-
.../server/scenarios/authentication_scenario.rs | 3 +-
.../scenarios/cross_protocol_pat_scenario.rs | 5 +-
.../server/scenarios/purge_delete_scenario.rs | 3 +-
.../stale_client_consumer_group_scenario.rs | 3 +-
.../tests/server/scenarios/user_scenario.rs | 9 +-
core/integration/tests/state/file.rs | 7 +-
core/integration/tests/state/system.rs | 10 +-
core/journal/src/lib.rs | 5 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/stm/user.rs | 5 +-
core/partitions/src/iggy_partition.rs | 51 ++-
core/partitions/src/iggy_partitions.rs | 54 +--
core/partitions/src/journal.rs | 394 +++++++++++++++++----
core/partitions/src/lib.rs | 35 +-
core/sdk/Cargo.toml | 2 +-
.../src/plotting/text => sdk/src/binary}/mod.rs | 3 +-
core/sdk/src/client_provider.rs | 9 +-
core/sdk/src/client_wrappers/binary_client.rs | 2 +-
.../src/client_wrappers/binary_cluster_client.rs | 2 +-
.../binary_consumer_group_client.rs | 2 +-
.../binary_consumer_offset_client.rs | 2 +-
.../src/client_wrappers/binary_message_client.rs | 2 +-
.../src/client_wrappers/binary_partition_client.rs | 2 +-
.../binary_personal_access_token_client.rs | 2 +-
.../src/client_wrappers/binary_segment_client.rs | 2 +-
.../src/client_wrappers/binary_stream_client.rs | 2 +-
.../src/client_wrappers/binary_system_client.rs | 2 +-
.../sdk/src/client_wrappers/binary_topic_client.rs | 2 +-
core/sdk/src/client_wrappers/binary_user_client.rs | 2 +-
core/sdk/src/clients/binary_cluster.rs | 2 +-
core/sdk/src/clients/binary_consumer_group.rs | 2 +-
core/sdk/src/clients/binary_consumer_offset.rs | 2 +-
core/sdk/src/clients/binary_message.rs | 2 +-
core/sdk/src/clients/binary_partitions.rs | 2 +-
.../src/clients/binary_personal_access_tokens.rs | 2 +-
core/sdk/src/clients/binary_segments.rs | 2 +-
core/sdk/src/clients/binary_streams.rs | 2 +-
core/sdk/src/clients/binary_system.rs | 2 +-
core/sdk/src/clients/binary_topics.rs | 2 +-
core/sdk/src/clients/binary_users.rs | 2 +-
core/sdk/src/clients/client.rs | 2 +-
core/sdk/src/clients/consumer.rs | 4 +-
core/sdk/src/clients/producer.rs | 2 +-
core/sdk/src/http/cluster.rs | 2 +-
core/sdk/src/http/consumer_groups.rs | 2 +-
core/sdk/src/http/consumer_offsets.rs | 2 +-
core/sdk/src/http/http_client.rs | 3 +-
core/sdk/src/http/messages.rs | 2 +-
core/sdk/src/http/partitions.rs | 2 +-
core/sdk/src/http/personal_access_tokens.rs | 5 +-
core/sdk/src/http/segments.rs | 2 +-
core/sdk/src/http/streams.rs | 2 +-
core/sdk/src/http/system.rs | 2 +-
core/sdk/src/http/topics.rs | 2 +-
core/sdk/src/http/users.rs | 11 +-
core/sdk/src/leader_aware.rs | 2 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/prelude.rs | 10 +-
core/sdk/src/quic/quic_client.rs | 48 +--
.../src/stream_builder/build/build_iggy_client.rs | 2 +-
core/sdk/src/tcp/tcp_client.rs | 46 +--
core/sdk/src/websocket/websocket_client.rs | 8 +-
core/server/Cargo.toml | 1 +
core/server/src/binary/command.rs | 8 +-
.../login_with_personal_access_token_handler.rs | 11 +-
.../binary/handlers/users/login_user_handler.rs | 3 +-
core/server/src/binary/macros.rs | 2 +-
core/server/src/http/mapper.rs | 3 +-
core/server/src/http/personal_access_tokens.rs | 7 +-
core/server/src/http/users.rs | 3 +-
core/server/src/shard/execution.rs | 17 +-
core/server/src/state/command.rs | 2 +-
core/server/src/state/models.rs | 2 +-
core/server/src/state/system.rs | 37 +-
core/simulator/src/deps.rs | 6 +-
.../consumer/GettingStartedConsumer.java | 8 +-
.../producer/GettingStartedProducer.java | 12 +-
.../consumer/MessageEnvelopeConsumer.java | 8 +-
.../producer/MessageEnvelopeProducer.java | 52 +--
.../consumer/MessageHeadersConsumer.java | 8 +-
.../producer/MessageHeadersProducer.java | 52 +--
.../multitenant/consumer/MultiTenantConsumer.java | 13 +-
.../multitenant/producer/MultiTenantProducer.java | 13 +-
.../sinkdataproducer/SinkDataProducer.java | 58 +--
.../iggy/examples/streambuilder/StreamBasic.java | 36 +-
.../examples/tcptls/consumer/TcpTlsConsumer.java | 8 +-
.../examples/tcptls/producer/TcpTlsProducer.java | 12 +-
foreign/cpp/.gitignore | 1 +
foreign/cpp/BUILD.bazel | 38 +-
foreign/cpp/Cargo.lock | 291 ---------------
foreign/cpp/Cargo.toml | 2 +
foreign/cpp/README.md | 10 +-
foreign/cpp/build.rs | 4 +
foreign/cpp/src/client.rs | 206 +++++++++++
foreign/cpp/src/identifier.rs | 63 ++++
foreign/cpp/src/lib.rs | 69 +++-
.../src/title.rs => foreign/cpp/src/stream.rs | 23 +-
.../src/title.rs => foreign/cpp/src/topic.rs | 26 +-
foreign/cpp/tests/client/low_level_e2e.cpp | 150 ++++++++
foreign/cpp/tests/common/test_helpers.hpp | 56 +++
foreign/cpp/tests/stream/low_level_e2e.cpp | 272 ++++++++++++++
foreign/cpp/tests/topic/low_level_e2e.cpp | 335 ++++++++++++++++++
foreign/cpp/tests/{test.cpp => unit_tests.cpp} | 0
foreign/java/BUILD_AND_TEST.md | 293 ---------------
foreign/java/gradle/libs.versions.toml | 12 +-
foreign/java/java-sdk/build.gradle.kts | 6 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 2 +-
.../blocking/tcp/ConsumerGroupsTcpClient.java | 53 +--
...cpClient.java => ConsumerOffsetsTcpClient.java} | 29 +-
.../iggy/client/blocking/tcp/FutureUtil.java} | 35 +-
.../iggy/client/blocking/tcp/IggyTcpClient.java | 95 ++---
.../client/blocking/tcp/IggyTcpClientBuilder.java | 59 +--
.../client/blocking/tcp/InternalTcpClient.java | 172 ---------
.../client/blocking/tcp/MessagesTcpClient.java | 61 +---
.../client/blocking/tcp/PartitionsTcpClient.java | 21 +-
.../tcp/PersonalAccessTokensTcpClient.java | 33 +-
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 42 +--
.../iggy/client/blocking/tcp/SystemTcpClient.java | 27 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 52 +--
.../iggy/client/blocking/tcp/UsersTcpClient.java | 94 +----
.../iggy/client/blocking/tcp/package-info.java | 9 +
281 files changed, 3070 insertions(+), 2227 deletions(-)
delete mode 100644 core/binary_protocol/src/client/binary_clients/mod.rs
delete mode 100644 core/binary_protocol/src/client/mod.rs
delete mode 100644 core/binary_protocol/src/utils/mod.rs
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_client/get_client.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_client/get_clients.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_client/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_cluster/get_cluster_metadata.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_cluster/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/create_consumer_group.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/delete_consumer_group.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/get_consumer_group.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/get_consumer_groups.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/get_consumer_offset.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/set_consumer_offset.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/common.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/get_contexts.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/use_context.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/flush_messages.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/poll_messages.rs (99%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/send_messages.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/create_partitions.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/delete_partitions.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/create_personal_access_token.rs
(93%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/delete_personal_access_tokens.rs
(96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/get_personal_access_tokens.rs
(97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_segments/delete_segments.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_segments/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/create_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/delete_stream.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/get_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/get_streams.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/purge_stream.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/update_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/login.rs (92%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/logout.rs (93%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_system/me.rs
(96%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_system/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/ping.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/session.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/snapshot.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/stats.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/create_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/delete_topic.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/get_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/get_topics.rs (98%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_topics/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/purge_topic.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/update_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/change_password.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/create_user.rs (77%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/delete_user.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/get_user.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/get_users.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_users/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/update_permissions.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/update_user.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/cli_command.rs (98%)
rename core/{binary_protocol/src/cli => cli/src/commands}/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/utils/login_session_expiry.rs (100%)
rename core/{binary_protocol/src/cli => cli/src/commands}/utils/mod.rs (100%)
copy {examples/rust => core/cli}/src/lib.rs (97%)
rename core/{binary_protocol/src/utils/auth.rs =>
common/src/traits/binary_auth.rs} (86%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/binary_client.rs (92%)
rename core/{binary_protocol/src/client/binary_cluster/mod.rs =>
common/src/traits/binary_impls/cluster.rs} (81%)
rename core/{binary_protocol/src/client/binary_consumer_groups/mod.rs =>
common/src/traits/binary_impls/consumer_groups.rs} (84%)
rename core/{binary_protocol/src/client/binary_consumer_offsets/mod.rs =>
common/src/traits/binary_impls/consumer_offsets.rs} (84%)
rename core/{binary_protocol/src/client/binary_messages/mod.rs =>
common/src/traits/binary_impls/messages.rs} (93%)
copy core/{bench/dashboard/frontend/src/components/tooltips =>
common/src/traits/binary_impls}/mod.rs (82%)
rename core/{binary_protocol/src/client/binary_partitions/mod.rs =>
common/src/traits/binary_impls/partitions.rs} (87%)
rename core/{binary_protocol/src/client/binary_personal_access_tokens/mod.rs
=> common/src/traits/binary_impls/personal_access_tokens.rs} (75%)
rename core/{binary_protocol/src/client/binary_segments/mod.rs =>
common/src/traits/binary_impls/segments.rs} (89%)
rename core/{binary_protocol/src/client/binary_streams/mod.rs =>
common/src/traits/binary_impls/streams.rs} (82%)
rename core/{binary_protocol/src/client/binary_system/mod.rs =>
common/src/traits/binary_impls/system.rs} (82%)
rename core/{binary_protocol/src/client/binary_topics/mod.rs =>
common/src/traits/binary_impls/topics.rs} (87%)
rename core/{binary_protocol/src/client/binary_users/mod.rs =>
common/src/traits/binary_impls/users.rs} (80%)
rename core/{binary_protocol/src/utils/mapper.rs =>
common/src/traits/binary_mapper.rs} (99%)
rename core/{binary_protocol/src/client/binary_transport/mod.rs =>
common/src/traits/binary_transport.rs} (94%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/cluster_client.rs (96%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/consumer_group_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/consumer_offset_client.rs (96%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/message_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/partition_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/personal_access_token_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/segment_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/stream_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/system_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/topic_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/user_client.rs (99%)
create mode 100644 core/common/src/utils/serde_secret.rs
copy core/{bench/report/src/plotting/text => sdk/src/binary}/mod.rs (93%)
delete mode 100644 foreign/cpp/Cargo.lock
create mode 100644 foreign/cpp/src/client.rs
create mode 100644 foreign/cpp/src/identifier.rs
copy core/bench/dashboard/shared/src/title.rs => foreign/cpp/src/stream.rs
(60%)
copy core/bench/dashboard/shared/src/title.rs => foreign/cpp/src/topic.rs (55%)
create mode 100644 foreign/cpp/tests/client/low_level_e2e.cpp
create mode 100644 foreign/cpp/tests/common/test_helpers.hpp
create mode 100644 foreign/cpp/tests/stream/low_level_e2e.cpp
create mode 100644 foreign/cpp/tests/topic/low_level_e2e.cpp
rename foreign/cpp/tests/{test.cpp => unit_tests.cpp} (100%)
delete mode 100644 foreign/java/BUILD_AND_TEST.md
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/{ConsumerOffsetTcpClient.java
=> ConsumerOffsetsTcpClient.java} (58%)
copy
foreign/java/java-sdk/src/{test/java/org/apache/iggy/client/blocking/tcp/UsersTcpClientTest.java
=> main/java/org/apache/iggy/client/blocking/tcp/FutureUtil.java} (50%)
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/InternalTcpClient.java
