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 003db4133 Merge branch 'master' into two_halves
add d21863011 docs(connectors): align MongoDB sink duplicate-key semantics
(#2941)
add 68abb6056 refactor(java): harden client lifecycle and streamline test
suite (#2959)
add b87a84f96 feat(rust): add wire protocol codec and types to
binary_protocol crate (#2946)
add 79103ee4b feat(server): add threads count and disk space to sysinfo
stats (#2917)
add c70ff9508 refactor(go): refactor WithTLS (#2957)
add a1045c3a3 fix(ci): prevent flaky keyring tests by keeping daemons
alive (#2963)
add 19387f303 feat(rust): add wire types for all commands and zero-copy
message primitives (#2962)
add 0102b50c3 fix(integration): reduce flakiness in connector integration
tests (#2966)
add eb63e5a7d Merge branch 'master' into two_halves
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 13 +-
.github/workflows/post-merge.yml | 11 +-
.typos.toml | 2 +
Cargo.lock | 6 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 2 +-
core/binary_protocol/Cargo.toml | 11 +-
core/binary_protocol/src/codec.rs | 226 +++++++
core/binary_protocol/src/codes.rs | 221 ++++++
core/binary_protocol/src/consensus/command.rs | 67 ++
core/binary_protocol/src/consensus/error.rs | 64 ++
.../src}/consensus/header.rs | 693 ++++++++-----------
core/binary_protocol/src/consensus/message.rs | 338 ++++++++++
core/binary_protocol/src/consensus/mod.rs | 54 ++
core/binary_protocol/src/consensus/operation.rs | 221 ++++++
core/binary_protocol/src/error.rs | 50 ++
.../binary_protocol/src/frame.rs | 39 +-
core/binary_protocol/src/lib.rs | 84 ++-
core/binary_protocol/src/message_layout.rs | 56 ++
core/binary_protocol/src/message_view.rs | 614 +++++++++++++++++
core/binary_protocol/src/primitives/consumer.rs | 133 ++++
core/binary_protocol/src/primitives/identifier.rs | 402 +++++++++++
.../src/primitives}/mod.rs | 8 +-
.../binary_protocol/src/primitives/partitioning.rs | 271 ++++++++
core/binary_protocol/src/primitives/permissions.rs | 471 +++++++++++++
.../src/primitives/polling_strategy.rs | 196 ++++++
.../consumer_groups/create_consumer_group.rs | 126 ++++
.../consumer_groups/delete_consumer_group.rs | 110 +++
.../requests/consumer_groups/get_consumer_group.rs | 110 +++
.../consumer_groups/get_consumer_groups.rs | 102 +++
.../consumer_groups/join_consumer_group.rs | 110 +++
.../consumer_groups/leave_consumer_group.rs | 110 +++
.../src/requests/consumer_groups/mod.rs} | 29 +-
.../consumer_offsets/delete_consumer_offset.rs | 175 +++++
.../consumer_offsets/get_consumer_offset.rs | 175 +++++
.../src/requests/consumer_offsets}/mod.rs | 8 +-
.../consumer_offsets/store_consumer_offset.rs | 180 +++++
.../src/requests/messages/flush_unsaved_buffer.rs | 155 +++++
.../src/requests}/messages/mod.rs | 6 +
.../src/requests/messages/poll_messages.rs | 220 ++++++
.../src/requests/messages/send_messages.rs | 750 +++++++++++++++++++++
.../src/requests}/mod.rs | 14 +-
.../src/requests/partitions/create_partitions.rs | 118 ++++
.../src/requests/partitions/delete_partitions.rs | 118 ++++
.../src/requests/partitions}/mod.rs | 6 +-
.../create_personal_access_token.rs | 115 ++++
.../delete_personal_access_token.rs | 82 +++
.../get_personal_access_tokens.rs | 53 ++
.../login_with_personal_access_token.rs | 82 +++
.../src/requests/personal_access_tokens}/mod.rs | 11 +-
.../src/requests/segments/delete_segments.rs | 128 ++++
.../src/requests/segments}/mod.rs | 4 +-
.../src/requests/streams/create_stream.rs | 96 +++
.../src/requests/streams/delete_stream.rs | 60 ++
.../src/requests/streams/get_stream.rs | 80 +++
.../src/requests/streams/get_streams.rs} | 46 +-
.../src/requests/streams}/mod.rs | 14 +-
.../src/requests/streams/purge_stream.rs | 60 ++
.../src/requests/streams/update_stream.rs | 81 +++
.../src/requests/system/get_client.rs | 96 +++
.../src/requests/system/get_clients.rs} | 46 +-
.../src/requests/system/get_cluster_metadata.rs | 53 ++
.../src/requests/system/get_me.rs} | 47 +-
.../src/requests/system/get_snapshot.rs | 47 +-
.../src/requests/system/get_stats.rs} | 47 +-
.../src/requests/system}/mod.rs | 17 +-
.../src/requests/system/ping.rs} | 47 +-
.../src/requests/topics/create_topic.rs | 147 ++++
.../src/requests/topics/delete_topic.rs | 98 +++
.../src/requests/topics/get_topic.rs | 98 +++
.../src/requests/topics/get_topics.rs | 71 ++
.../src/requests/topics}/mod.rs | 14 +-
.../src/requests/topics/purge_topic.rs | 86 +++
.../src/requests/topics/update_topic.rs | 150 +++++
.../src/requests/users/change_password.rs | 131 ++++
.../src/requests/users/create_user.rs | 203 ++++++
.../src/requests/users/delete_user.rs | 71 ++
.../binary_protocol/src/requests/users/get_user.rs | 80 +++
.../src/requests/users/get_users.rs} | 47 +-
.../src/requests/users/login_user.rs | 220 ++++++
.../src/requests/users/logout_user.rs} | 46 +-
.../src/requests/users}/mod.rs | 20 +-
.../src/requests/users/update_permissions.rs | 160 +++++
.../src/requests/users/update_user.rs | 184 +++++
.../src/responses/clients/client_response.rs | 211 ++++++
.../src/responses/clients/get_client.rs | 143 ++++
.../src/responses/clients/get_clients.rs | 98 +++
.../src/responses/clients}/mod.rs | 8 +-
.../consumer_groups/consumer_group_response.rs | 132 ++++
.../consumer_groups/create_consumer_group.rs} | 7 +-
.../consumer_groups/delete_consumer_group.rs} | 7 +-
.../consumer_groups/get_consumer_group.rs | 210 ++++++
.../consumer_groups/get_consumer_groups.rs | 109 +++
.../consumer_groups/join_consumer_group.rs} | 7 +-
.../consumer_groups/leave_consumer_group.rs} | 7 +-
.../src/responses/consumer_groups/mod.rs | 39 +-
.../consumer_offsets/delete_consumer_offset.rs} | 7 +-
.../consumer_offsets/get_consumer_offset.rs | 114 ++++
.../src/responses/consumer_offsets}/mod.rs | 9 +-
.../consumer_offsets/store_consumer_offset.rs} | 7 +-
.../src/responses}/messages/mod.rs | 4 +-
.../src/responses/messages/poll_messages.rs | 176 +++++
.../src/responses/mod.rs} | 42 +-
.../create_personal_access_token.rs | 80 +++
.../delete_personal_access_token.rs} | 2 +-
.../get_personal_access_tokens.rs | 145 ++++
.../login_with_personal_access_token.rs} | 6 +-
.../src/responses/personal_access_tokens}/mod.rs | 20 +-
.../src/responses/streams/create_stream.rs} | 13 +-
.../src/responses/streams/delete_stream.rs} | 7 +-
.../src/responses/streams/get_stream.rs | 232 +++++++
.../src/responses/streams/get_streams.rs | 103 +++
.../src/responses/streams}/mod.rs | 18 +-
.../src/responses/streams/purge_stream.rs} | 7 +-
.../src/responses/streams/stream_response.rs | 142 ++++
.../src/responses/streams/update_stream.rs} | 7 +-
.../src/responses/system/get_stats.rs | 427 ++++++++++++
.../src/responses/system}/mod.rs | 7 +-
.../src/responses/system/ping.rs} | 2 +-
.../src/responses/topics/create_topic.rs} | 7 +-
.../src/responses/topics/delete_topic.rs} | 7 +-
.../src/responses/topics/get_topic.rs | 234 +++++++
.../src/responses/topics/get_topics.rs | 115 ++++
.../src/responses/topics}/mod.rs | 16 +-
.../src/responses/topics/purge_topic.rs} | 7 +-
.../src/responses/topics/update_topic.rs} | 7 +-
.../src/responses/users/change_password.rs} | 2 +-
.../src/responses/users/create_user.rs} | 2 +-
.../src/responses/users/delete_user.rs} | 2 +-
.../src/responses/users/get_user.rs | 205 ++++++
.../src/responses/users/get_users.rs | 97 +++
.../src/responses/users/login_user.rs | 75 +++
.../src/responses/users/logout_user.rs} | 2 +-
.../binary_protocol/src/responses/users/mod.rs | 42 +-
.../src/responses/users/update_permissions.rs} | 2 +-
.../src/responses/users/update_user.rs} | 2 +-
.../src/responses/users/user_response.rs | 132 ++++
core/cli/src/commands/binary_system/stats.rs | 23 +
core/common/src/traits/binary_mapper.rs | 38 ++
core/common/src/types/stats/mod.rs | 9 +
core/connectors/sinks/mongodb_sink/README.md | 9 +-
.../src/harness/handle/connectors_runtime.rs | 16 +-
core/integration/src/harness/handle/mcp.rs | 12 +-
.../tests/cli/system/test_stats_command.rs | 130 +++-
core/integration/tests/connectors/mongodb/mod.rs | 2 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 2 +-
core/server/src/binary/mapper.rs | 4 +
core/server/src/shard/system/stats.rs | 21 +
.../src/shard/tasks/periodic/sysinfo_printer.rs | 12 +-
examples/go/getting-started/consumer/main.go | 7 +-
examples/go/getting-started/producer/main.go | 7 +-
foreign/go/client/tcp/tcp_core.go | 84 ++-
foreign/go/tests/tls_test.go | 15 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 6 +
.../async/tcp/AsyncIggyTcpClientBuilder.java | 17 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 26 +-
.../iggy/client/async/tcp/SystemTcpClient.java | 2 +-
.../iggy/client/blocking/http/IggyHttpClient.java | 6 +
.../blocking/http/IggyHttpClientBuilder.java | 14 +-
.../client/blocking/http/MessagesHttpClient.java | 4 +-
.../client/blocking/tcp/IggyTcpClientBuilder.java | 15 +-
.../client/async/AsyncClientIntegrationTest.java | 732 +++++---------------
.../iggy/client/async/AsyncConsumerGroupsTest.java | 343 +++-------
.../iggy/client/async/AsyncPollMessageTest.java | 333 ---------
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 79 +++
.../iggy/client/async/tcp/UsersTcpClientTest.java | 239 -------
.../blocking/ConsumerGroupsClientBaseTest.java | 2 +-
.../client/blocking/MessagesClientBaseTest.java | 82 +++
.../iggy/client/blocking/SystemClientBaseTest.java | 21 +
.../iggy/client/blocking/UsersClientBaseTest.java | 64 +-
.../blocking/tcp/IggyTcpClientBuilderTest.java | 68 ++
170 files changed, 13617 insertions(+), 2351 deletions(-)
create mode 100644 core/binary_protocol/src/codec.rs
create mode 100644 core/binary_protocol/src/codes.rs
create mode 100644 core/binary_protocol/src/consensus/command.rs
create mode 100644 core/binary_protocol/src/consensus/error.rs
copy core/{common/src/types => binary_protocol/src}/consensus/header.rs (57%)
create mode 100644 core/binary_protocol/src/consensus/message.rs
create mode 100644 core/binary_protocol/src/consensus/mod.rs
create mode 100644 core/binary_protocol/src/consensus/operation.rs
create mode 100644 core/binary_protocol/src/error.rs
copy bdd/go/tests/suite_test.go => core/binary_protocol/src/frame.rs (56%)
create mode 100644 core/binary_protocol/src/message_layout.rs
create mode 100644 core/binary_protocol/src/message_view.rs
create mode 100644 core/binary_protocol/src/primitives/consumer.rs
create mode 100644 core/binary_protocol/src/primitives/identifier.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/primitives}/mod.rs (82%)
create mode 100644 core/binary_protocol/src/primitives/partitioning.rs
create mode 100644 core/binary_protocol/src/primitives/permissions.rs
create mode 100644 core/binary_protocol/src/primitives/polling_strategy.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/create_consumer_group.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/delete_consumer_group.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/get_consumer_group.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/get_consumer_groups.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/join_consumer_group.rs
create mode 100644
core/binary_protocol/src/requests/consumer_groups/leave_consumer_group.rs
copy core/{bench/dashboard/frontend/src/components/layout/logo.rs =>
binary_protocol/src/requests/consumer_groups/mod.rs} (63%)
create mode 100644
core/binary_protocol/src/requests/consumer_offsets/delete_consumer_offset.rs
create mode 100644
core/binary_protocol/src/requests/consumer_offsets/get_consumer_offset.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/consumer_offsets}/mod.rs (75%)
create mode 100644
core/binary_protocol/src/requests/consumer_offsets/store_consumer_offset.rs
create mode 100644
core/binary_protocol/src/requests/messages/flush_unsaved_buffer.rs
copy core/{common/src/commands =>
binary_protocol/src/requests}/messages/mod.rs (80%)
create mode 100644 core/binary_protocol/src/requests/messages/poll_messages.rs
create mode 100644 core/binary_protocol/src/requests/messages/send_messages.rs
copy core/{bench/dashboard/frontend/src/components/tooltips =>
binary_protocol/src/requests}/mod.rs (79%)
create mode 100644
core/binary_protocol/src/requests/partitions/create_partitions.rs
create mode 100644
core/binary_protocol/src/requests/partitions/delete_partitions.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/partitions}/mod.rs (83%)
create mode 100644
core/binary_protocol/src/requests/personal_access_tokens/create_personal_access_token.rs
create mode 100644
core/binary_protocol/src/requests/personal_access_tokens/delete_personal_access_token.rs
create mode 100644
core/binary_protocol/src/requests/personal_access_tokens/get_personal_access_tokens.rs
create mode 100644
core/binary_protocol/src/requests/personal_access_tokens/login_with_personal_access_token.rs
copy core/{bench/dashboard/server/src/github =>
binary_protocol/src/requests/personal_access_tokens}/mod.rs (64%)
create mode 100644
core/binary_protocol/src/requests/segments/delete_segments.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/segments}/mod.rs (91%)
create mode 100644 core/binary_protocol/src/requests/streams/create_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/delete_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/get_stream.rs
copy core/{common/src/sharding/local_idx.rs =>
binary_protocol/src/requests/streams/get_streams.rs} (51%)
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/streams}/mod.rs (67%)
create mode 100644 core/binary_protocol/src/requests/streams/purge_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/update_stream.rs
create mode 100644 core/binary_protocol/src/requests/system/get_client.rs
copy core/{common/src/sharding/local_idx.rs =>
binary_protocol/src/requests/system/get_clients.rs} (51%)
create mode 100644
core/binary_protocol/src/requests/system/get_cluster_metadata.rs
copy core/{common/src/types/consumer/consumer_offsets.rs =>
binary_protocol/src/requests/system/get_me.rs} (52%)
copy foreign/csharp/Iggy_SDK/JsonConverters/TimeSpanConverter.cs =>
core/binary_protocol/src/requests/system/get_snapshot.rs (54%)
copy core/{common/src/types/consumer/consumer_offsets.rs =>
binary_protocol/src/requests/system/get_stats.rs} (51%)
copy core/{bench/dashboard/server/src/github =>
binary_protocol/src/requests/system}/mod.rs (66%)
copy core/{common/src/types/consumer/consumer_offsets.rs =>
binary_protocol/src/requests/system/ping.rs} (52%)
create mode 100644 core/binary_protocol/src/requests/topics/create_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/delete_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/get_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/get_topics.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/topics}/mod.rs (68%)
create mode 100644 core/binary_protocol/src/requests/topics/purge_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/update_topic.rs
create mode 100644 core/binary_protocol/src/requests/users/change_password.rs
create mode 100644 core/binary_protocol/src/requests/users/create_user.rs
create mode 100644 core/binary_protocol/src/requests/users/delete_user.rs
create mode 100644 core/binary_protocol/src/requests/users/get_user.rs
copy core/{common/src/types/consumer/consumer_offsets.rs =>
binary_protocol/src/requests/users/get_users.rs} (51%)
create mode 100644 core/binary_protocol/src/requests/users/login_user.rs
copy core/{common/src/sharding/local_idx.rs =>
binary_protocol/src/requests/users/logout_user.rs} (51%)
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/requests/users}/mod.rs (58%)
create mode 100644
core/binary_protocol/src/requests/users/update_permissions.rs
create mode 100644 core/binary_protocol/src/requests/users/update_user.rs
create mode 100644
core/binary_protocol/src/responses/clients/client_response.rs
create mode 100644 core/binary_protocol/src/responses/clients/get_client.rs
create mode 100644 core/binary_protocol/src/responses/clients/get_clients.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/responses/clients}/mod.rs (78%)
create mode 100644
core/binary_protocol/src/responses/consumer_groups/consumer_group_response.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_groups/create_consumer_group.rs} (88%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_groups/delete_consumer_group.rs} (88%)
create mode 100644
core/binary_protocol/src/responses/consumer_groups/get_consumer_group.rs
create mode 100644
core/binary_protocol/src/responses/consumer_groups/get_consumer_groups.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_groups/join_consumer_group.rs} (88%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_groups/leave_consumer_group.rs} (88%)
copy bdd/go/tests/tcp_test/session_feature_logout.go =>
core/binary_protocol/src/responses/consumer_groups/mod.rs (55%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_offsets/delete_consumer_offset.rs} (88%)
create mode 100644
core/binary_protocol/src/responses/consumer_offsets/get_consumer_offset.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/responses/consumer_offsets}/mod.rs (73%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/consumer_offsets/store_consumer_offset.rs} (88%)
copy core/{common/src/commands =>
binary_protocol/src/responses}/messages/mod.rs (91%)
create mode 100644 core/binary_protocol/src/responses/messages/poll_messages.rs
copy core/{common/src/sharding/shard_id.rs =>
binary_protocol/src/responses/mod.rs} (55%)
create mode 100644
core/binary_protocol/src/responses/personal_access_tokens/create_personal_access_token.rs
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/personal_access_tokens/delete_personal_access_token.rs}
(92%)
create mode 100644
core/binary_protocol/src/responses/personal_access_tokens/get_personal_access_tokens.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/personal_access_tokens/login_with_personal_access_token.rs}
(89%)
copy core/{common/src/sharding =>
binary_protocol/src/responses/personal_access_tokens}/mod.rs (61%)
copy core/{bench/dashboard/frontend/src/components/selectors/mod.rs =>
binary_protocol/src/responses/streams/create_stream.rs} (74%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/streams/delete_stream.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/streams/get_stream.rs
create mode 100644 core/binary_protocol/src/responses/streams/get_streams.rs
copy core/{bench/dashboard/server/src/github =>
binary_protocol/src/responses/streams}/mod.rs (62%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/streams/purge_stream.rs} (89%)
create mode 100644
core/binary_protocol/src/responses/streams/stream_response.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/streams/update_stream.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/system/get_stats.rs
copy core/{bench/dashboard/frontend/src/hooks =>
binary_protocol/src/responses/system}/mod.rs (86%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/system/ping.rs} (94%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/topics/create_topic.rs} (89%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/topics/delete_topic.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/topics/get_topic.rs
create mode 100644 core/binary_protocol/src/responses/topics/get_topics.rs
copy core/{bench/dashboard/server/src/github =>
binary_protocol/src/responses/topics}/mod.rs (66%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/topics/purge_topic.rs} (90%)
copy core/{bench/dashboard/frontend/src/state/mod.rs =>
binary_protocol/src/responses/topics/update_topic.rs} (89%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/change_password.rs} (93%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/create_user.rs} (93%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/delete_user.rs} (93%)
create mode 100644 core/binary_protocol/src/responses/users/get_user.rs
create mode 100644 core/binary_protocol/src/responses/users/get_users.rs
create mode 100644 core/binary_protocol/src/responses/users/login_user.rs
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/logout_user.rs} (93%)
copy foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs =>
core/binary_protocol/src/responses/users/mod.rs (56%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/update_permissions.rs} (93%)
copy core/{common/src/types/client/mod.rs =>
binary_protocol/src/responses/users/update_user.rs} (93%)
create mode 100644 core/binary_protocol/src/responses/users/user_response.rs
delete mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/AsyncPollMessageTest.java
delete mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/UsersTcpClientTest.java
