This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch skipping-offset
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard fb6d7bfdb Merge branch 'master' into skipping-offset
discard 513a6e342 Merge branch 'master' into skipping-offset
discard 1d05ba5ab fix(server): prevent consumer offset skip during concurrent
produce+consume
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 b45254f2d docs(go): solve typo in DeleteStream method. (#2972)
add 34280ab7b fix(sdk): fix broken Windows build for SDK and CLI (#2971)
add 9c8b5cc6c feat(bdd): add --coverage flag to run-bdd-tests.sh for all
SDKs (#2950)
add b72fa14a6 fix(server): prevent consumer offset skip during
produce+consume and after restart
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (fb6d7bfdb)
\
N -- N -- N refs/heads/skipping-offset (b72fa14a6)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 20 +-
.github/config/components.yml | 24 +-
.github/workflows/_test.yml | 1 +
.github/workflows/post-merge.yml | 11 +-
.typos.toml | 4 +-
Cargo.lock | 14 +-
Cargo.toml | 8 +-
DEPENDENCIES.md | 8 +-
bdd/docker-compose.coverage.yml | 91 +++
bdd/java/build.gradle.kts | 7 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 2 +-
bdd/python/pyproject.toml | 1 +
bdd/python/uv.lock | 142 +++-
core/binary_protocol/Cargo.toml | 13 +-
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/Cargo.toml | 2 +-
core/cli/src/commands/binary_system/stats.rs | 23 +
core/common/Cargo.toml | 2 +-
core/common/src/traits/binary_mapper.rs | 38 ++
core/common/src/types/segment.rs | 29 +-
.../src/types/segment_storage/messages_reader.rs | 4 +-
core/common/src/types/stats/mod.rs | 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 +-
core/integration/tests/server/message_cleanup.rs | 7 +
.../concurrent_produce_consume_scenario.rs | 196 ++++++
.../server/scenarios/message_cleanup_scenario.rs | 140 ++++
core/integration/tests/server/scenarios/mod.rs | 1 +
core/sdk/Cargo.toml | 2 +-
core/server/src/binary/mapper.rs | 4 +
core/server/src/bootstrap.rs | 2 +-
core/server/src/shard/mod.rs | 13 +-
core/server/src/shard/system/segments.rs | 12 +-
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 +-
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 3 +-
foreign/go/client/tcp/tcp_core.go | 84 ++-
foreign/go/contracts/client.go | 4 +-
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 ++
foreign/python/Cargo.toml | 2 +-
scripts/run-bdd-tests.sh | 30 +-
192 files changed, 14318 insertions(+), 2389 deletions(-)
create mode 100644 bdd/docker-compose.coverage.yml
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
create mode 100644
core/integration/tests/server/scenarios/concurrent_produce_consume_scenario.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
