This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch dashboard-views
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 0a12ea52 feat(bench): add Yew routing for benchmark sharing
add 978edead chore(docs): fix error link (#1771)
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 b3c3a5c2 feat(bench): Introduce benchmark deep linking and 'Recent' tab
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 (0a12ea52)
\
N -- N -- N refs/heads/dashboard-views (b3c3a5c2)
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/changed-files-config.json | 6 +
.github/workflows/ci-check-java-sdk.yml | 81 +
.github/workflows/ci-check-pr.yml | 8 +
.gitignore | 7 +-
Cargo.lock | 3 +-
README.md | 4 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/README.md | 13 -
core/bench/dashboard/frontend/Cargo.toml | 5 +-
core/bench/dashboard/frontend/assets/style.css | 594 ++++-
core/bench/dashboard/frontend/src/api/mod.rs | 25 +-
.../frontend/src/components/app_content.rs | 116 +-
.../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 | 83 +-
.../frontend/src/components/layout/sidebar.rs | 175 +-
.../frontend/src/components/layout/topbar.rs | 2 +-
.../bench/dashboard/frontend/src/components/mod.rs | 1 +
.../components/selectors/benchmark_search_box.rs | 27 +
.../src/components/selectors/benchmark_selector.rs | 33 +-
.../src/components/selectors/hardware_selector.rs | 2 +-
.../frontend/src/components/selectors/mod.rs | 2 +
.../selectors/recent_benchmarks_selector.rs | 271 ++
.../src/components/selectors/view_mode_selector.rs | 69 +-
core/bench/dashboard/frontend/src/state/ui.rs | 5 +-
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/cache/query.rs | 24 +
core/bench/dashboard/server/src/github/client.rs | 4 +-
core/bench/dashboard/server/src/handlers.rs | 30 +-
core/bench/dashboard/server/src/main.rs | 6 +-
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/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 | 2 +-
.../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 | 27 +-
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/server/Cargo.toml | 2 +-
.../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 | 4 +-
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 | 2 +-
.../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 | 31 +-
.../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 | 14 +-
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 +-
535 files changed, 10764 insertions(+), 2095 deletions(-)
create mode 100644 .github/workflows/ci-check-java-sdk.yml
create mode 100644
core/bench/dashboard/frontend/src/components/selectors/benchmark_search_box.rs
create mode 100644
core/bench/dashboard/frontend/src/components/selectors/recent_benchmarks_selector.rs
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
