This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch io_uring_tpc
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard 7bb27bde begin shard init
discard 1f831d97 feat(io_uring): load server_config (#1798)
omit 8507c732 feat(io_uring): bootstrap the main function (#1788)
omit 5cb4a07a initial setup and migration of shards
add 50fd0af0 chore(repo): update Rust edition to 2024 across multiple
Cargo.toml files (#1772)
add ff9bf2fc chore(sdk): Initial commit with existing
iggy-rs/iggy-cpp-client code (#1775)
add ec96f35d chore(test): improve consumption message log (#1780)
add 9d3608d6 chore(ci): add CI pipeline for java-sdk (#1782)
add 22fd92c1 feat(js): implement new zero copy message format for send &
poll (#1757)
add 1a2058b0 chore(sdk): refactor prelude package reference (#1783)
add f272171d chore(sdk): Add type safety to CommandCode (#1751)
add 679efb7b chore(sdk): update group and version for java-sdk (#1786)
add e977417e chore(sdk): Add checkstyle support (#1753)
add 926fc4f7 fix(test): Fix error logging in integration sample tests
(#1791)
add bb97a3b3 chore(repo): fix clippy lints for Rust 1.87 (#1800)
new f930cd3b initial setup and migration of shards
new 03520660 feat(io_uring): bootstrap the main function (#1788)
new 3dd41328 feat(io_uring): load server_config (#1798)
new 4de68be9 begin shard init
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 (7bb27bde)
\
N -- N -- N refs/heads/io_uring_tpc (4de68be9)
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.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/changed-files-config.json | 6 +
.github/workflows/ci-check-java-sdk.yml | 81 +
.github/workflows/ci-check-pr.yml | 8 +
.gitignore | 7 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
.../frontend/src/components/app_content.rs | 8 +-
.../frontend/src/components/chart/plot_trend.rs | 2 +-
.../frontend/src/components/chart/single_chart.rs | 2 +-
.../frontend/src/components/chart/trend_chart.rs | 2 +-
.../frontend/src/components/layout/main_content.rs | 2 +-
.../frontend/src/components/layout/sidebar.rs | 4 +-
.../frontend/src/components/layout/topbar.rs | 2 +-
.../src/components/selectors/benchmark_selector.rs | 2 +-
.../src/components/selectors/hardware_selector.rs | 2 +-
.../src/components/selectors/view_mode_selector.rs | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/dashboard/server/Dockerfile | 2 +-
core/bench/dashboard/server/src/args.rs | 2 +-
core/bench/dashboard/server/src/github/client.rs | 4 +-
core/bench/dashboard/server/src/handlers.rs | 4 +-
core/bench/dashboard/server/src/main.rs | 5 +-
core/bench/dashboard/shared/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/bench/report/src/plotting/chart.rs | 2 +-
core/bench/runner/Cargo.toml | 2 +-
.../bench/runner/src/app/local_benchmark_runner.rs | 2 +-
core/bench/runner/src/main.rs | 2 +-
core/bench/src/actors/consumer.rs | 9 +-
core/bench/src/actors/producer.rs | 2 +-
core/bench/src/actors/producing_consumer.rs | 29 +-
core/bench/src/analytics/metrics/group.rs | 2 +-
core/bench/src/analytics/metrics/individual.rs | 2 +-
.../time_series/calculators/throughput.rs | 2 +-
core/bench/src/args/common.rs | 3 +-
.../src/args/kinds/balanced/consumer_group.rs | 2 +-
core/bench/src/args/kinds/balanced/producer.rs | 2 +-
.../kinds/balanced/producer_and_consumer_group.rs | 2 +-
.../args/kinds/end_to_end/producing_consumer.rs | 2 +-
.../kinds/end_to_end/producing_consumer_group.rs | 2 +-
core/bench/src/args/kinds/pinned/consumer.rs | 2 +-
core/bench/src/args/kinds/pinned/producer.rs | 2 +-
.../src/args/kinds/pinned/producer_and_consumer.rs | 2 +-
.../src/benchmarks/balanced_consumer_group.rs | 4 +-
core/bench/src/benchmarks/balanced_producer.rs | 4 +-
.../balanced_producer_and_consumer_group.rs | 4 +-
core/bench/src/benchmarks/benchmark.rs | 8 +-
core/bench/src/benchmarks/common.rs | 6 +-
.../benchmarks/end_to_end_producing_consumer.rs | 4 +-
core/bench/src/benchmarks/pinned_producer.rs | 7 +-
.../src/benchmarks/pinned_producer_and_consumer.rs | 4 +-
core/bench/src/main.rs | 2 +-
core/bench/src/plot.rs | 9 +-
core/bench/src/runner.rs | 2 +-
core/bench/src/utils/batch_generator.rs | 8 +-
core/bench/src/utils/finish_condition.rs | 2 +-
core/bench/src/utils/rate_limiter.rs | 2 +-
core/bench/src/utils/server_starter.rs | 8 +-
core/binary_protocol/Cargo.toml | 2 +-
.../src/cli/binary_client/get_client.rs | 6 +-
.../src/cli/binary_client/get_clients.rs | 4 +-
.../create_consumer_group.rs | 6 +-
.../delete_consumer_group.rs | 6 +-
.../binary_consumer_groups/get_consumer_group.rs | 8 +-
.../binary_consumer_groups/get_consumer_groups.rs | 6 +-
.../binary_consumer_offsets/get_consumer_offset.rs | 4 +-
.../binary_consumer_offsets/set_consumer_offset.rs | 6 +-
.../src/cli/binary_context/common.rs | 7 +-
.../src/cli/binary_context/get_contexts.rs | 4 +-
.../src/cli/binary_context/use_context.rs | 4 +-
.../src/cli/binary_message/flush_messages.rs | 4 +-
.../src/cli/binary_message/poll_messages.rs | 4 +-
.../src/cli/binary_message/send_messages.rs | 4 +-
.../src/cli/binary_partitions/create_partitions.rs | 6 +-
.../src/cli/binary_partitions/delete_partitions.rs | 6 +-
.../create_personal_access_token.rs | 6 +-
.../delete_personal_access_tokens.rs | 4 +-
.../get_personal_access_tokens.rs | 4 +-
.../src/cli/binary_segments/delete_segments.rs | 6 +-
.../src/cli/binary_streams/create_stream.rs | 4 +-
.../src/cli/binary_streams/delete_stream.rs | 6 +-
.../src/cli/binary_streams/get_stream.rs | 6 +-
.../src/cli/binary_streams/get_streams.rs | 4 +-
.../src/cli/binary_streams/purge_stream.rs | 6 +-
.../src/cli/binary_streams/update_stream.rs | 6 +-
.../binary_protocol/src/cli/binary_system/login.rs | 4 +-
.../src/cli/binary_system/logout.rs | 4 +-
core/binary_protocol/src/cli/binary_system/me.rs | 4 +-
core/binary_protocol/src/cli/binary_system/ping.rs | 6 +-
.../src/cli/binary_system/snapshot.rs | 4 +-
.../binary_protocol/src/cli/binary_system/stats.rs | 4 +-
.../src/cli/binary_topics/create_topic.rs | 4 +-
.../src/cli/binary_topics/delete_topic.rs | 6 +-
.../src/cli/binary_topics/get_topic.rs | 6 +-
.../src/cli/binary_topics/get_topics.rs | 4 +-
.../src/cli/binary_topics/purge_topic.rs | 6 +-
.../src/cli/binary_topics/update_topic.rs | 4 +-
.../src/cli/binary_users/change_password.rs | 6 +-
.../src/cli/binary_users/create_user.rs | 6 +-
.../src/cli/binary_users/delete_user.rs | 6 +-
.../src/cli/binary_users/get_user.rs | 6 +-
.../src/cli/binary_users/get_users.rs | 4 +-
.../src/cli/binary_users/update_permissions.rs | 4 +-
.../src/cli/binary_users/update_user.rs | 6 +-
.../src/client/binary_clients/binary_client.rs | 2 +-
.../src/client/binary_consumer_offsets/mod.rs | 2 +-
.../src/client/binary_messages/mod.rs | 4 +-
.../src/client/binary_segments/mod.rs | 2 +-
core/cli/Cargo.toml | 2 +-
core/cli/src/args/mod.rs | 2 +-
core/cli/src/args/topic.rs | 5 +-
core/cli/src/args/user.rs | 2 +-
core/cli/src/credentials.rs | 14 +-
core/cli/src/main.rs | 9 +-
core/common/Cargo.toml | 2 +-
.../consumer_groups/create_consumer_group.rs | 4 +-
.../consumer_groups/delete_consumer_group.rs | 2 +-
.../commands/consumer_groups/get_consumer_group.rs | 2 +-
.../consumer_groups/get_consumer_groups.rs | 2 +-
.../consumer_groups/join_consumer_group.rs | 2 +-
.../consumer_groups/leave_consumer_group.rs | 2 +-
.../consumer_offsets/delete_consumer_offset.rs | 2 +-
.../consumer_offsets/get_consumer_offset.rs | 2 +-
.../consumer_offsets/store_consumer_offset.rs | 2 +-
.../src/commands/messages/flush_unsaved_buffer.rs | 9 +-
core/common/src/commands/messages/poll_messages.rs | 6 +-
core/common/src/commands/messages/send_messages.rs | 8 +-
.../src/commands/partitions/create_partitions.rs | 4 +-
.../src/commands/partitions/delete_partitions.rs | 2 +-
.../create_personal_access_token.rs | 6 +-
.../delete_personal_access_token.rs | 4 +-
.../get_personal_access_tokens.rs | 2 +-
.../login_with_personal_access_token.rs | 4 +-
.../src/commands/segments/delete_segments.rs | 2 +-
core/common/src/commands/streams/create_stream.rs | 4 +-
core/common/src/commands/streams/delete_stream.rs | 2 +-
core/common/src/commands/streams/get_stream.rs | 2 +-
core/common/src/commands/streams/get_streams.rs | 2 +-
core/common/src/commands/streams/purge_stream.rs | 2 +-
core/common/src/commands/streams/update_stream.rs | 2 +-
core/common/src/commands/system/get_client.rs | 2 +-
core/common/src/commands/system/get_clients.rs | 2 +-
core/common/src/commands/system/get_me.rs | 2 +-
core/common/src/commands/system/get_snapshot.rs | 2 +-
core/common/src/commands/system/get_stats.rs | 2 +-
core/common/src/commands/system/ping.rs | 2 +-
core/common/src/commands/topics/create_topic.rs | 8 +-
core/common/src/commands/topics/delete_topic.rs | 2 +-
core/common/src/commands/topics/get_topic.rs | 2 +-
core/common/src/commands/topics/get_topics.rs | 2 +-
core/common/src/commands/topics/purge_topic.rs | 2 +-
core/common/src/commands/topics/update_topic.rs | 6 +-
core/common/src/commands/users/change_password.rs | 4 +-
core/common/src/commands/users/create_user.rs | 4 +-
core/common/src/commands/users/delete_user.rs | 2 +-
core/common/src/commands/users/get_user.rs | 2 +-
core/common/src/commands/users/get_users.rs | 2 +-
core/common/src/commands/users/login_user.rs | 2 +-
core/common/src/commands/users/logout_user.rs | 2 +-
.../src/commands/users/update_permissions.rs | 2 +-
core/common/src/commands/users/update_user.rs | 2 +-
core/common/src/error/iggy_error.rs | 30 +-
core/common/src/traits/partitioner.rs | 2 +-
core/common/src/types/command/mod.rs | 2 +-
.../src/types/compression/compression_algorithm.rs | 2 +-
core/common/src/types/consumer/consumer_kind.rs | 4 +-
core/common/src/types/consumer/mod.rs | 4 +-
core/common/src/types/identifier/mod.rs | 4 +-
core/common/src/types/message/iggy_message.rs | 10 +-
core/common/src/types/message/indexes.rs | 2 +-
core/common/src/types/message/message_header.rs | 2 +-
.../src/types/message/message_header_view.rs | 10 +-
core/common/src/types/message/message_view.rs | 6 +-
core/common/src/types/message/messages_batch.rs | 4 +-
core/common/src/types/message/mod.rs | 10 +-
core/common/src/types/message/partitioning.rs | 2 +-
core/common/src/types/message/polled_messages.rs | 2 +-
core/common/src/types/message/polling_strategy.rs | 4 +-
core/common/src/types/message/user_headers.rs | 2 +-
.../src/types/permissions/permissions_global.rs | 4 +-
core/common/src/types/topic/mod.rs | 4 +-
core/common/src/types/user/user_info.rs | 2 +-
core/common/src/utils/crypto.rs | 2 +-
core/common/src/utils/duration.rs | 2 +-
core/common/src/utils/expiry.rs | 4 +-
core/common/src/utils/text.rs | 2 +-
core/common/src/utils/timestamp.rs | 2 +-
core/common/src/utils/topic_size.rs | 2 +-
core/examples/Cargo.toml | 2 +-
core/examples/src/multi-tenant/consumer/main.rs | 18 +-
core/examples/src/multi-tenant/producer/main.rs | 7 +-
core/examples/src/new-sdk/consumer/main.rs | 14 +-
core/examples/src/shared/messages_generator.rs | 2 +-
core/examples/src/shared/stream.rs | 7 +-
core/examples/src/shared/system.rs | 10 +-
core/integration/Cargo.toml | 2 +-
core/integration/src/tcp_client.rs | 4 +-
core/integration/src/test_server.rs | 7 +-
core/integration/tests/archiver/s3.rs | 2 +-
core/integration/tests/bench/mod.rs | 2 +-
.../tests/cli/client/test_client_help_command.rs | 2 +-
.../tests/cli/client/test_client_list_command.rs | 2 +-
core/integration/tests/cli/common/mod.rs | 4 +-
.../test_consumer_group_create_command.rs | 17 +-
.../test_consumer_group_delete_command.rs | 10 +-
.../test_consumer_group_get_command.rs | 4 +-
.../test_consumer_group_help_command.rs | 2 +-
.../test_consumer_group_list_command.rs | 4 +-
.../test_consumer_offset_get_command.rs | 9 +-
.../test_consumer_offset_set_command.rs | 4 +-
core/integration/tests/cli/context/common.rs | 2 +-
.../tests/cli/context/test_context_list_command.rs | 2 +-
.../tests/cli/context/test_context_use_command.rs | 2 +-
.../tests/cli/general/test_help_command.rs | 2 +-
.../tests/cli/general/test_overview_command.rs | 2 +-
.../cli/message/test_message_flush_command.rs | 8 +-
.../tests/cli/message/test_message_help_command.rs | 2 +-
.../tests/cli/message/test_message_poll_command.rs | 10 +-
.../message/test_message_poll_to_file_command.rs | 6 +-
.../tests/cli/message/test_message_send_command.rs | 10 +-
.../cli/partition/test_partition_create_command.rs | 10 +-
.../cli/partition/test_partition_delete_command.rs | 10 +-
.../cli/partition/test_partition_help_command.rs | 2 +-
.../test_pat_create_command.rs | 10 +-
.../test_pat_delete_command.rs | 6 +-
.../personal_access_token/test_pat_help_command.rs | 2 +-
.../personal_access_token/test_pat_list_command.rs | 2 +-
.../tests/cli/stream/test_stream_delete_command.rs | 2 +-
.../tests/cli/stream/test_stream_get_command.rs | 2 +-
.../tests/cli/stream/test_stream_help_command.rs | 2 +-
.../tests/cli/stream/test_stream_list_command.rs | 2 +-
.../tests/cli/stream/test_stream_purge_command.rs | 2 +-
.../tests/cli/stream/test_stream_update_command.rs | 12 +-
.../tests/cli/system/test_ping_command.rs | 2 +-
.../tests/cli/system/test_stats_command.rs | 2 +-
.../tests/cli/topic/test_topic_create_command.rs | 2 +-
.../tests/cli/topic/test_topic_delete_command.rs | 10 +-
.../tests/cli/topic/test_topic_get_command.rs | 4 +-
.../tests/cli/topic/test_topic_help_command.rs | 2 +-
.../tests/cli/topic/test_topic_list_command.rs | 4 +-
.../tests/cli/topic/test_topic_purge_command.rs | 10 +-
.../tests/cli/topic/test_topic_update_command.rs | 10 +-
.../tests/cli/user/test_login_options.rs | 2 +-
.../tests/cli/user/test_user_create_command.rs | 2 +-
.../tests/cli/user/test_user_delete_command.rs | 2 +-
.../tests/cli/user/test_user_get_command.rs | 2 +-
.../tests/cli/user/test_user_help_command.rs | 2 +-
.../tests/cli/user/test_user_list_command.rs | 2 +-
.../tests/cli/user/test_user_name_command.rs | 8 +-
.../tests/cli/user/test_user_password_command.rs | 5 +-
.../cli/user/test_user_permissions_command.rs | 5 +-
.../tests/cli/user/test_user_status_command.rs | 15 +-
core/integration/tests/config_provider/mod.rs | 46 +-
.../data_integrity/verify_after_server_restart.rs | 6 +-
core/integration/tests/examples/mod.rs | 9 +-
core/integration/tests/mod.rs | 2 +-
.../scenarios/consumer_group_join_scenario.rs | 7 +-
...h_multiple_clients_polling_messages_scenario.rs | 10 +-
...with_single_client_polling_messages_scenario.rs | 10 +-
.../server/scenarios/create_message_payload.rs | 14 +-
.../server/scenarios/message_headers_scenario.rs | 18 +-
.../server/scenarios/message_size_scenario.rs | 10 +-
core/integration/tests/server/scenarios/mod.rs | 2 +-
.../scenarios/stream_size_validation_scenario.rs | 4 +-
.../tests/server/scenarios/system_scenario.rs | 8 +-
.../tests/server/scenarios/user_scenario.rs | 6 +-
core/integration/tests/state/file.rs | 2 +-
core/integration/tests/state/system.rs | 2 +-
core/integration/tests/streaming/get_by_offset.rs | 8 +-
.../tests/streaming/get_by_timestamp.rs | 8 +-
core/integration/tests/streaming/messages.rs | 2 +-
core/integration/tests/streaming/partition.rs | 6 +-
core/integration/tests/streaming/segment.rs | 39 +-
core/integration/tests/streaming/topic.rs | 2 +-
core/integration/tests/streaming/topic_messages.rs | 2 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 85 +-
core/sdk/src/clients/producer.rs | 8 +-
core/sdk/src/http/binary_consumer_groups.rs | 2 +-
core/sdk/src/http/binary_personal_access_tokens.rs | 4 +-
core/sdk/src/http/binary_system.rs | 2 +-
core/sdk/src/http/http_client.rs | 6 +-
core/sdk/src/prelude.rs | 31 +-
core/sdk/src/quic/quick_client.rs | 12 +-
.../src/stream_builder/build/build_stream_topic.rs | 6 +-
core/sdk/src/stream_builder/iggy_stream.rs | 2 +-
.../sdk/src/stream_builder/iggy_stream_consumer.rs | 2 +-
.../sdk/src/stream_builder/iggy_stream_producer.rs | 2 +-
core/sdk/src/tcp/tcp_client.rs | 12 +-
core/sdk/src/tcp/tcp_connection_stream.rs | 2 +-
core/sdk/src/tcp/tcp_connection_stream_kind.rs | 1 +
core/server/Cargo.toml | 2 +-
core/server/src/archiver/mod.rs | 1 +
.../create_consumer_group_handler.rs | 2 +-
.../delete_consumer_group_handler.rs | 2 +-
.../consumer_groups/get_consumer_group_handler.rs | 2 +-
.../consumer_groups/get_consumer_groups_handler.rs | 2 +-
.../consumer_groups/join_consumer_group_handler.rs | 2 +-
.../leave_consumer_group_handler.rs | 2 +-
.../delete_consumer_offset_handler.rs | 2 +-
.../get_consumer_offset_handler.rs | 2 +-
.../store_consumer_offset_handler.rs | 2 +-
.../handlers/messages/send_messages_handler.rs | 2 +-
.../partitions/create_partitions_handler.rs | 2 +-
.../partitions/delete_partitions_handler.rs | 2 +-
.../create_personal_access_token_handler.rs | 2 +-
.../delete_personal_access_token_handler.rs | 2 +-
.../get_personal_access_tokens_handler.rs | 2 +-
.../login_with_personal_access_token_handler.rs | 2 +-
.../handlers/segments/delete_segments_handler.rs | 2 +-
.../handlers/streams/create_stream_handler.rs | 2 +-
.../handlers/streams/delete_stream_handler.rs | 2 +-
.../binary/handlers/streams/get_stream_handler.rs | 2 +-
.../binary/handlers/streams/get_streams_handler.rs | 2 +-
.../handlers/streams/purge_stream_handler.rs | 2 +-
.../handlers/streams/update_stream_handler.rs | 2 +-
.../binary/handlers/system/get_client_handler.rs | 2 +-
.../binary/handlers/system/get_clients_handler.rs | 2 +-
.../src/binary/handlers/system/get_me_handler.rs | 2 +-
.../src/binary/handlers/system/get_snapshot.rs | 2 +-
.../binary/handlers/system/get_stats_handler.rs | 2 +-
.../src/binary/handlers/system/ping_handler.rs | 4 +-
.../binary/handlers/topics/create_topic_handler.rs | 2 +-
.../binary/handlers/topics/delete_topic_handler.rs | 2 +-
.../binary/handlers/topics/get_topic_handler.rs | 2 +-
.../binary/handlers/topics/get_topics_handler.rs | 2 +-
.../binary/handlers/topics/purge_topic_handler.rs | 2 +-
.../binary/handlers/topics/update_topic_handler.rs | 2 +-
.../handlers/users/change_password_handler.rs | 2 +-
.../binary/handlers/users/create_user_handler.rs | 2 +-
.../binary/handlers/users/delete_user_handler.rs | 2 +-
.../src/binary/handlers/users/get_user_handler.rs | 2 +-
.../src/binary/handlers/users/get_users_handler.rs | 2 +-
.../binary/handlers/users/login_user_handler.rs | 2 +-
.../binary/handlers/users/logout_user_handler.rs | 2 +-
.../handlers/users/update_permissions_handler.rs | 2 +-
.../binary/handlers/users/update_user_handler.rs | 2 +-
core/server/src/build.rs | 4 +-
.../commands/clean_personal_access_tokens.rs | 4 +-
.../src/channels/commands/maintain_messages.rs | 22 +-
core/server/src/channels/commands/print_sysinfo.rs | 26 +-
core/server/src/channels/commands/save_messages.rs | 4 +-
.../src/channels/commands/verify_heartbeats.rs | 8 +-
.../src/compat/index_rebuilding/index_rebuilder.rs | 2 +-
core/server/src/configs/config_provider.rs | 8 +-
core/server/src/configs/displays.rs | 108 +-
core/server/src/configs/http.rs | 2 +-
core/server/src/configs/quic.rs | 2 +-
core/server/src/configs/server.rs | 4 +-
core/server/src/configs/system.rs | 2 +-
core/server/src/configs/tcp.rs | 2 +-
core/server/src/configs/validators.rs | 6 +-
core/server/src/http/consumer_groups.rs | 6 +-
core/server/src/http/consumer_offsets.rs | 8 +-
core/server/src/http/diagnostics.rs | 4 +-
core/server/src/http/error.rs | 2 +-
core/server/src/http/http_server.rs | 2 +-
core/server/src/http/jwt/jwt_manager.rs | 8 +-
core/server/src/http/jwt/storage.rs | 2 +-
core/server/src/http/mapper.rs | 9 +-
core/server/src/http/messages.rs | 2 +-
core/server/src/http/partitions.rs | 6 +-
core/server/src/http/personal_access_tokens.rs | 6 +-
core/server/src/http/streams.rs | 6 +-
core/server/src/http/system.rs | 8 +-
core/server/src/http/topics.rs | 6 +-
core/server/src/http/users.rs | 2 +-
core/server/src/log/logger.rs | 18 +-
core/server/src/main.rs | 2 +-
core/server/src/quic/quic_server.rs | 2 +-
core/server/src/state/command.rs | 8 +-
core/server/src/state/entry.rs | 2 +-
core/server/src/state/file.rs | 4 +-
core/server/src/state/models.rs | 8 +-
core/server/src/state/system.rs | 14 +-
.../server/src/streaming/clients/client_manager.rs | 4 +-
.../src/streaming/partitions/consumer_offsets.rs | 32 +-
core/server/src/streaming/partitions/messages.rs | 44 +-
core/server/src/streaming/partitions/partition.rs | 4 +-
.../server/src/streaming/partitions/persistence.rs | 2 +-
core/server/src/streaming/partitions/segments.rs | 2 +-
core/server/src/streaming/partitions/storage.rs | 72 +-
core/server/src/streaming/persistence/task.rs | 2 +-
.../personal_access_token.rs | 2 +-
.../src/streaming/segments/indexes/index_reader.rs | 24 +-
.../src/streaming/segments/indexes/index_writer.rs | 4 +-
.../src/streaming/segments/indexes/indexes_mut.rs | 4 +-
.../streaming/segments/messages/messages_reader.rs | 20 +-
.../streaming/segments/messages/messages_writer.rs | 4 +-
.../streaming/segments/messages/persister_task.rs | 10 +-
.../src/streaming/segments/messages_accumulator.rs | 11 +-
.../src/streaming/segments/reading_messages.rs | 5 +-
core/server/src/streaming/segments/segment.rs | 30 +-
.../streaming/segments/types/message_view_mut.rs | 2 +-
.../streaming/segments/types/messages_batch_mut.rs | 33 +-
.../src/streaming/segments/writing_messages.rs | 14 +-
core/server/src/streaming/storage.rs | 2 +-
core/server/src/streaming/streams/persistence.rs | 2 +-
core/server/src/streaming/streams/storage.rs | 26 +-
core/server/src/streaming/streams/stream.rs | 2 +-
core/server/src/streaming/streams/topics.rs | 4 +-
core/server/src/streaming/systems/clients.rs | 6 +-
.../src/streaming/systems/consumer_groups.rs | 4 +-
.../src/streaming/systems/consumer_offsets.rs | 2 +-
core/server/src/streaming/systems/info.rs | 8 +-
core/server/src/streaming/systems/messages.rs | 11 +-
core/server/src/streaming/systems/partitions.rs | 2 +-
.../streaming/systems/personal_access_tokens.rs | 6 +-
core/server/src/streaming/systems/segments.rs | 4 +-
core/server/src/streaming/systems/stats.rs | 2 +-
core/server/src/streaming/systems/storage.rs | 4 +-
core/server/src/streaming/systems/streams.rs | 20 +-
core/server/src/streaming/systems/system.rs | 2 +-
core/server/src/streaming/systems/topics.rs | 2 +-
core/server/src/streaming/systems/users.rs | 14 +-
core/server/src/streaming/topics/consumer_group.rs | 20 +-
.../server/src/streaming/topics/consumer_groups.rs | 6 +-
.../src/streaming/topics/consumer_offsets.rs | 44 +-
core/server/src/streaming/topics/messages.rs | 16 +-
core/server/src/streaming/topics/partitions.rs | 2 +-
core/server/src/streaming/topics/persistence.rs | 4 +-
core/server/src/streaming/topics/storage.rs | 29 +-
core/server/src/streaming/topics/topic.rs | 2 +-
core/server/src/streaming/users/user.rs | 2 +-
core/server/src/streaming/utils/file.rs | 2 +-
core/server/src/streaming/utils/memory_pool.rs | 5 +-
core/server/src/streaming/utils/mod.rs | 2 +-
core/server/src/streaming/utils/pooled_buffer.rs | 2 +-
core/server/src/tcp/tcp_listener.rs | 8 +-
core/server/src/tcp/tcp_tls_listener.rs | 8 +-
core/tools/Cargo.toml | 2 +-
foreign/cpp/.clang-format | 7 +
foreign/cpp/.devcontainer/devcontainer.json | 32 +
.../cpp/.devcontainer/post-install.sh | 18 +-
foreign/cpp/.gitignore | 5 +
foreign/cpp/.lcovrc | 3 +
foreign/cpp/.pre-commit-config.yaml | 107 +
foreign/cpp/.yamllint | 3 +
foreign/cpp/CMakeLists.txt | 123 +
foreign/cpp/CMakePresets.json | 54 +
foreign/cpp/CONTRIBUTORS.md | 49 +
foreign/cpp/CPPLINT.cfg | 3 +
foreign/cpp/Doxyfile | 2657 ++++++++++++++++++++
foreign/cpp/LICENSE | 21 +
foreign/cpp/README.md | 5 +
foreign/cpp/cmake/modules/CodeCoverage.cmake | 842 +++++++
.../test.yml => foreign/cpp/docs/CMakeLists.txt | 23 +-
foreign/cpp/docs/images/init_act.png | Bin 0 -> 161574 bytes
foreign/cpp/docs/images/pre-commit_run.png | Bin 0 -> 148646 bytes
.../iggy-cpp-build/.devcontainer/devcontainer.json | 39 +
foreign/cpp/images/iggy-cpp-build/README.md | 6 +
foreign/cpp/sdk/binary.h | 77 +
foreign/cpp/sdk/client.cc | 40 +
foreign/cpp/sdk/client.h | 108 +
foreign/cpp/sdk/command.h | 481 ++++
.../Iggy_SDK_Tests/Usings.cs => cpp/sdk/json.cc} | 3 +-
.../session_feature_logout.go => cpp/sdk/json.h} | 40 +-
.../Iggy_SDK_Tests/Usings.cs => cpp/sdk/model.cc} | 3 +-
foreign/cpp/sdk/model.h | 679 +++++
foreign/cpp/sdk/net/address.cc | 51 +
foreign/cpp/sdk/net/address.h | 67 +
.../auto_login.rs => foreign/cpp/sdk/net/conn.cc | 9 +-
foreign/cpp/sdk/net/conn.h | 67 +
.../Usings.cs => cpp/sdk/net/http/conn.cc} | 3 +-
.../Usings.cs => cpp/sdk/net/http/conn.h} | 3 +-
foreign/cpp/sdk/net/iggy.cc | 41 +
foreign/cpp/sdk/net/iggy.h | 61 +
.../sdk/net/protocol.cc} | 46 +-
foreign/cpp/sdk/net/protocol.h | 126 +
.../Usings.cs => cpp/sdk/net/quic/address.h} | 3 +-
.../Usings.cs => cpp/sdk/net/quic/conn.h} | 3 +-
.../Usings.cs => cpp/sdk/net/quic/stream.h} | 3 +-
foreign/cpp/sdk/net/ssl/crypto.cc | 88 +
foreign/cpp/sdk/net/ssl/crypto.h | 328 +++
foreign/cpp/sdk/net/ssl/ssl.cc | 212 ++
foreign/cpp/sdk/net/ssl/ssl.h | 166 ++
.../mod.rs => foreign/cpp/sdk/net/ssl/ssl_engine.h | 8 +-
.../Usings.cs => cpp/sdk/net/tcp/conn.cc} | 3 +-
.../Usings.cs => cpp/sdk/net/tcp/conn.h} | 3 +-
.../sdk/net/transport.h} | 40 +-
.../title.rs => foreign/cpp/sdk/serialization.cc | 26 +-
.../identifier.go => cpp/sdk/serialization.h} | 52 +-
foreign/cpp/sdk/types.h | 41 +
foreign/cpp/tests/CMakeLists.txt | 101 +
foreign/cpp/tests/e2e/e2e_testutils.cc | 49 +
.../tests/e2e/e2e_testutils.h} | 25 +-
.../login.go => cpp/tests/e2e/ping_cmd_test.cc} | 23 +-
.../configs => foreign/cpp/tests/e2e}/server.toml | 277 +-
.../cpp/tests/unit/client_test.cc | 18 +-
foreign/cpp/tests/unit/crypto_test.cc | 50 +
.../cpp/tests/unit/iggy_protocol_provider_test.cc | 50 +
.../cpp/tests/unit/model_test.cc | 16 +-
.../tests/unit/serialization_test.cc} | 32 +-
foreign/cpp/tests/unit/ssl_test.cc | 148 ++
foreign/cpp/tests/unit/unit_testutils.cc | 63 +
.../tests/unit/unit_testutils.h} | 46 +-
foreign/cpp/vcpkg-configuration.json | 14 +
foreign/cpp/vcpkg.json | 14 +
foreign/java/README.md | 14 +-
.../java/dev-support/checks/build.sh | 15 +-
foreign/java/dev-support/checkstyle/checkstyle.xml | 213 ++
.../java/examples/simple-consumer/build.gradle.kts | 6 +-
.../java/examples/simple-producer/build.gradle.kts | 6 +-
foreign/java/java-sdk/build.gradle.kts | 29 +-
.../iggy/client/blocking/tcp/CommandCode.java | 192 ++
.../blocking/tcp/ConsumerGroupsTcpClient.java | 19 +-
.../blocking/tcp/ConsumerOffsetTcpClient.java | 7 +-
.../client/blocking/tcp/InternalTcpClient.java | 12 +
.../client/blocking/tcp/MessagesTcpClient.java | 7 +-
.../client/blocking/tcp/PartitionsTcpClient.java | 6 +-
.../tcp/PersonalAccessTokensTcpClient.java | 13 +-
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 15 +-
.../iggy/client/blocking/tcp/SystemTcpClient.java | 15 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 16 +-
.../iggy/client/blocking/tcp/UsersTcpClient.java | 28 +-
foreign/java/settings.gradle.kts | 15 +-
foreign/node/src/debug-send.ts | 12 +-
foreign/node/src/debug-send.ts~ | 118 -
foreign/node/src/debug.ts | 8 +-
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 17 +-
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 2 +-
foreign/node/src/e2e/tcp.send-message.e2e.ts | 30 +-
foreign/node/src/stream/consumer-stream.ts | 2 +-
foreign/node/src/wire/identifier.utils.ts | 14 -
foreign/node/src/wire/message/iggy-header.utils.ts | 67 +
foreign/node/src/wire/message/message.utils.ts | 54 +-
foreign/node/src/wire/message/poll.utils.ts | 71 +-
527 files changed, 9526 insertions(+), 1919 deletions(-)
create mode 100644 .github/workflows/ci-check-java-sdk.yml
create mode 100644 foreign/cpp/.clang-format
create mode 100644 foreign/cpp/.devcontainer/devcontainer.json
copy scripts/dashboard/build_release.sh =>
foreign/cpp/.devcontainer/post-install.sh (72%)
create mode 100644 foreign/cpp/.gitignore
create mode 100644 foreign/cpp/.lcovrc
create mode 100644 foreign/cpp/.pre-commit-config.yaml
create mode 100644 foreign/cpp/.yamllint
create mode 100644 foreign/cpp/CMakeLists.txt
create mode 100644 foreign/cpp/CMakePresets.json
create mode 100644 foreign/cpp/CONTRIBUTORS.md
create mode 100644 foreign/cpp/CPPLINT.cfg
create mode 100644 foreign/cpp/Doxyfile
create mode 100644 foreign/cpp/LICENSE
create mode 100644 foreign/cpp/README.md
create mode 100644 foreign/cpp/cmake/modules/CodeCoverage.cmake
copy .github/workflows/test.yml => foreign/cpp/docs/CMakeLists.txt (56%)
create mode 100644 foreign/cpp/docs/images/init_act.png
create mode 100644 foreign/cpp/docs/images/pre-commit_run.png
create mode 100644
foreign/cpp/images/iggy-cpp-build/.devcontainer/devcontainer.json
create mode 100644 foreign/cpp/images/iggy-cpp-build/README.md
create mode 100644 foreign/cpp/sdk/binary.h
create mode 100644 foreign/cpp/sdk/client.cc
create mode 100644 foreign/cpp/sdk/client.h
create mode 100644 foreign/cpp/sdk/command.h
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/json.cc} (97%)
copy foreign/{go/e2e/tcp_test/session_feature_logout.go => cpp/sdk/json.h}
(61%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/model.cc} (97%)
create mode 100644 foreign/cpp/sdk/model.h
create mode 100644 foreign/cpp/sdk/net/address.cc
create mode 100644 foreign/cpp/sdk/net/address.h
copy core/common/src/types/configuration/auth_config/auto_login.rs =>
foreign/cpp/sdk/net/conn.cc (83%)
create mode 100644 foreign/cpp/sdk/net/conn.h
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/http/conn.cc}
(97%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/http/conn.h} (97%)
create mode 100644 foreign/cpp/sdk/net/iggy.cc
create mode 100644 foreign/cpp/sdk/net/iggy.h
copy foreign/{go/e2e/tcp_test/topic_feature_get_all.go =>
cpp/sdk/net/protocol.cc} (50%)
create mode 100644 foreign/cpp/sdk/net/protocol.h
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/quic/address.h}
(97%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/quic/conn.h} (97%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/quic/stream.h}
(97%)
create mode 100644 foreign/cpp/sdk/net/ssl/crypto.cc
create mode 100644 foreign/cpp/sdk/net/ssl/crypto.h
create mode 100644 foreign/cpp/sdk/net/ssl/ssl.cc
create mode 100644 foreign/cpp/sdk/net/ssl/ssl.h
copy core/bench/dashboard/server/src/github/mod.rs =>
foreign/cpp/sdk/net/ssl/ssl_engine.h (88%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/tcp/conn.cc} (97%)
copy foreign/{csharp/Iggy_SDK_Tests/Usings.cs => cpp/sdk/net/tcp/conn.h} (97%)
copy foreign/{csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs =>
cpp/sdk/net/transport.h} (57%)
copy core/bench/dashboard/shared/src/title.rs =>
foreign/cpp/sdk/serialization.cc (55%)
copy foreign/{go/contracts/identifier.go => cpp/sdk/serialization.h} (52%)
create mode 100644 foreign/cpp/sdk/types.h
create mode 100644 foreign/cpp/tests/CMakeLists.txt
create mode 100644 foreign/cpp/tests/e2e/e2e_testutils.cc
copy foreign/{csharp/Iggy_SDK/Contracts/Http/DeleteConsumerGroup.cs =>
cpp/tests/e2e/e2e_testutils.h} (59%)
copy foreign/{go/contracts/login.go => cpp/tests/e2e/ping_cmd_test.cc} (68%)
copy {core/configs => foreign/cpp/tests/e2e}/server.toml (57%)
copy core/bench/dashboard/frontend/src/router.rs =>
foreign/cpp/tests/unit/client_test.cc (76%)
create mode 100644 foreign/cpp/tests/unit/crypto_test.cc
create mode 100644 foreign/cpp/tests/unit/iggy_protocol_provider_test.cc
copy core/bench/dashboard/frontend/src/router.rs =>
foreign/cpp/tests/unit/model_test.cc (76%)
copy foreign/{csharp/Iggy_SDK/JsonConfiguration/UserResponseConverter.cs =>
cpp/tests/unit/serialization_test.cc} (57%)
create mode 100644 foreign/cpp/tests/unit/ssl_test.cc
create mode 100644 foreign/cpp/tests/unit/unit_testutils.cc
copy foreign/{go/binary_serialization/create_stream_serializer.go =>
cpp/tests/unit/unit_testutils.h} (53%)
create mode 100644 foreign/cpp/vcpkg-configuration.json
create mode 100644 foreign/cpp/vcpkg.json
copy .github/workflows/test.yml => foreign/java/dev-support/checks/build.sh
(81%)
mode change 100644 => 100755
create mode 100644 foreign/java/dev-support/checkstyle/checkstyle.xml
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/CommandCode.java
delete mode 100644 foreign/node/src/debug-send.ts~
create mode 100644 foreign/node/src/wire/message/iggy-header.utils.ts
