This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch disk-space-ci
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit b2e14cfc6 Merge branch 'master' into disk-space-ci
omit d5fba00ff ci: tune per-task disk and cache for rust pre-merge
add dbeab0cf2 ci: replace `addlicense` with `HawkEye` for license header
checks (#3325)
add 809703902 ci: tune per-task disk and cache for rust pre-merge
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 (b2e14cfc6)
\
N -- N -- N refs/heads/disk-space-ci (809703902)
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/config/hawkeye.version | 1 +
.github/workflows/_common.yml | 16 +-
.pre-commit-config.yaml | 2 +-
AGENTS.md | 56 ++--
CONTRIBUTING.md | 20 +-
bdd/rust/tests/basic_messaging.rs | 33 +-
bdd/rust/tests/common/global_context.rs | 33 +-
bdd/rust/tests/common/leader_context.rs | 33 +-
bdd/rust/tests/common/mod.rs | 33 +-
bdd/rust/tests/helpers/cluster.rs | 33 +-
bdd/rust/tests/helpers/mod.rs | 33 +-
bdd/rust/tests/helpers/test_data.rs | 33 +-
bdd/rust/tests/leader_redirection.rs | 33 +-
bdd/rust/tests/steps/auth.rs | 33 +-
bdd/rust/tests/steps/leader_redirection.rs | 33 +-
bdd/rust/tests/steps/messages.rs | 33 +-
bdd/rust/tests/steps/mod.rs | 33 +-
bdd/rust/tests/steps/server.rs | 33 +-
bdd/rust/tests/steps/streams.rs | 33 +-
bdd/rust/tests/steps/topics.rs | 33 +-
core/ai/mcp/Dockerfile | 22 +-
core/ai/mcp/src/api.rs | 34 +--
core/ai/mcp/src/configs.rs | 34 +--
core/ai/mcp/src/error.rs | 34 +--
core/ai/mcp/src/log.rs | 34 +--
core/ai/mcp/src/main.rs | 34 +--
core/ai/mcp/src/service/mod.rs | 33 +-
core/ai/mcp/src/service/requests.rs | 33 +-
core/ai/mcp/src/stream.rs | 34 +--
core/bench/dashboard/frontend/assets/style.css | 2 +-
core/bench/dashboard/frontend/index.dev.html | 33 +-
core/bench/dashboard/frontend/index.prod.html | 31 +-
core/bench/report/src/lib.rs | 33 +-
core/bench/report/src/plotting/chart.rs | 33 +-
core/bench/report/src/plotting/chart_kind.rs | 33 +-
core/bench/report/src/plotting/mod.rs | 33 +-
core/bench/report/src/plotting/text/mod.rs | 33 +-
core/bench/report/src/plotting/text/subtext.rs | 33 +-
core/bench/report/src/plotting/text/title.rs | 33 +-
core/bench/report/src/prints.rs | 33 +-
core/bench/report/src/types/actor_kind.rs | 33 +-
core/bench/report/src/types/benchmark_kind.rs | 33 +-
core/bench/report/src/types/group_metrics.rs | 33 +-
core/bench/report/src/types/group_metrics_kind.rs | 33 +-
.../report/src/types/group_metrics_summary.rs | 33 +-
core/bench/report/src/types/hardware.rs | 33 +-
core/bench/report/src/types/individual_metrics.rs | 33 +-
.../report/src/types/individual_metrics_summary.rs | 33 +-
.../bench/report/src/types/latency_distribution.rs | 33 +-
core/bench/report/src/types/mod.rs | 33 +-
core/bench/report/src/types/params.rs | 33 +-
core/bench/report/src/types/report.rs | 33 +-
core/bench/report/src/types/server_stats.rs | 33 +-
core/bench/report/src/types/time_series.rs | 33 +-
core/bench/report/src/types/transport.rs | 33 +-
core/bench/report/src/utils.rs | 33 +-
.../src/actors/consumer/benchmark_consumer.rs | 33 +-
.../bench/src/actors/consumer/client/high_level.rs | 33 +-
core/bench/src/actors/consumer/client/interface.rs | 33 +-
core/bench/src/actors/consumer/client/low_level.rs | 33 +-
core/bench/src/actors/consumer/client/mod.rs | 33 +-
core/bench/src/actors/consumer/mod.rs | 33 +-
.../actors/consumer/typed_benchmark_consumer.rs | 33 +-
core/bench/src/actors/mod.rs | 33 +-
.../src/actors/producer/benchmark_producer.rs | 33 +-
.../bench/src/actors/producer/client/high_level.rs | 33 +-
core/bench/src/actors/producer/client/interface.rs | 33 +-
core/bench/src/actors/producer/client/low_level.rs | 33 +-
core/bench/src/actors/producer/client/mod.rs | 33 +-
core/bench/src/actors/producer/mod.rs | 33 +-
.../actors/producer/typed_benchmark_producer.rs | 33 +-
.../benchmark_producing_consumer.rs | 33 +-
core/bench/src/actors/producing_consumer/mod.rs | 33 +-
.../typed_benchmark_producing_consumer.rs | 33 +-
core/bench/src/analytics/metrics/group.rs | 33 +-
core/bench/src/analytics/metrics/individual.rs | 33 +-
.../src/analytics/metrics/latency_distribution.rs | 33 +-
core/bench/src/analytics/metrics/mod.rs | 33 +-
core/bench/src/analytics/mod.rs | 33 +-
core/bench/src/analytics/record.rs | 33 +-
core/bench/src/analytics/report_builder.rs | 33 +-
core/bench/src/analytics/time_series/calculator.rs | 33 +-
.../analytics/time_series/calculators/latency.rs | 33 +-
.../src/analytics/time_series/calculators/mod.rs | 33 +-
.../time_series/calculators/throughput.rs | 33 +-
core/bench/src/analytics/time_series/mod.rs | 33 +-
.../src/analytics/time_series/processors/mod.rs | 33 +-
.../time_series/processors/moving_average.rs | 33 +-
core/bench/src/args/common.rs | 33 +-
core/bench/src/args/defaults.rs | 33 +-
core/bench/src/args/examples.rs | 33 +-
core/bench/src/args/kind.rs | 33 +-
.../src/args/kinds/balanced/consumer_group.rs | 33 +-
core/bench/src/args/kinds/balanced/mod.rs | 33 +-
core/bench/src/args/kinds/balanced/producer.rs | 33 +-
.../kinds/balanced/producer_and_consumer_group.rs | 33 +-
core/bench/src/args/kinds/end_to_end/mod.rs | 33 +-
.../args/kinds/end_to_end/producing_consumer.rs | 33 +-
.../kinds/end_to_end/producing_consumer_group.rs | 33 +-
core/bench/src/args/kinds/mod.rs | 33 +-
core/bench/src/args/kinds/pinned/consumer.rs | 33 +-
core/bench/src/args/kinds/pinned/mod.rs | 33 +-
core/bench/src/args/kinds/pinned/producer.rs | 33 +-
.../src/args/kinds/pinned/producer_and_consumer.rs | 33 +-
core/bench/src/args/mod.rs | 33 +-
core/bench/src/args/output.rs | 33 +-
core/bench/src/args/props.rs | 33 +-
core/bench/src/args/transport.rs | 33 +-
.../src/benchmarks/balanced_consumer_group.rs | 33 +-
core/bench/src/benchmarks/balanced_producer.rs | 33 +-
.../balanced_producer_and_consumer_group.rs | 33 +-
core/bench/src/benchmarks/benchmark.rs | 33 +-
core/bench/src/benchmarks/common.rs | 33 +-
.../benchmarks/end_to_end_producing_consumer.rs | 33 +-
.../end_to_end_producing_consumer_group.rs | 33 +-
core/bench/src/benchmarks/mod.rs | 33 +-
core/bench/src/benchmarks/pinned_consumer.rs | 33 +-
core/bench/src/benchmarks/pinned_producer.rs | 33 +-
core/bench/src/main.rs | 33 +-
core/bench/src/plot.rs | 33 +-
core/bench/src/runner.rs | 33 +-
core/bench/src/utils/client_factory.rs | 33 +-
core/bench/src/utils/cpu_name.rs | 33 +-
core/bench/src/utils/mod.rs | 33 +-
core/cli/build.rs | 33 +-
core/cli/src/args/client.rs | 33 +-
core/cli/src/args/cluster.rs | 33 +-
core/cli/src/args/common.rs | 33 +-
core/cli/src/args/consumer_group.rs | 33 +-
core/cli/src/args/consumer_offset.rs | 33 +-
core/cli/src/args/context.rs | 33 +-
core/cli/src/args/message.rs | 33 +-
core/cli/src/args/mod.rs | 33 +-
core/cli/src/args/partition.rs | 33 +-
core/cli/src/args/permissions/constants.rs | 33 +-
core/cli/src/args/permissions/global.rs | 33 +-
core/cli/src/args/permissions/mod.rs | 33 +-
core/cli/src/args/permissions/stream.rs | 33 +-
core/cli/src/args/permissions/topic.rs | 33 +-
core/cli/src/args/personal_access_token.rs | 33 +-
core/cli/src/args/segment.rs | 34 +--
core/cli/src/args/session.rs | 33 +-
core/cli/src/args/stream.rs | 33 +-
core/cli/src/args/system.rs | 33 +-
core/cli/src/args/topic.rs | 33 +-
core/cli/src/args/user.rs | 33 +-
core/cli/src/commands/binary_client/get_client.rs | 33 +-
core/cli/src/commands/binary_client/get_clients.rs | 33 +-
core/cli/src/commands/binary_client/mod.rs | 33 +-
.../binary_cluster/get_cluster_metadata.rs | 33 +-
core/cli/src/commands/binary_cluster/mod.rs | 33 +-
.../create_consumer_group.rs | 33 +-
.../delete_consumer_group.rs | 33 +-
.../binary_consumer_groups/get_consumer_group.rs | 33 +-
.../binary_consumer_groups/get_consumer_groups.rs | 33 +-
.../cli/src/commands/binary_consumer_groups/mod.rs | 33 +-
.../binary_consumer_offsets/get_consumer_offset.rs | 33 +-
.../src/commands/binary_consumer_offsets/mod.rs | 33 +-
.../binary_consumer_offsets/set_consumer_offset.rs | 33 +-
core/cli/src/commands/binary_context/common.rs | 33 +-
.../src/commands/binary_context/create_context.rs | 33 +-
.../src/commands/binary_context/delete_context.rs | 33 +-
.../src/commands/binary_context/get_contexts.rs | 33 +-
core/cli/src/commands/binary_context/mod.rs | 33 +-
.../src/commands/binary_context/show_context.rs | 33 +-
.../cli/src/commands/binary_context/use_context.rs | 33 +-
.../src/commands/binary_message/flush_messages.rs | 33 +-
core/cli/src/commands/binary_message/mod.rs | 33 +-
.../src/commands/binary_message/poll_messages.rs | 33 +-
.../src/commands/binary_message/send_messages.rs | 33 +-
.../binary_partitions/create_partitions.rs | 33 +-
.../binary_partitions/delete_partitions.rs | 33 +-
core/cli/src/commands/binary_partitions/mod.rs | 33 +-
.../create_personal_access_token.rs | 33 +-
.../delete_personal_access_tokens.rs | 33 +-
.../get_personal_access_tokens.rs | 33 +-
.../commands/binary_personal_access_tokens/mod.rs | 33 +-
.../commands/binary_segments/delete_segments.rs | 34 +--
core/cli/src/commands/binary_segments/mod.rs | 33 +-
.../src/commands/binary_streams/create_stream.rs | 33 +-
.../src/commands/binary_streams/delete_stream.rs | 33 +-
core/cli/src/commands/binary_streams/get_stream.rs | 33 +-
.../cli/src/commands/binary_streams/get_streams.rs | 33 +-
core/cli/src/commands/binary_streams/mod.rs | 33 +-
.../src/commands/binary_streams/purge_stream.rs | 33 +-
.../src/commands/binary_streams/update_stream.rs | 33 +-
core/cli/src/commands/binary_system/login.rs | 33 +-
core/cli/src/commands/binary_system/logout.rs | 33 +-
core/cli/src/commands/binary_system/me.rs | 33 +-
core/cli/src/commands/binary_system/mod.rs | 33 +-
core/cli/src/commands/binary_system/ping.rs | 33 +-
core/cli/src/commands/binary_system/session.rs | 33 +-
.../src/commands/binary_system/session_status.rs | 33 +-
core/cli/src/commands/binary_system/snapshot.rs | 33 +-
core/cli/src/commands/binary_system/stats.rs | 33 +-
.../cli/src/commands/binary_topics/create_topic.rs | 33 +-
.../cli/src/commands/binary_topics/delete_topic.rs | 33 +-
core/cli/src/commands/binary_topics/get_topic.rs | 33 +-
core/cli/src/commands/binary_topics/get_topics.rs | 33 +-
core/cli/src/commands/binary_topics/mod.rs | 33 +-
core/cli/src/commands/binary_topics/purge_topic.rs | 33 +-
.../cli/src/commands/binary_topics/update_topic.rs | 33 +-
.../src/commands/binary_users/change_password.rs | 33 +-
core/cli/src/commands/binary_users/create_user.rs | 33 +-
core/cli/src/commands/binary_users/delete_user.rs | 33 +-
core/cli/src/commands/binary_users/get_user.rs | 33 +-
core/cli/src/commands/binary_users/get_users.rs | 33 +-
core/cli/src/commands/binary_users/mod.rs | 33 +-
.../commands/binary_users/update_permissions.rs | 33 +-
core/cli/src/commands/binary_users/update_user.rs | 33 +-
core/cli/src/commands/cli_command.rs | 33 +-
core/cli/src/commands/mod.rs | 33 +-
.../cli/src/commands/utils/login_session_expiry.rs | 33 +-
core/cli/src/commands/utils/mod.rs | 33 +-
core/cli/src/credentials.rs | 33 +-
core/cli/src/error.rs | 33 +-
core/cli/src/lib.rs | 33 +-
core/cli/src/logging.rs | 33 +-
core/cli/src/main.rs | 33 +-
core/common/Cargo.toml | 1 +
core/common/src/error/client_error.rs | 33 +-
core/common/src/error/iggy_error.rs | 34 +--
.../http/consumer_groups/create_consumer_group.rs | 33 +-
.../http/consumer_groups/delete_consumer_group.rs | 33 +-
core/common/src/http/consumer_groups/mod.rs | 33 +-
.../consumer_offsets/delete_consumer_offset.rs | 33 +-
.../http/consumer_offsets/get_consumer_offset.rs | 33 +-
core/common/src/http/consumer_offsets/mod.rs | 33 +-
.../http/consumer_offsets/store_consumer_offset.rs | 33 +-
.../src/http/messages/flush_unsaved_buffer.rs | 33 +-
core/common/src/http/messages/poll_messages.rs | 33 +-
core/common/src/http/messages/send_messages.rs | 33 +-
.../src/http/partitions/create_partitions.rs | 33 +-
.../src/http/partitions/delete_partitions.rs | 33 +-
core/common/src/http/partitions/mod.rs | 33 +-
.../create_personal_access_token.rs | 33 +-
.../delete_personal_access_token.rs | 33 +-
.../login_with_personal_access_token.rs | 33 +-
core/common/src/http/personal_access_tokens/mod.rs | 33 +-
core/common/src/http/segments/delete_segments.rs | 34 +--
core/common/src/http/segments/mod.rs | 34 +--
core/common/src/http/streams/create_stream.rs | 33 +-
core/common/src/http/streams/delete_stream.rs | 33 +-
core/common/src/http/streams/mod.rs | 33 +-
core/common/src/http/streams/purge_stream.rs | 33 +-
core/common/src/http/streams/update_stream.rs | 33 +-
core/common/src/http/system/get_snapshot.rs | 33 +-
core/common/src/http/system/mod.rs | 33 +-
core/common/src/http/topics/create_topic.rs | 33 +-
core/common/src/http/topics/delete_topic.rs | 33 +-
core/common/src/http/topics/mod.rs | 33 +-
core/common/src/http/topics/purge_topic.rs | 33 +-
core/common/src/http/topics/update_topic.rs | 33 +-
core/common/src/http/users/change_password.rs | 33 +-
core/common/src/http/users/create_user.rs | 33 +-
core/common/src/http/users/defaults.rs | 33 +-
core/common/src/http/users/delete_user.rs | 33 +-
core/common/src/http/users/login_user.rs | 33 +-
core/common/src/http/users/mod.rs | 33 +-
core/common/src/http/users/update_permissions.rs | 33 +-
core/common/src/http/users/update_user.rs | 33 +-
core/common/src/lib.rs | 34 +--
core/common/src/locking/mod.rs | 33 +-
core/common/src/locking/tokio_lock.rs | 33 +-
core/common/src/traits/binary_auth.rs | 33 +-
core/common/src/traits/binary_client.rs | 33 +-
core/common/src/traits/binary_impls/cluster.rs | 33 +-
.../src/traits/binary_impls/consumer_groups.rs | 33 +-
.../src/traits/binary_impls/consumer_offsets.rs | 33 +-
core/common/src/traits/binary_impls/messages.rs | 34 +--
core/common/src/traits/binary_impls/partitions.rs | 33 +-
.../traits/binary_impls/personal_access_tokens.rs | 34 +--
core/common/src/traits/binary_impls/segments.rs | 33 +-
core/common/src/traits/binary_impls/streams.rs | 33 +-
core/common/src/traits/binary_impls/system.rs | 33 +-
core/common/src/traits/binary_impls/topics.rs | 33 +-
core/common/src/traits/binary_impls/users.rs | 33 +-
core/common/src/traits/binary_transport.rs | 33 +-
core/common/src/traits/client.rs | 33 +-
core/common/src/traits/cluster_client.rs | 33 +-
core/common/src/traits/consumer_group_client.rs | 33 +-
core/common/src/traits/consumer_offset_client.rs | 33 +-
core/common/src/traits/message_client.rs | 34 +--
core/common/src/traits/partition_client.rs | 33 +-
core/common/src/traits/partitioner.rs | 33 +-
.../src/traits/personal_access_token_client.rs | 33 +-
core/common/src/traits/segment_client.rs | 33 +-
core/common/src/traits/sizeable.rs | 33 +-
core/common/src/traits/stream_client.rs | 33 +-
core/common/src/traits/system_client.rs | 33 +-
core/common/src/traits/topic_client.rs | 33 +-
core/common/src/traits/user_client.rs | 33 +-
core/common/src/traits/validatable.rs | 33 +-
core/common/src/types/args/mod.rs | 33 +-
core/common/src/types/client/client_info.rs | 33 +-
core/common/src/types/client_state/mod.rs | 33 +-
core/common/src/types/cluster/metadata.rs | 33 +-
core/common/src/types/cluster/mod.rs | 33 +-
core/common/src/types/cluster/node.rs | 33 +-
core/common/src/types/cluster/role.rs | 33 +-
.../src/types/cluster/transport_endpoints.rs | 33 +-
.../src/types/compression/compression_algorithm.rs | 33 +-
core/common/src/types/compression/mod.rs | 33 +-
.../configuration/auth_config/connection_string.rs | 33 +-
.../auth_config/connection_string_options.rs | 34 +--
.../http_config/http_client_config.rs | 33 +-
.../http_config/http_client_config_builder.rs | 33 +-
.../http_config/http_connection_string_options.rs | 33 +-
.../quic_config/quic_client_config.rs | 33 +-
.../quic_config/quic_client_config_builder.rs | 33 +-
.../quic_config/quic_client_reconnection_config.rs | 33 +-
.../quic_config/quic_connection_string_options.rs | 33 +-
.../configuration/tcp_config/tcp_client_config.rs | 34 +--
.../tcp_config/tcp_client_reconnection_config.rs | 34 +--
.../tcp_config/tcp_connection_string_options.rs | 33 +-
core/common/src/types/configuration/transport.rs | 33 +-
.../websocket_config/websocket_client_config.rs | 33 +-
.../websocket_client_config_builder.rs | 33 +-
.../websocket_client_reconnection_config.rs | 33 +-
core/common/src/types/consumer/consumer_group.rs | 33 +-
core/common/src/types/consumer/consumer_kind.rs | 33 +-
.../src/types/consumer/consumer_offset_info.rs | 33 +-
core/common/src/types/consumer/mod.rs | 33 +-
.../src/types/diagnostic/diagnostic_event.rs | 33 +-
core/common/src/types/http.rs | 33 +-
core/common/src/types/identifier/mod.rs | 33 +-
core/common/src/types/message/iggy_message.rs | 33 +-
core/common/src/types/message/index.rs | 33 +-
core/common/src/types/message/index_view.rs | 33 +-
core/common/src/types/message/indexes.rs | 33 +-
.../common/src/types/message/message_boundaries.rs | 33 +-
core/common/src/types/message/message_header.rs | 33 +-
.../src/types/message/message_header_view.rs | 33 +-
.../src/types/message/message_header_view_mut.rs | 34 +--
core/common/src/types/message/message_view.rs | 33 +-
core/common/src/types/message/message_view_mut.rs | 33 +-
core/common/src/types/message/messages_batch.rs | 33 +-
core/common/src/types/message/mod.rs | 33 +-
core/common/src/types/message/partitioning.rs | 33 +-
core/common/src/types/message/partitioning_kind.rs | 33 +-
core/common/src/types/message/poll_metadata.rs | 33 +-
core/common/src/types/message/polled_messages.rs | 33 +-
core/common/src/types/message/polling_kind.rs | 33 +-
core/common/src/types/message/polling_strategy.rs | 33 +-
core/common/src/types/message/user_headers.rs | 33 +-
core/common/src/types/partition/mod.rs | 33 +-
.../src/types/permissions/permissions_global.rs | 33 +-
.../src/types/permissions/personal_access_token.rs | 33 +-
.../common/src/types/personal_access_tokens/mod.rs | 34 +--
core/common/src/types/segment.rs | 33 +-
core/common/src/types/snapshot/mod.rs | 33 +-
core/common/src/types/stats/mod.rs | 33 +-
core/common/src/types/stream/mod.rs | 33 +-
core/common/src/types/topic/mod.rs | 33 +-
core/common/src/types/user/user_identity_info.rs | 33 +-
core/common/src/types/user/user_info.rs | 33 +-
core/common/src/types/user/user_status.rs | 33 +-
core/common/src/utils/byte_size.rs | 33 +-
core/common/src/utils/checksum.rs | 33 +-
core/common/src/utils/crypto.rs | 33 +-
core/common/src/utils/duration.rs | 33 +-
core/common/src/utils/expiry.rs | 33 +-
core/common/src/utils/hash.rs | 33 +-
core/common/src/utils/mod.rs | 34 +--
core/common/src/utils/net.rs | 34 +--
.../src/utils/personal_access_token_expiry.rs | 33 +-
core/common/src/utils/random_id.rs | 33 +-
core/common/src/utils/serde_secret.rs | 34 +--
core/common/src/utils/text.rs | 33 +-
core/common/src/utils/timestamp.rs | 33 +-
core/common/src/utils/topic_size.rs | 33 +-
core/common/src/utils/versioning.rs | 34 +--
core/common/src/wire_conversions.rs | 33 +-
core/configs/src/configs_impl/env_mapping.rs | 34 +--
core/configs/src/configs_impl/error.rs | 34 +--
core/configs/src/configs_impl/file_provider.rs | 34 +--
core/configs/src/configs_impl/mod.rs | 34 +--
core/configs/src/configs_impl/parsing.rs | 34 +--
core/configs/src/configs_impl/traits.rs | 34 +--
.../configs/src/configs_impl/typed_env_provider.rs | 34 +--
core/configs/src/lib.rs | 34 +--
core/configs/src/server_config/cache_indexes.rs | 33 +-
core/configs/src/server_config/cluster.rs | 33 +-
core/configs/src/server_config/defaults.rs | 33 +-
core/configs/src/server_config/displays.rs | 34 +--
core/configs/src/server_config/http.rs | 33 +-
core/configs/src/server_config/mod.rs | 34 +--
core/configs/src/server_config/quic.rs | 33 +-
core/configs/src/server_config/server.rs | 35 ++-
core/configs/src/server_config/sharding.rs | 33 +-
core/configs/src/server_config/system.rs | 33 +-
core/configs/src/server_config/tcp.rs | 33 +-
core/configs/src/server_config/validators.rs | 34 +--
core/configs/src/server_config/websocket.rs | 33 +-
core/configs/src/server_ng_config/defaults.rs | 34 +--
core/configs/src/server_ng_config/displays.rs | 34 +--
core/configs/src/server_ng_config/message_bus.rs | 34 +--
core/configs/src/server_ng_config/mod.rs | 34 +--
core/configs/src/server_ng_config/quic.rs | 33 +-
core/configs/src/server_ng_config/server_ng.rs | 34 +--
core/configs/src/server_ng_config/tcp.rs | 33 +-
core/configs/src/server_ng_config/validators.rs | 34 +--
core/configs/src/server_ng_config/websocket.rs | 33 +-
core/configs_derive/src/config_env.rs | 34 +--
core/configs_derive/src/lib.rs | 34 +--
core/connectors/runtime/Dockerfile | 22 +-
core/connectors/runtime/src/api/auth.rs | 33 +-
core/connectors/runtime/src/api/config.rs | 34 +--
core/connectors/runtime/src/api/error.rs | 33 +-
core/connectors/runtime/src/api/mod.rs | 34 +--
core/connectors/runtime/src/api/models.rs | 34 +--
core/connectors/runtime/src/api/sink.rs | 34 +--
core/connectors/runtime/src/api/source.rs | 34 +--
core/connectors/runtime/src/benchmark.rs | 34 +--
core/connectors/runtime/src/configs/connectors.rs | 34 +--
.../src/configs/connectors/http_provider.rs | 34 +--
.../connectors/http_provider/response_extractor.rs | 34 +--
.../connectors/http_provider/url_builder.rs | 34 +--
.../src/configs/connectors/local_provider.rs | 34 +--
core/connectors/runtime/src/configs/mod.rs | 34 +--
core/connectors/runtime/src/configs/runtime.rs | 34 +--
core/connectors/runtime/src/context.rs | 35 ++-
core/connectors/runtime/src/error.rs | 34 +--
core/connectors/runtime/src/log.rs | 34 +--
core/connectors/runtime/src/main.rs | 34 +--
core/connectors/runtime/src/manager/mod.rs | 34 +--
core/connectors/runtime/src/manager/sink.rs | 35 ++-
core/connectors/runtime/src/manager/source.rs | 35 ++-
core/connectors/runtime/src/metrics.rs | 34 +--
core/connectors/runtime/src/sink.rs | 34 +--
core/connectors/runtime/src/source.rs | 34 +--
core/connectors/runtime/src/state.rs | 34 +--
core/connectors/runtime/src/stats.rs | 34 +--
core/connectors/runtime/src/stream.rs | 34 +--
core/connectors/runtime/src/transform.rs | 34 +--
core/connectors/sdk/examples/user.fbs | 6 +-
core/connectors/sdk/examples/user.proto | 6 +-
core/connectors/sdk/src/api.rs | 34 +--
core/connectors/sdk/src/convert.rs | 34 +--
core/connectors/sdk/src/decoders/avro.rs | 33 +-
core/connectors/sdk/src/decoders/flatbuffer.rs | 33 +-
core/connectors/sdk/src/decoders/json.rs | 33 +-
core/connectors/sdk/src/decoders/mod.rs | 33 +-
core/connectors/sdk/src/decoders/proto.rs | 32 +-
core/connectors/sdk/src/decoders/raw.rs | 33 +-
core/connectors/sdk/src/decoders/text.rs | 33 +-
core/connectors/sdk/src/encoders/avro.rs | 33 +-
core/connectors/sdk/src/encoders/flatbuffer.rs | 33 +-
core/connectors/sdk/src/encoders/json.rs | 33 +-
core/connectors/sdk/src/encoders/mod.rs | 33 +-
core/connectors/sdk/src/encoders/proto.rs | 33 +-
core/connectors/sdk/src/encoders/raw.rs | 33 +-
core/connectors/sdk/src/encoders/text.rs | 33 +-
core/connectors/sdk/src/lib.rs | 34 +--
core/connectors/sdk/src/log.rs | 34 +--
core/connectors/sdk/src/retry.rs | 33 +-
core/connectors/sdk/src/sink.rs | 34 +--
core/connectors/sdk/src/source.rs | 34 +--
core/connectors/sdk/src/transforms/add_fields.rs | 33 +-
core/connectors/sdk/src/transforms/avro_convert.rs | 33 +-
.../connectors/sdk/src/transforms/delete_fields.rs | 33 +-
.../connectors/sdk/src/transforms/filter_fields.rs | 33 +-
.../sdk/src/transforms/flatbuffer_convert.rs | 33 +-
.../sdk/src/transforms/json/add_fields.rs | 33 +-
.../sdk/src/transforms/json/delete_fields.rs | 39 ++-
.../sdk/src/transforms/json/filter_fields.rs | 33 +-
core/connectors/sdk/src/transforms/json/mod.rs | 33 +-
.../sdk/src/transforms/json/test_utils.rs | 33 +-
.../sdk/src/transforms/json/unwrap_envelope.rs | 33 +-
.../sdk/src/transforms/json/update_fields.rs | 33 +-
core/connectors/sdk/src/transforms/mod.rs | 33 +-
.../connectors/sdk/src/transforms/proto_convert.rs | 33 +-
.../sdk/src/transforms/unwrap_envelope.rs | 33 +-
.../connectors/sdk/src/transforms/update_fields.rs | 33 +-
.../connectors/sdk/tests/flatbuffer_integration.rs | 33 +-
core/connectors/sdk/tests/protobuf_integration.rs | 32 +-
core/connectors/sinks/delta_sink/src/coercions.rs | 33 +-
core/connectors/sinks/delta_sink/src/lib.rs | 33 +-
core/connectors/sinks/delta_sink/src/sink.rs | 33 +-
core/connectors/sinks/delta_sink/src/storage.rs | 33 +-
core/connectors/sinks/doris_sink/src/lib.rs | 33 +-
.../connectors/sinks/elasticsearch_sink/src/lib.rs | 34 +--
core/connectors/sinks/http_sink/src/lib.rs | 33 +-
core/connectors/sinks/iceberg_sink/src/catalog.rs | 33 +-
core/connectors/sinks/iceberg_sink/src/lib.rs | 33 +-
core/connectors/sinks/iceberg_sink/src/props.rs | 33 +-
.../iceberg_sink/src/router/arrow_streamer.rs | 33 +-
.../iceberg_sink/src/router/dynamic_router.rs | 34 +--
.../sinks/iceberg_sink/src/router/mod.rs | 33 +-
.../sinks/iceberg_sink/src/router/static_router.rs | 33 +-
core/connectors/sinks/iceberg_sink/src/sink.rs | 34 +--
core/connectors/sinks/influxdb_sink/src/lib.rs | 33 +-
.../connectors/sinks/influxdb_sink/src/protocol.rs | 33 +-
core/connectors/sinks/mongodb_sink/src/lib.rs | 33 +-
core/connectors/sinks/postgres_sink/src/lib.rs | 33 +-
core/connectors/sinks/quickwit_sink/src/lib.rs | 33 +-
core/connectors/sinks/stdout_sink/src/lib.rs | 33 +-
.../sources/elasticsearch_source/src/lib.rs | 35 ++-
.../elasticsearch_source/src/state_manager.rs | 34 +--
.../sources/influxdb_source/src/common.rs | 33 +-
core/connectors/sources/influxdb_source/src/lib.rs | 33 +-
core/connectors/sources/influxdb_source/src/row.rs | 33 +-
core/connectors/sources/influxdb_source/src/v2.rs | 33 +-
core/connectors/sources/influxdb_source/src/v3.rs | 33 +-
core/connectors/sources/postgres_source/src/lib.rs | 34 +--
core/connectors/sources/random_source/src/lib.rs | 34 +--
core/harness_derive/src/attrs.rs | 33 +-
core/harness_derive/src/codegen.rs | 33 +-
core/harness_derive/src/lib.rs | 33 +-
core/harness_derive/src/params.rs | 33 +-
core/integration/build.rs | 33 +-
core/integration/src/harness/config/client.rs | 34 +--
core/integration/src/harness/config/common.rs | 34 +--
.../src/harness/config/connectors_runtime.rs | 34 +--
core/integration/src/harness/config/jwks.rs | 34 +--
core/integration/src/harness/config/mcp.rs | 34 +--
core/integration/src/harness/config/mod.rs | 34 +--
core/integration/src/harness/config/resolve.rs | 34 +--
core/integration/src/harness/config/server.rs | 34 +--
core/integration/src/harness/context.rs | 34 +--
core/integration/src/harness/error.rs | 34 +--
core/integration/src/harness/fixture.rs | 34 +--
core/integration/src/harness/handle/client.rs | 34 +--
.../src/harness/handle/client_builder.rs | 34 +--
core/integration/src/harness/handle/common.rs | 34 +--
.../src/harness/handle/connectors_runtime.rs | 34 +--
core/integration/src/harness/handle/mcp.rs | 34 +--
core/integration/src/harness/handle/mod.rs | 34 +--
core/integration/src/harness/handle/server.rs | 34 +--
core/integration/src/harness/helpers.rs | 34 +--
core/integration/src/harness/mod.rs | 34 +--
.../src/harness/orchestrator/builder.rs | 34 +--
.../src/harness/orchestrator/harness.rs | 34 +--
core/integration/src/harness/orchestrator/mod.rs | 34 +--
core/integration/src/harness/port_reserver.rs | 34 +--
core/integration/src/harness/seeds.rs | 34 +--
core/integration/src/harness/traits.rs | 34 +--
core/integration/src/lib.rs | 33 +-
core/integration/tests/cli/client/mod.rs | 33 +-
.../tests/cli/client/test_client_get_command.rs | 33 +-
.../tests/cli/client/test_client_help_command.rs | 33 +-
.../tests/cli/client/test_client_list_command.rs | 33 +-
core/integration/tests/cli/common/command.rs | 33 +-
core/integration/tests/cli/common/help.rs | 33 +-
core/integration/tests/cli/common/keyring.rs | 33 +-
core/integration/tests/cli/common/mod.rs | 33 +-
core/integration/tests/cli/consumer_group/mod.rs | 33 +-
.../test_consumer_group_create_command.rs | 33 +-
.../test_consumer_group_delete_command.rs | 33 +-
.../test_consumer_group_get_command.rs | 33 +-
.../test_consumer_group_help_command.rs | 33 +-
.../test_consumer_group_list_command.rs | 33 +-
core/integration/tests/cli/consumer_offset/mod.rs | 33 +-
.../test_consumer_offset_get_command.rs | 33 +-
.../test_consumer_offset_set_command.rs | 33 +-
core/integration/tests/cli/context/common.rs | 33 +-
core/integration/tests/cli/context/mod.rs | 33 +-
.../tests/cli/context/test_context_applied.rs | 33 +-
.../cli/context/test_context_create_command.rs | 33 +-
.../cli/context/test_context_delete_command.rs | 33 +-
.../tests/cli/context/test_context_list_command.rs | 33 +-
.../tests/cli/context/test_context_show_command.rs | 33 +-
.../tests/cli/context/test_context_use_command.rs | 33 +-
core/integration/tests/cli/general/mod.rs | 33 +-
.../tests/cli/general/test_help_command.rs | 33 +-
.../tests/cli/general/test_missing_credentials.rs | 33 +-
.../tests/cli/general/test_overview_command.rs | 33 +-
.../tests/cli/general/test_quiet_mode.rs | 33 +-
core/integration/tests/cli/message/mod.rs | 33 +-
.../cli/message/test_message_flush_command.rs | 33 +-
.../tests/cli/message/test_message_help_command.rs | 33 +-
.../tests/cli/message/test_message_poll_command.rs | 33 +-
.../message/test_message_poll_to_file_command.rs | 33 +-
.../cli/message/test_message_reply_via_file.rs | 33 +-
.../tests/cli/message/test_message_send_command.rs | 33 +-
.../message/test_message_send_from_file_command.rs | 33 +-
core/integration/tests/cli/mod.rs | 33 +-
core/integration/tests/cli/partition/mod.rs | 33 +-
.../cli/partition/test_partition_create_command.rs | 33 +-
.../cli/partition/test_partition_delete_command.rs | 33 +-
.../cli/partition/test_partition_help_command.rs | 33 +-
.../tests/cli/personal_access_token/mod.rs | 33 +-
.../test_pat_create_command.rs | 33 +-
.../test_pat_delete_command.rs | 33 +-
.../personal_access_token/test_pat_help_command.rs | 33 +-
.../personal_access_token/test_pat_list_command.rs | 33 +-
.../test_pat_login_options.rs | 33 +-
core/integration/tests/cli/stream/mod.rs | 33 +-
.../tests/cli/stream/test_stream_create_command.rs | 33 +-
.../tests/cli/stream/test_stream_delete_command.rs | 33 +-
.../tests/cli/stream/test_stream_get_command.rs | 33 +-
.../tests/cli/stream/test_stream_help_command.rs | 33 +-
.../tests/cli/stream/test_stream_list_command.rs | 33 +-
.../tests/cli/stream/test_stream_purge_command.rs | 33 +-
.../tests/cli/stream/test_stream_update_command.rs | 33 +-
core/integration/tests/cli/system/mod.rs | 33 +-
.../tests/cli/system/test_cli_session_scenario.rs | 33 +-
.../cli/system/test_cluster_metadata_command.rs | 33 +-
.../integration/tests/cli/system/test_login_cmd.rs | 33 +-
.../tests/cli/system/test_login_command.rs | 37 ++-
.../tests/cli/system/test_logout_cmd.rs | 33 +-
.../tests/cli/system/test_logout_command.rs | 33 +-
.../tests/cli/system/test_me_command.rs | 33 +-
.../tests/cli/system/test_ping_command.rs | 33 +-
.../tests/cli/system/test_snapshot_cmd.rs | 33 +-
.../tests/cli/system/test_stats_command.rs | 33 +-
core/integration/tests/cli/topic/mod.rs | 33 +-
.../tests/cli/topic/test_topic_create_command.rs | 33 +-
.../tests/cli/topic/test_topic_delete_command.rs | 33 +-
.../tests/cli/topic/test_topic_get_command.rs | 33 +-
.../tests/cli/topic/test_topic_help_command.rs | 33 +-
.../tests/cli/topic/test_topic_list_command.rs | 33 +-
.../tests/cli/topic/test_topic_purge_command.rs | 33 +-
.../tests/cli/topic/test_topic_update_command.rs | 33 +-
core/integration/tests/cli/user/common.rs | 33 +-
core/integration/tests/cli/user/mod.rs | 33 +-
.../tests/cli/user/test_login_options.rs | 33 +-
.../tests/cli/user/test_user_create_command.rs | 33 +-
.../tests/cli/user/test_user_delete_command.rs | 33 +-
.../tests/cli/user/test_user_get_command.rs | 33 +-
.../tests/cli/user/test_user_help_command.rs | 33 +-
.../tests/cli/user/test_user_list_command.rs | 33 +-
.../tests/cli/user/test_user_name_command.rs | 33 +-
.../tests/cli/user/test_user_password_command.rs | 33 +-
.../cli/user/test_user_permissions_command.rs | 33 +-
.../tests/cli/user/test_user_status_command.rs | 33 +-
core/integration/tests/cluster/mod.rs | 33 +-
core/integration/tests/config_provider/mod.rs | 34 +--
core/integration/tests/connectors/api/endpoints.rs | 34 +--
core/integration/tests/connectors/api/mod.rs | 34 +--
.../tests/connectors/delta/delta_sink.rs | 34 +--
core/integration/tests/connectors/delta/mod.rs | 34 +--
.../tests/connectors/doris/doris_sink.rs | 34 +--
core/integration/tests/connectors/doris/mod.rs | 34 +--
.../connectors/elasticsearch/elasticsearch_sink.rs | 34 +--
.../elasticsearch/elasticsearch_source.rs | 34 +--
.../tests/connectors/elasticsearch/mod.rs | 34 +--
.../tests/connectors/fixtures/delta/fixture.rs | 34 +--
.../tests/connectors/fixtures/delta/mod.rs | 34 +--
.../tests/connectors/fixtures/doris/container.rs | 34 +--
.../tests/connectors/fixtures/doris/mod.rs | 34 +--
.../connectors/fixtures/elasticsearch/container.rs | 34 +--
.../tests/connectors/fixtures/elasticsearch/mod.rs | 34 +--
.../connectors/fixtures/elasticsearch/sink.rs | 34 +--
.../connectors/fixtures/elasticsearch/source.rs | 34 +--
.../tests/connectors/fixtures/http/container.rs | 34 +--
.../tests/connectors/fixtures/http/mod.rs | 34 +--
.../tests/connectors/fixtures/http/sink.rs | 34 +--
.../tests/connectors/fixtures/iceberg/container.rs | 34 +--
.../tests/connectors/fixtures/iceberg/mod.rs | 34 +--
.../connectors/fixtures/influxdb/container.rs | 34 +--
.../connectors/fixtures/influxdb/container_v3.rs | 34 +--
.../tests/connectors/fixtures/influxdb/mod.rs | 34 +--
.../tests/connectors/fixtures/influxdb/sink.rs | 34 +--
.../tests/connectors/fixtures/influxdb/sink_v3.rs | 34 +--
.../tests/connectors/fixtures/influxdb/source.rs | 34 +--
.../connectors/fixtures/influxdb/source_v3.rs | 34 +--
core/integration/tests/connectors/fixtures/mod.rs | 34 +--
.../tests/connectors/fixtures/mongodb/container.rs | 34 +--
.../tests/connectors/fixtures/mongodb/mod.rs | 34 +--
.../tests/connectors/fixtures/mongodb/sink.rs | 34 +--
.../connectors/fixtures/postgres/container.rs | 34 +--
.../tests/connectors/fixtures/postgres/mod.rs | 34 +--
.../tests/connectors/fixtures/postgres/sink.rs | 34 +--
.../tests/connectors/fixtures/postgres/source.rs | 34 +--
.../connectors/fixtures/quickwit/container.rs | 34 +--
.../tests/connectors/fixtures/quickwit/mod.rs | 34 +--
.../tests/connectors/fixtures/wiremock.rs | 34 +--
.../integration/tests/connectors/http/http_sink.rs | 34 +--
core/integration/tests/connectors/http/mod.rs | 34 +--
.../http_config_provider/direct_responses.rs | 34 +--
.../tests/connectors/http_config_provider/mod.rs | 34 +--
.../http_config_provider/wrapped_responses.rs | 34 +--
.../tests/connectors/iceberg/iceberg_sink.rs | 34 +--
core/integration/tests/connectors/iceberg/mod.rs | 34 +--
.../tests/connectors/influxdb/influxdb_sink.rs | 34 +--
.../connectors/influxdb/influxdb_sink_formats.rs | 34 +--
.../tests/connectors/influxdb/influxdb_sink_v3.rs | 34 +--
.../tests/connectors/influxdb/influxdb_source.rs | 31 +-
.../connectors/influxdb/influxdb_source_formats.rs | 34 +--
.../connectors/influxdb/influxdb_source_v3.rs | 34 +--
core/integration/tests/connectors/influxdb/mod.rs | 34 +--
.../tests/connectors/influxdb/sink.toml | 6 +-
.../tests/connectors/influxdb/sink_base64.toml | 6 +-
.../connectors/influxdb/sink_no_metadata.toml | 6 +-
.../tests/connectors/influxdb/sink_text.toml | 6 +-
.../tests/connectors/influxdb/source.toml | 6 +-
.../tests/connectors/influxdb/source_raw.toml | 6 +-
.../tests/connectors/influxdb/source_text.toml | 6 +-
core/integration/tests/connectors/mod.rs | 34 +--
core/integration/tests/connectors/mongodb/mod.rs | 34 +--
.../tests/connectors/mongodb/mongodb_sink.rs | 34 +--
core/integration/tests/connectors/postgres/mod.rs | 34 +--
.../tests/connectors/postgres/postgres_sink.rs | 34 +--
.../tests/connectors/postgres/postgres_source.rs | 34 +--
.../tests/connectors/postgres/restart.rs | 34 +--
core/integration/tests/connectors/quickwit/mod.rs | 34 +--
.../tests/connectors/quickwit/quickwit_sink.rs | 34 +--
core/integration/tests/connectors/random/mod.rs | 34 +--
.../tests/connectors/random/random_source.rs | 34 +--
.../tests/connectors/random_source_liveness.rs | 34 +--
.../tests/connectors/runtime/benchmark.rs | 34 +--
.../tests/connectors/runtime/error_isolation.rs | 34 +--
core/integration/tests/connectors/runtime/mod.rs | 34 +--
core/integration/tests/connectors/stdout/mod.rs | 34 +--
.../tests/connectors/stdout/stdout_sink.rs | 34 +--
core/integration/tests/data_integrity/mod.rs | 33 +-
.../data_integrity/verify_after_server_restart.rs | 33 +-
.../verify_consumer_group_partition_assignment.rs | 33 +-
.../verify_no_plaintext_credentials_on_disk.rs | 33 +-
.../verify_user_login_after_restart.rs | 33 +-
core/integration/tests/mcp/mod.rs | 33 +-
core/integration/tests/mod.rs | 33 +-
core/integration/tests/sdk/clients.rs | 33 +-
core/integration/tests/sdk/hello_world.rs | 33 +-
core/integration/tests/sdk/mod.rs | 33 +-
core/integration/tests/sdk/producer/background.rs | 33 +-
core/integration/tests/sdk/producer/mod.rs | 33 +-
core/integration/tests/sdk/raw.rs | 33 +-
core/integration/tests/server/a2a_jwt/jwt_tests.rs | 34 +--
core/integration/tests/server/a2a_jwt/mod.rs | 34 +--
.../tests/server/concurrent_addition.rs | 33 +-
core/integration/tests/server/message_cleanup.rs | 33 +-
core/integration/tests/server/message_retrieval.rs | 33 +-
core/integration/tests/server/mod.rs | 33 +-
core/integration/tests/server/purge_delete.rs | 34 +--
.../server/scenarios/authentication_scenario.rs | 33 +-
.../tests/server/scenarios/bench_scenario.rs | 33 +-
.../concurrent_produce_consume_scenario.rs | 33 +-
.../tests/server/scenarios/concurrent_scenario.rs | 33 +-
...umer_group_auto_commit_reconnection_scenario.rs | 33 +-
.../scenarios/consumer_group_join_scenario.rs | 33 +-
...er_group_new_messages_after_restart_scenario.rs | 33 +-
.../consumer_group_offset_cleanup_scenario.rs | 33 +-
...h_multiple_clients_polling_messages_scenario.rs | 33 +-
...with_single_client_polling_messages_scenario.rs | 33 +-
.../consumer_timestamp_polling_scenario.rs | 33 +-
.../server/scenarios/create_message_payload.rs | 33 +-
.../scenarios/cross_protocol_pat_scenario.rs | 33 +-
.../tests/server/scenarios/encryption_scenario.rs | 33 +-
.../scenarios/invalid_consumer_offset_scenario.rs | 34 +--
.../server/scenarios/log_rotation_scenario.rs | 34 +--
.../server/scenarios/message_headers_scenario.rs | 33 +-
.../server/scenarios/message_size_scenario.rs | 33 +-
core/integration/tests/server/scenarios/mod.rs | 33 +-
.../tests/server/scenarios/offset_scenario.rs | 33 +-
.../tests/server/scenarios/permissions_scenario.rs | 33 +-
.../scenarios/read_during_persistence_scenario.rs | 33 +-
.../scenarios/reconnect_after_restart_scenario.rs | 33 +-
.../scenarios/restart_offset_skip_scenario.rs | 33 +-
.../scenarios/segment_rotation_race_scenario.rs | 33 +-
.../scenarios/single_message_per_batch_scenario.rs | 33 +-
.../tests/server/scenarios/snapshot_scenario.rs | 33 +-
.../stale_client_consumer_group_scenario.rs | 33 +-
.../scenarios/stream_size_validation_scenario.rs | 33 +-
.../tests/server/scenarios/system_scenario.rs | 33 +-
.../tests/server/scenarios/tcp_tls_scenario.rs | 33 +-
.../tests/server/scenarios/timestamp_scenario.rs | 33 +-
.../tests/server/scenarios/user_scenario.rs | 33 +-
.../server/scenarios/websocket_tls_scenario.rs | 33 +-
core/integration/tests/server/specific.rs | 34 +--
core/integration/tests/state/file.rs | 33 +-
core/integration/tests/state/mod.rs | 34 +--
core/integration/tests/state/system.rs | 33 +-
core/integration/tests/storage/consumer_offsets.rs | 33 +-
core/integration/tests/storage/mod.rs | 33 +-
core/message_bus/tests/tcp_tls_client_listener.rs | 7 -
core/message_bus/tests/tcp_tls_client_roundtrip.rs | 8 -
core/message_bus/tests/wss_client_listener.rs | 11 -
core/message_bus/tests/wss_client_roundtrip.rs | 8 -
core/metadata/src/impls/metadata.rs | 1 +
core/metadata/src/impls/mod.rs | 1 +
.../permissioner_rules/consumer_groups.rs | 33 +-
.../permissioner_rules/consumer_offsets.rs | 33 +-
.../permissioner/permissioner_rules/messages.rs | 33 +-
.../src/permissioner/permissioner_rules/mod.rs | 33 +-
.../permissioner/permissioner_rules/partitions.rs | 33 +-
.../permissioner/permissioner_rules/segments.rs | 33 +-
.../src/permissioner/permissioner_rules/streams.rs | 33 +-
.../src/permissioner/permissioner_rules/system.rs | 33 +-
.../src/permissioner/permissioner_rules/topics.rs | 33 +-
.../src/permissioner/permissioner_rules/users.rs | 33 +-
core/sdk/src/binary/mod.rs | 33 +-
core/sdk/src/client_provider.rs | 33 +-
core/sdk/src/client_wrappers/binary_client.rs | 33 +-
.../src/client_wrappers/binary_cluster_client.rs | 33 +-
.../binary_consumer_group_client.rs | 33 +-
.../binary_consumer_offset_client.rs | 33 +-
.../src/client_wrappers/binary_message_client.rs | 33 +-
.../src/client_wrappers/binary_partition_client.rs | 33 +-
.../binary_personal_access_token_client.rs | 33 +-
.../src/client_wrappers/binary_segment_client.rs | 33 +-
.../src/client_wrappers/binary_stream_client.rs | 33 +-
.../src/client_wrappers/binary_system_client.rs | 33 +-
.../sdk/src/client_wrappers/binary_topic_client.rs | 33 +-
core/sdk/src/client_wrappers/binary_user_client.rs | 33 +-
core/sdk/src/client_wrappers/client_wrapper.rs | 33 +-
core/sdk/src/client_wrappers/connection_info.rs | 33 +-
core/sdk/src/client_wrappers/mod.rs | 33 +-
core/sdk/src/clients/binary_cluster.rs | 33 +-
core/sdk/src/clients/binary_consumer_group.rs | 33 +-
core/sdk/src/clients/binary_consumer_offset.rs | 33 +-
core/sdk/src/clients/binary_message.rs | 33 +-
core/sdk/src/clients/binary_partitions.rs | 33 +-
.../src/clients/binary_personal_access_tokens.rs | 33 +-
core/sdk/src/clients/binary_segments.rs | 33 +-
core/sdk/src/clients/binary_streams.rs | 33 +-
core/sdk/src/clients/binary_system.rs | 33 +-
core/sdk/src/clients/binary_topics.rs | 33 +-
core/sdk/src/clients/binary_users.rs | 33 +-
core/sdk/src/clients/client.rs | 33 +-
core/sdk/src/clients/client_builder.rs | 33 +-
core/sdk/src/clients/consumer.rs | 33 +-
core/sdk/src/clients/consumer_builder.rs | 33 +-
core/sdk/src/clients/mod.rs | 33 +-
core/sdk/src/clients/producer.rs | 34 +--
core/sdk/src/clients/producer_config.rs | 34 +--
core/sdk/src/clients/producer_dispatcher.rs | 34 +--
core/sdk/src/clients/producer_error_callback.rs | 34 +--
core/sdk/src/clients/producer_sharding.rs | 34 +--
core/sdk/src/consumer_ext/consumer_message_ext.rs | 33 +-
.../sdk/src/consumer_ext/consumer_message_trait.rs | 33 +-
core/sdk/src/consumer_ext/mod.rs | 33 +-
core/sdk/src/http/cluster.rs | 33 +-
core/sdk/src/http/consumer_groups.rs | 33 +-
core/sdk/src/http/consumer_offsets.rs | 33 +-
core/sdk/src/http/http_client.rs | 33 +-
core/sdk/src/http/messages.rs | 33 +-
core/sdk/src/http/mod.rs | 33 +-
core/sdk/src/http/partitions.rs | 33 +-
core/sdk/src/http/personal_access_tokens.rs | 33 +-
core/sdk/src/http/segments.rs | 34 +--
core/sdk/src/http/streams.rs | 33 +-
core/sdk/src/http/system.rs | 33 +-
core/sdk/src/http/topics.rs | 33 +-
core/sdk/src/http/users.rs | 33 +-
core/sdk/src/leader_aware.rs | 33 +-
core/sdk/src/lib.rs | 33 +-
core/sdk/src/prelude.rs | 33 +-
core/sdk/src/quic/mod.rs | 33 +-
core/sdk/src/quic/quic_client.rs | 33 +-
core/sdk/src/session.rs | 34 +--
.../stream_builder/config/config_iggy_consumer.rs | 33 +-
.../stream_builder/config/config_iggy_producer.rs | 33 +-
.../stream_builder/config/config_iggy_stream.rs | 33 +-
core/sdk/src/stream_builder/config/mod.rs | 33 +-
core/sdk/src/stream_builder/iggy_stream.rs | 33 +-
.../sdk/src/stream_builder/iggy_stream_consumer.rs | 33 +-
.../sdk/src/stream_builder/iggy_stream_producer.rs | 33 +-
core/sdk/src/stream_builder/mod.rs | 33 +-
core/sdk/src/tcp/mod.rs | 33 +-
core/sdk/src/tcp/tcp_client.rs | 33 +-
core/sdk/src/tcp/tcp_connection_stream.rs | 33 +-
core/sdk/src/tcp/tcp_connection_stream_kind.rs | 34 +--
core/sdk/src/tcp/tcp_stream.rs | 33 +-
core/sdk/src/tcp/tcp_tls_connection_stream.rs | 33 +-
core/sdk/src/tcp/tcp_tls_verifier.rs | 33 +-
core/sdk/src/vsr.rs | 33 +-
core/sdk/src/websocket/mod.rs | 33 +-
core/sdk/src/websocket/websocket_client.rs | 33 +-
.../src/websocket/websocket_connection_stream.rs | 33 +-
core/sdk/src/websocket/websocket_stream.rs | 33 +-
core/sdk/src/websocket/websocket_stream_kind.rs | 33 +-
.../websocket/websocket_tls_connection_stream.rs | 33 +-
core/server-ng/build.rs | 33 +-
core/server-ng/src/args.rs | 34 +--
core/server-ng/src/auth.rs | 34 +--
core/server-ng/src/bootstrap.rs | 34 +--
core/server-ng/src/config_writer.rs | 34 +--
core/server-ng/src/dispatch.rs | 34 +--
core/server-ng/src/lib.rs | 34 +--
core/server-ng/src/login_register.rs | 34 +--
core/server-ng/src/main.rs | 34 +--
core/server-ng/src/pat.rs | 34 +--
core/server-ng/src/responses.rs | 34 +--
core/server-ng/src/server_error.rs | 34 +--
core/server-ng/src/session_manager.rs | 34 +--
core/server-ng/src/wire.rs | 34 +--
core/server/build.rs | 33 +-
core/server/src/args.rs | 33 +-
core/server/src/binary/dispatch.rs | 33 +-
.../cluster/get_cluster_metadata_handler.rs | 33 +-
core/server/src/binary/handlers/cluster/mod.rs | 33 +-
.../create_consumer_group_handler.rs | 33 +-
.../delete_consumer_group_handler.rs | 33 +-
.../consumer_groups/get_consumer_group_handler.rs | 33 +-
.../consumer_groups/get_consumer_groups_handler.rs | 33 +-
.../consumer_groups/join_consumer_group_handler.rs | 33 +-
.../leave_consumer_group_handler.rs | 33 +-
.../src/binary/handlers/consumer_groups/mod.rs | 33 +-
.../delete_consumer_offset_handler.rs | 33 +-
.../get_consumer_offset_handler.rs | 33 +-
.../src/binary/handlers/consumer_offsets/mod.rs | 33 +-
.../store_consumer_offset_handler.rs | 33 +-
.../messages/flush_unsaved_buffer_handler.rs | 33 +-
core/server/src/binary/handlers/messages/mod.rs | 33 +-
.../handlers/messages/poll_messages_handler.rs | 33 +-
.../handlers/messages/send_messages_handler.rs | 33 +-
core/server/src/binary/handlers/mod.rs | 33 +-
.../partitions/create_partitions_handler.rs | 33 +-
.../partitions/delete_partitions_handler.rs | 33 +-
core/server/src/binary/handlers/partitions/mod.rs | 33 +-
.../create_personal_access_token_handler.rs | 33 +-
.../delete_personal_access_token_handler.rs | 33 +-
.../get_personal_access_tokens_handler.rs | 33 +-
.../login_with_personal_access_token_handler.rs | 33 +-
.../binary/handlers/personal_access_tokens/mod.rs | 33 +-
.../handlers/segments/delete_segments_handler.rs | 33 +-
core/server/src/binary/handlers/segments/mod.rs | 34 +--
.../handlers/streams/create_stream_handler.rs | 33 +-
.../handlers/streams/delete_stream_handler.rs | 33 +-
.../binary/handlers/streams/get_stream_handler.rs | 33 +-
.../binary/handlers/streams/get_streams_handler.rs | 33 +-
core/server/src/binary/handlers/streams/mod.rs | 33 +-
.../handlers/streams/purge_stream_handler.rs | 33 +-
.../handlers/streams/update_stream_handler.rs | 33 +-
.../binary/handlers/system/get_client_handler.rs | 33 +-
.../binary/handlers/system/get_clients_handler.rs | 33 +-
.../src/binary/handlers/system/get_me_handler.rs | 33 +-
.../binary/handlers/system/get_snapshot_handler.rs | 33 +-
.../binary/handlers/system/get_stats_handler.rs | 33 +-
core/server/src/binary/handlers/system/mod.rs | 33 +-
.../src/binary/handlers/system/ping_handler.rs | 33 +-
.../binary/handlers/topics/create_topic_handler.rs | 33 +-
.../binary/handlers/topics/delete_topic_handler.rs | 33 +-
.../binary/handlers/topics/get_topic_handler.rs | 33 +-
.../binary/handlers/topics/get_topics_handler.rs | 33 +-
core/server/src/binary/handlers/topics/mod.rs | 33 +-
.../binary/handlers/topics/purge_topic_handler.rs | 33 +-
.../binary/handlers/topics/update_topic_handler.rs | 33 +-
.../handlers/users/change_password_handler.rs | 33 +-
.../binary/handlers/users/create_user_handler.rs | 33 +-
.../binary/handlers/users/delete_user_handler.rs | 33 +-
.../src/binary/handlers/users/get_user_handler.rs | 33 +-
.../src/binary/handlers/users/get_users_handler.rs | 33 +-
.../binary/handlers/users/login_user_handler.rs | 33 +-
.../binary/handlers/users/logout_user_handler.rs | 33 +-
core/server/src/binary/handlers/users/mod.rs | 33 +-
.../handlers/users/update_permissions_handler.rs | 33 +-
.../binary/handlers/users/update_user_handler.rs | 33 +-
core/server/src/binary/mod.rs | 33 +-
core/server/src/bootstrap.rs | 34 +--
.../src/compat/index_rebuilding/index_rebuilder.rs | 33 +-
core/server/src/compat/index_rebuilding/mod.rs | 33 +-
core/server/src/compat/mod.rs | 33 +-
core/server/src/configs.rs | 34 +--
core/server/src/diagnostics.rs | 33 +-
core/server/src/http/consumer_groups.rs | 33 +-
core/server/src/http/consumer_offsets.rs | 33 +-
core/server/src/http/diagnostics.rs | 33 +-
core/server/src/http/error.rs | 33 +-
core/server/src/http/http_server.rs | 34 +--
core/server/src/http/jwt/json_web_token.rs | 33 +-
core/server/src/http/jwt/jwks.rs | 33 +-
core/server/src/http/jwt/jwt_manager.rs | 33 +-
core/server/src/http/jwt/middleware.rs | 33 +-
core/server/src/http/jwt/mod.rs | 33 +-
core/server/src/http/jwt/storage.rs | 33 +-
core/server/src/http/mapper.rs | 33 +-
core/server/src/http/messages.rs | 33 +-
core/server/src/http/metrics.rs | 33 +-
core/server/src/http/mod.rs | 33 +-
core/server/src/http/partitions.rs | 33 +-
core/server/src/http/personal_access_tokens.rs | 33 +-
core/server/src/http/segments.rs | 33 +-
core/server/src/http/shared.rs | 33 +-
core/server/src/http/streams.rs | 33 +-
core/server/src/http/system.rs | 33 +-
core/server/src/http/topics.rs | 33 +-
core/server/src/http/users.rs | 33 +-
core/server/src/io/fs_utils.rs | 33 +-
core/server/src/lib.rs | 34 +--
core/server/src/log/logger.rs | 34 +--
core/server/src/log/mod.rs | 34 +--
core/server/src/main.rs | 34 +--
core/server/src/quic/listener.rs | 33 +-
core/server/src/quic/mod.rs | 33 +-
core/server/src/quic/quic_server.rs | 33 +-
core/server/src/quic/quic_socket.rs | 34 +--
core/server/src/sender/mod.rs | 33 +-
core/server/src/sender/quic_sender.rs | 33 +-
core/server/src/sender/tcp_sender.rs | 33 +-
core/server/src/sender/tcp_tls_sender.rs | 33 +-
core/server/src/sender/websocket_sender.rs | 33 +-
core/server/src/sender/websocket_tls_sender.rs | 33 +-
core/server/src/server_error.rs | 34 +--
core/server/src/shard/builder.rs | 34 +--
core/server/src/shard/mod.rs | 34 +--
core/server/src/shard/system/clients.rs | 33 +-
core/server/src/shard/system/cluster.rs | 33 +-
core/server/src/shard/system/consumer_groups.rs | 33 +-
core/server/src/shard/system/consumer_offsets.rs | 33 +-
core/server/src/shard/system/info.rs | 34 +--
core/server/src/shard/system/messages.rs | 33 +-
core/server/src/shard/system/mod.rs | 33 +-
core/server/src/shard/system/partitions.rs | 33 +-
.../src/shard/system/personal_access_tokens.rs | 33 +-
core/server/src/shard/system/segments.rs | 34 +--
core/server/src/shard/system/snapshot/mod.rs | 33 +-
core/server/src/shard/system/snapshot/procdump.rs | 33 +-
core/server/src/shard/system/stats.rs | 33 +-
core/server/src/shard/system/storage.rs | 33 +-
core/server/src/shard/system/streams.rs | 33 +-
core/server/src/shard/system/topics.rs | 33 +-
core/server/src/shard/system/users.rs | 33 +-
core/server/src/shard/systemd.rs | 34 +--
core/server/src/shard/task_registry/shutdown.rs | 33 +-
.../src/shard/tasks/continuous/http_server.rs | 33 +-
.../src/shard/tasks/continuous/message_pump.rs | 33 +-
core/server/src/shard/tasks/continuous/mod.rs | 33 +-
.../src/shard/tasks/continuous/quic_server.rs | 33 +-
.../src/shard/tasks/continuous/tcp_server.rs | 33 +-
.../src/shard/tasks/continuous/websocket_server.rs | 33 +-
core/server/src/shard/tasks/mod.rs | 33 +-
.../src/shard/tasks/periodic/heartbeat_verifier.rs | 33 +-
.../src/shard/tasks/periodic/jwt_token_cleaner.rs | 33 +-
.../src/shard/tasks/periodic/message_cleaner.rs | 33 +-
.../src/shard/tasks/periodic/message_saver.rs | 33 +-
core/server/src/shard/tasks/periodic/mod.rs | 33 +-
.../periodic/personal_access_token_cleaner.rs | 33 +-
.../src/shard/tasks/periodic/revocation_timeout.rs | 33 +-
.../src/shard/tasks/periodic/sysinfo_printer.rs | 33 +-
core/server/src/shard/transmission/connector.rs | 33 +-
core/server/src/shard/transmission/frame.rs | 34 +--
core/server/src/shard/transmission/message.rs | 34 +--
core/server/src/shard/transmission/mod.rs | 33 +-
core/server/src/shard_allocator.rs | 34 +--
core/server/src/state/command.rs | 33 +-
core/server/src/state/entry.rs | 33 +-
core/server/src/state/file.rs | 34 +--
core/server/src/state/mod.rs | 33 +-
core/server/src/state/models.rs | 33 +-
core/server/src/state/system.rs | 33 +-
.../server/src/streaming/clients/client_manager.rs | 33 +-
core/server/src/streaming/clients/mod.rs | 33 +-
core/server/src/streaming/deduplication/mod.rs | 33 +-
core/server/src/streaming/diagnostics/metrics.rs | 33 +-
core/server/src/streaming/diagnostics/mod.rs | 33 +-
core/server/src/streaming/mod.rs | 33 +-
core/server/src/streaming/partitions/mod.rs | 33 +-
core/server/src/streaming/partitions/ops.rs | 33 +-
core/server/src/streaming/partitions/segments.rs | 33 +-
core/server/src/streaming/persistence/mod.rs | 33 +-
core/server/src/streaming/persistence/persister.rs | 33 +-
core/server/src/streaming/polling_consumer.rs | 33 +-
core/server/src/streaming/segments/indexes/mod.rs | 33 +-
core/server/src/streaming/segments/messages/mod.rs | 33 +-
core/server/src/streaming/segments/mod.rs | 33 +-
core/server/src/streaming/segments/types/mod.rs | 33 +-
core/server/src/streaming/session.rs | 33 +-
core/server/src/streaming/storage.rs | 33 +-
core/server/src/streaming/streams/mod.rs | 33 +-
core/server/src/streaming/topics/mod.rs | 33 +-
core/server/src/streaming/users/mod.rs | 33 +-
core/server/src/streaming/users/user.rs | 34 +--
core/server/src/streaming/utils/address.rs | 33 +-
core/server/src/streaming/utils/crypto.rs | 33 +-
core/server/src/streaming/utils/file.rs | 33 +-
core/server/src/streaming/utils/mod.rs | 33 +-
core/server/src/tcp/connection_handler.rs | 33 +-
core/server/src/tcp/mod.rs | 33 +-
core/server/src/tcp/tcp_listener.rs | 33 +-
core/server/src/tcp/tcp_server.rs | 33 +-
core/server/src/tcp/tcp_socket.rs | 33 +-
core/server/src/tcp/tcp_tls_listener.rs | 33 +-
core/server/src/websocket/connection_handler.rs | 33 +-
core/server/src/websocket/websocket_listener.rs | 33 +-
core/server/src/websocket/websocket_server.rs | 33 +-
.../server/src/websocket/websocket_tls_listener.rs | 33 +-
core/server_common/Cargo.toml | 1 +
core/server_common/src/bootstrap.rs | 34 +--
core/server_common/src/buffer.rs | 33 +-
core/server_common/src/certificates.rs | 33 +-
.../src/deduplication/message_deduplicator.rs | 33 +-
core/server_common/src/deduplication/mod.rs | 33 +-
core/server_common/src/diagnostics.rs | 34 +--
core/server_common/src/executor.rs | 34 +--
core/server_common/src/in_flight.rs | 33 +-
core/server_common/src/indexes_mut.rs | 33 +-
core/server_common/src/lib.rs | 33 +-
core/server_common/src/memory_pool.rs | 33 +-
core/server_common/src/messages_batch_mut.rs | 33 +-
core/server_common/src/messages_batch_set.rs | 33 +-
core/tools/src/data-seeder/main.rs | 33 +-
core/tools/src/data-seeder/seeder.rs | 33 +-
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 22 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 22 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 22 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 22 +-
.../Iggy_SDK.Examples.Shared.csproj | 22 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 22 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 22 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 22 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 22 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 22 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 22 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 20 ++
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 20 ++
examples/java/gradle.properties | 2 -
examples/java/settings.gradle.kts | 1 +
examples/node/eslint.config.ts | 35 ++-
examples/node/src/basic/consumer.ts | 35 ++-
examples/node/src/basic/producer.ts | 35 ++-
examples/node/src/getting-started/consumer.ts | 35 ++-
examples/node/src/getting-started/producer.ts | 35 ++-
examples/node/src/index.ts | 35 ++-
examples/node/src/message-envelope/consumer.ts | 35 ++-
examples/node/src/message-envelope/producer.ts | 35 ++-
examples/node/src/message-headers/consumer.ts | 35 ++-
examples/node/src/message-headers/producer.ts | 35 ++-
examples/node/src/multi-tenant/consumer.ts | 35 ++-
examples/node/src/multi-tenant/producer.ts | 35 ++-
examples/node/src/sink-data-producer/producer.ts | 35 ++-
examples/node/src/stream-builder/example.ts | 35 ++-
examples/node/src/tcp-tls/consumer.ts | 35 ++-
examples/node/src/tcp-tls/producer.ts | 35 ++-
examples/node/src/utils/index.ts | 35 ++-
examples/php/basic/consumer.php | 35 +--
examples/php/basic/producer.php | 35 +--
examples/php/getting-started/consumer.php | 35 +--
examples/php/getting-started/producer.php | 35 +--
examples/php/src/common.php | 35 +--
examples/rust/src/basic/consumer/main.rs | 33 +-
examples/rust/src/basic/producer/main.rs | 33 +-
examples/rust/src/getting-started/consumer/main.rs | 33 +-
examples/rust/src/getting-started/producer/main.rs | 33 +-
examples/rust/src/lib.rs | 33 +-
.../rust/src/message-envelope/consumer/main.rs | 33 +-
.../rust/src/message-envelope/producer/main.rs | 33 +-
.../message-compression/consumer/main.rs | 33 +-
.../message-compression/producer/main.rs | 33 +-
.../message-headers/message-type/consumer/main.rs | 33 +-
.../message-headers/message-type/producer/main.rs | 33 +-
.../message-headers/typed-headers/consumer/main.rs | 33 +-
.../message-headers/typed-headers/producer/main.rs | 33 +-
examples/rust/src/multi-tenant/consumer/main.rs | 33 +-
examples/rust/src/multi-tenant/producer/main.rs | 33 +-
examples/rust/src/new-sdk/consumer/main.rs | 33 +-
examples/rust/src/new-sdk/producer/main.rs | 33 +-
examples/rust/src/shared/args.rs | 33 +-
examples/rust/src/shared/client.rs | 33 +-
examples/rust/src/shared/codec.rs | 33 +-
examples/rust/src/shared/messages.rs | 33 +-
examples/rust/src/shared/messages_generator.rs | 33 +-
examples/rust/src/shared/mod.rs | 33 +-
examples/rust/src/shared/stream.rs | 33 +-
examples/rust/src/shared/system.rs | 33 +-
examples/rust/src/sink-data-producer/main.rs | 33 +-
.../rust/src/stream-builder/stream-basic/main.rs | 33 +-
.../stream-builder/stream-consumer-config/main.rs | 33 +-
.../src/stream-builder/stream-consumer/main.rs | 33 +-
.../stream-builder/stream-producer-config/main.rs | 33 +-
.../src/stream-builder/stream-producer/main.rs | 33 +-
examples/rust/src/tcp-tls/consumer/main.rs | 33 +-
examples/rust/src/tcp-tls/producer/main.rs | 33 +-
foreign/cpp/include/iggy.hpp | 34 ++-
foreign/cpp/src/lib.rs | 1 +
foreign/cpp/tests/client/low_level_e2e.cpp | 36 +--
foreign/cpp/tests/common/test_helpers.hpp | 34 ++-
foreign/cpp/tests/consumer_group/low_level_e2e.cpp | 34 ++-
foreign/cpp/tests/identifier/unit_tests.cpp | 34 ++-
foreign/cpp/tests/message/low_level_e2e.cpp | 34 ++-
foreign/cpp/tests/message/unit_tests.cpp | 34 ++-
foreign/cpp/tests/partition/low_level_e2e.cpp | 34 ++-
foreign/cpp/tests/stream/low_level_e2e.cpp | 34 ++-
foreign/cpp/tests/topic/low_level_e2e.cpp | 34 ++-
foreign/cpp/tests/unit_tests.cpp | 34 ++-
foreign/csharp/Benchmarks/Benchmarks.csproj | 20 ++
foreign/csharp/Benchmarks/Program.cs | 4 +-
foreign/csharp/Directory.Build.props | 20 ++
foreign/csharp/Directory.Packages.props | 20 ++
.../Iggy_SDK.Tests.BDD/Context/TestContext.cs | 32 +-
.../csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs | 32 +-
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 20 ++
.../BasicMessagingOperationsSteps.cs | 32 +-
.../Attributes/SkipHttpAttribute.cs | 32 +-
.../Attributes/SkipTcpAttribute.cs | 32 +-
.../ConsumerGroupTests.cs | 32 +-
.../FetchMessagesTests.cs | 32 +-
.../FlushMessagesTests.cs | 32 +-
.../IggyConsumerTests.cs | 32 +-
.../IggyPublisherTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration.csproj | 20 ++
.../Iggy_SDK.Tests.Integration/OffsetTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration/PartitionsTests.cs | 32 +-
.../PersonalAccessTokenTests.cs | 32 +-
.../SendMessagesTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 32 +-
.../Iggy_SDK.Tests.Integration/UsersTests.cs | 32 +-
.../Iggy_SDK/Contracts/Http/ErrorResponse.cs | 32 +-
.../Exceptions/ConsumerGroupNotFoundException.cs | 22 +-
.../Iggy_SDK/Exceptions/MissingLeaderException.cs | 32 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 20 ++
.../Iggy_SDK/JsonConverters/ConsumerConverter.cs | 32 +-
.../Iggy_SDK/JsonConverters/SizeConverter.cs | 22 +-
.../csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj | 20 ++
.../UtilityTests/EventAggregatorTests.cs | 32 +-
foreign/csharp/Shared/Shared.csproj | 20 ++
foreign/go/contracts/cluster_node.go | 33 +-
foreign/go/contracts/role.go | 33 +-
foreign/go/contracts/transport_endpoints.go | 33 +-
foreign/java/dev-support/checkstyle/checkstyle.xml | 34 ++-
.../java/dev-support/checkstyle/suppressions.xml | 30 +-
foreign/java/gradle.properties | 2 -
.../src/main/resources/iggy-version.properties | 17 ++
.../java-sdk/src/test/resources/logback-test.xml | 35 +--
foreign/node/src/bdd/auth.ts | 36 ++-
foreign/node/src/bdd/message.ts | 35 ++-
foreign/node/src/bdd/stream.ts | 36 ++-
foreign/node/src/bdd/topic.ts | 36 ++-
foreign/node/src/bdd/world.ts | 36 ++-
foreign/node/src/client.e2e.ts | 40 ++-
foreign/node/src/client/client.connection.ts | 36 ++-
foreign/node/src/client/client.debug.ts | 36 ++-
foreign/node/src/client/client.socket.ts | 36 ++-
foreign/node/src/client/client.ts | 36 ++-
foreign/node/src/client/client.type.ts | 36 ++-
foreign/node/src/client/client.utils.test.ts | 35 ++-
foreign/node/src/client/client.utils.ts | 36 ++-
foreign/node/src/client/index.ts | 36 ++-
foreign/node/src/debug-send.ts | 36 ++-
foreign/node/src/debug.ts | 35 ++-
foreign/node/src/e2e/tcp.client.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.cluster.e2e.ts | 35 ++-
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.parallel.e2e.ts | 38 ++-
foreign/node/src/e2e/tcp.send-message.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.stream.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.system.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.token.e2e.ts | 40 ++-
foreign/node/src/e2e/tcp.topic.e2e.ts | 36 ++-
foreign/node/src/e2e/tcp.user.e2e.ts | 40 ++-
foreign/node/src/e2e/test-client.utils.ts | 35 ++-
foreign/node/src/e2e/tls.system.e2e.ts | 35 ++-
foreign/node/src/examples/stream-file-to-topic.ts | 35 ++-
foreign/node/src/examples/stream-topic-to-file.ts | 36 ++-
foreign/node/src/examples/utils.ts | 36 ++-
foreign/node/src/index.ts | 35 ++-
foreign/node/src/stream/consumer-stream.ts | 36 ++-
foreign/node/src/stream/index.ts | 36 ++-
foreign/node/src/tcp.e2e.ts | 36 ++-
foreign/node/src/tcp.sm.utils.ts | 35 ++-
foreign/node/src/tls.system.e2e.ts | 36 ++-
foreign/node/src/type.utils.ts | 36 ++-
foreign/node/src/wire/client/client.utils.ts | 36 ++-
foreign/node/src/wire/client/get-client.command.ts | 36 ++-
.../node/src/wire/client/get-clients.command.ts | 36 ++-
foreign/node/src/wire/client/get-me.command.ts | 36 ++-
foreign/node/src/wire/client/index.ts | 36 ++-
foreign/node/src/wire/cluster/cluster.type.ts | 35 ++-
foreign/node/src/wire/cluster/cluster.utils.ts | 35 ++-
.../wire/cluster/get-cluster-metadata.command.ts | 35 ++-
foreign/node/src/wire/cluster/index.ts | 35 ++-
foreign/node/src/wire/command-set.ts | 36 ++-
foreign/node/src/wire/command.code.ts | 36 ++-
foreign/node/src/wire/command.utils.ts | 36 ++-
.../consumer-group/create-group.command.test.ts | 36 ++-
.../wire/consumer-group/create-group.command.ts | 36 ++-
.../wire/consumer-group/delete-group.command.ts | 36 ++-
.../consumer-group/ensure-group.virtual.command.ts | 36 ++-
.../src/wire/consumer-group/get-group.command.ts | 36 ++-
.../src/wire/consumer-group/get-groups.command.ts | 36 ++-
.../src/wire/consumer-group/group.command.test.ts | 42 ++-
.../node/src/wire/consumer-group/group.utils.ts | 36 ++-
foreign/node/src/wire/consumer-group/index.ts | 36 ++-
.../src/wire/consumer-group/join-group.command.ts | 36 ++-
.../src/wire/consumer-group/leave-group.command.ts | 36 ++-
foreign/node/src/wire/error.code.ts | 39 ++-
foreign/node/src/wire/error.utils.ts | 36 ++-
foreign/node/src/wire/identifier.utils.test.ts | 36 ++-
foreign/node/src/wire/identifier.utils.ts | 36 ++-
foreign/node/src/wire/index.ts | 36 ++-
.../wire/message/flush-unsaved-buffers.command.ts | 36 ++-
foreign/node/src/wire/message/header.type.ts | 35 ++-
foreign/node/src/wire/message/header.utils.test.ts | 35 ++-
foreign/node/src/wire/message/header.utils.ts | 35 ++-
foreign/node/src/wire/message/iggy-header.utils.ts | 35 ++-
foreign/node/src/wire/message/index.ts | 35 ++-
foreign/node/src/wire/message/message.utils.ts | 36 ++-
.../node/src/wire/message/partitioning.utils.ts | 36 ++-
.../node/src/wire/message/poll-messages.command.ts | 36 ++-
foreign/node/src/wire/message/poll.utils.ts | 35 ++-
.../src/wire/message/send-messages.command.test.ts | 35 ++-
.../node/src/wire/message/send-messages.command.ts | 36 ++-
foreign/node/src/wire/number.utils.ts | 36 ++-
.../node/src/wire/offset/delete-offset.command.ts | 36 ++-
foreign/node/src/wire/offset/get-offset.command.ts | 36 ++-
foreign/node/src/wire/offset/index.ts | 36 ++-
foreign/node/src/wire/offset/offset.utils.ts | 36 ++-
.../node/src/wire/offset/store-offset.command.ts | 36 ++-
.../src/wire/partition/create-partition.command.ts | 36 ++-
.../src/wire/partition/delete-partition.command.ts | 36 ++-
foreign/node/src/wire/partition/index.ts | 36 ++-
.../src/wire/partition/partition.utils.test.ts | 36 ++-
foreign/node/src/wire/partition/partition.utils.ts | 36 ++-
.../src/wire/segment/delete-segments.command.ts | 36 ++-
foreign/node/src/wire/segment/index.ts | 36 ++-
foreign/node/src/wire/segment/segment.utils.ts | 36 ++-
foreign/node/src/wire/serialize.utils.ts | 36 ++-
foreign/node/src/wire/session/index.ts | 36 ++-
.../wire/session/login-with-token.command.test.ts | 36 ++-
.../src/wire/session/login-with-token.command.ts | 36 ++-
.../node/src/wire/session/login.command.test.ts | 36 ++-
foreign/node/src/wire/session/login.command.ts | 36 ++-
foreign/node/src/wire/session/login.utils.ts | 35 ++-
foreign/node/src/wire/session/logout.command.ts | 36 ++-
.../src/wire/stream/create-stream.command.test.ts | 36 ++-
.../node/src/wire/stream/create-stream.command.ts | 36 ++-
.../node/src/wire/stream/delete-stream.command.ts | 36 ++-
.../wire/stream/ensure-stream.virtual.command.ts | 36 ++-
foreign/node/src/wire/stream/get-stream.command.ts | 36 ++-
.../node/src/wire/stream/get-streams.command.ts | 36 ++-
foreign/node/src/wire/stream/index.ts | 36 ++-
.../node/src/wire/stream/purge-stream.command.ts | 36 ++-
foreign/node/src/wire/stream/stream.utils.ts | 36 ++-
.../node/src/wire/stream/update-stream.command.ts | 35 ++-
foreign/node/src/wire/system/get-stats.command.ts | 36 ++-
foreign/node/src/wire/system/index.ts | 36 ++-
foreign/node/src/wire/system/ping.command.ts | 38 ++-
.../src/wire/token/create-token.command.test.ts | 36 ++-
.../node/src/wire/token/create-token.command.ts | 36 ++-
.../src/wire/token/delete-token.command.test.ts | 36 ++-
.../node/src/wire/token/delete-token.command.ts | 36 ++-
foreign/node/src/wire/token/get-tokens.command.ts | 36 ++-
foreign/node/src/wire/token/index.ts | 36 ++-
foreign/node/src/wire/token/token.utils.ts | 36 ++-
.../src/wire/topic/create-topic.command.test.ts | 36 ++-
.../node/src/wire/topic/create-topic.command.ts | 36 ++-
.../node/src/wire/topic/delete-topic.command.ts | 36 ++-
.../src/wire/topic/ensure-topic.virtual.command.ts | 36 ++-
foreign/node/src/wire/topic/get-topic.command.ts | 36 ++-
foreign/node/src/wire/topic/get-topics.command.ts | 36 ++-
foreign/node/src/wire/topic/index.ts | 36 ++-
foreign/node/src/wire/topic/purge-topic.command.ts | 36 ++-
foreign/node/src/wire/topic/topic.utils.ts | 36 ++-
.../node/src/wire/topic/update-topic.command.ts | 36 ++-
.../node/src/wire/user/change-password.command.ts | 36 ++-
.../node/src/wire/user/create-user.command.test.ts | 36 ++-
foreign/node/src/wire/user/create-user.command.ts | 36 ++-
foreign/node/src/wire/user/delete-user.command.ts | 36 ++-
foreign/node/src/wire/user/get-user.command.ts | 36 ++-
foreign/node/src/wire/user/get-users.command.ts | 36 ++-
foreign/node/src/wire/user/index.ts | 36 ++-
.../node/src/wire/user/permissions.utils.test.ts | 36 ++-
foreign/node/src/wire/user/permissions.utils.ts | 36 ++-
.../src/wire/user/update-permissions.command.ts | 36 ++-
foreign/node/src/wire/user/update-user.command.ts | 36 ++-
foreign/node/src/wire/user/user.utils.ts | 36 ++-
foreign/node/src/wire/uuid.utils.ts | 36 ++-
foreign/php/phpunit.xml.dist | 20 ++
foreign/php/src/client.rs | 33 +-
foreign/php/src/consumer.rs | 33 +-
foreign/php/src/error.rs | 33 +-
foreign/php/src/identifier.rs | 33 +-
foreign/php/src/lib.rs | 33 +-
foreign/php/src/receive_message.rs | 33 +-
foreign/php/src/runtime.rs | 33 +-
foreign/php/src/send_message.rs | 33 +-
foreign/php/src/stream.rs | 33 +-
foreign/php/src/topic.rs | 33 +-
foreign/php/tests/ErrorTest.php | 35 +--
foreign/php/tests/IggySdkTest.php | 35 +--
foreign/php/tests/TlsTest.php | 35 +--
foreign/php/tests/bootstrap.php | 35 +--
foreign/python/src/client.rs | 33 +-
foreign/python/src/consumer.rs | 33 +-
foreign/python/src/identifier.rs | 33 +-
foreign/python/src/iterator.rs | 33 +-
foreign/python/src/lib.rs | 33 +-
foreign/python/src/receive_message.rs | 33 +-
foreign/python/src/send_message.rs | 33 +-
foreign/python/src/stream.rs | 33 +-
foreign/python/src/topic.rs | 33 +-
helm/charts/iggy/templates/deployment.yaml | 1 +
helm/charts/iggy/templates/hpa.yaml | 1 +
helm/charts/iggy/templates/ingress.yaml | 1 +
.../iggy/templates/root-user-credentials.yaml | 3 +-
helm/charts/iggy/templates/service.yaml | 1 +
licenserc.toml | 143 +++++++++
scripts/check-backwards-compat.sh | 2 -
scripts/ci/license-headers.sh | 334 +++++++++++++++++----
scripts/ci/setup-helm-smoke-cluster.sh | 2 -
scripts/ci/setup-helm-tools.sh | 2 -
scripts/ci/shellcheck.sh | 2 -
scripts/ci/test-helm.sh | 2 -
scripts/ci/third-party-licenses.sh | 1 -
scripts/cross-docker-entrypoint.sh | 1 -
.../performance/run-standard-performance-suite.sh | 1 -
scripts/performance/utils.sh | 1 -
scripts/prepare-cross-toml.sh | 1 -
scripts/prepare-release.sh | 1 -
scripts/profile.sh | 1 -
scripts/run-benches.sh | 1 -
scripts/run-examples-from-readme.sh | 1 -
scripts/utils.sh | 1 -
web/docs/server-api.http | 17 ++
web/eslint.config.js | 34 +--
web/justfile | 17 ++
web/postcss.config.js | 34 +--
web/src/ambient.d.ts | 34 +--
web/src/app.d.ts | 34 +--
web/src/app.html | 31 +-
web/src/hooks.client.ts | 34 +--
web/src/lib/actions/tooltip.ts | 34 +--
web/src/lib/api/ApiSchema.ts | 34 +--
web/src/lib/api/clientApi.ts | 34 +--
web/src/lib/api/convertBigIntsToStrings.ts | 34 +--
web/src/lib/api/fetchApi.ts | 34 +--
web/src/lib/api/fetchRouteApi.ts | 34 +--
web/src/lib/api/getJson.ts | 34 +--
web/src/lib/api/handleFetchErrors.ts | 34 +--
web/src/lib/auth/authStore.svelte.ts | 34 +--
web/src/lib/components/AppToasts.svelte | 35 +--
web/src/lib/components/Breadcrumbs.svelte | 35 +--
web/src/lib/components/Button.svelte | 31 +-
web/src/lib/components/Checkbox.svelte | 35 +--
web/src/lib/components/Combobox.svelte | 35 +--
.../components/DeleteButtonWithConfirmation.svelte | 31 +-
.../components/DropdownMenu/DropdownMenu.svelte | 31 +-
web/src/lib/components/DurationInput.svelte | 35 +--
web/src/lib/components/FixedSvelteComponent.svelte | 35 +--
web/src/lib/components/Header.svelte | 31 +-
web/src/lib/components/Icon.svelte | 31 +-
web/src/lib/components/Input.svelte | 31 +-
.../lib/components/Layouts/SettingsLayout.svelte | 31 +-
web/src/lib/components/Listbox.svelte | 31 +-
web/src/lib/components/Loader.svelte | 35 +--
web/src/lib/components/LoadingIndicator.svelte | 31 +-
web/src/lib/components/Logo/Logo.svelte | 31 +-
web/src/lib/components/Logo/LogoMark.svelte | 31 +-
web/src/lib/components/Logo/LogoType.svelte | 31 +-
.../MessageDecoder/MessageDecoder.svelte | 35 +--
.../decoders/BuiltInDecoders/jsonDecoder.ts | 34 +--
.../decoders/BuiltInDecoders/stringDecoder.ts | 34 +--
.../decoders/BuiltInDecoders/xmlDecoder.ts | 34 +--
.../components/MessageDecoder/decoders/types.ts | 34 +--
.../decoders/utils/decoderRegistry.ts | 34 +--
web/src/lib/components/ModalConfirmation.svelte | 31 +-
.../components/Modals/AddPartitionsModal.svelte | 31 +-
.../lib/components/Modals/AddStreamModal.svelte | 31 +-
web/src/lib/components/Modals/AddTopicModal.svelte | 35 +--
web/src/lib/components/Modals/AddUserModal.svelte | 35 +--
web/src/lib/components/Modals/AppModals.svelte | 31 +-
.../components/Modals/DeletePartitionsModal.svelte | 35 +--
.../lib/components/Modals/DeleteUserModal.svelte | 35 +--
web/src/lib/components/Modals/EditUserModal.svelte | 35 +--
.../Modals/EditUserPermissionsModal.svelte | 35 +--
.../lib/components/Modals/InspectMessage.svelte | 35 +--
web/src/lib/components/Modals/ModalBase.svelte | 31 +-
.../components/Modals/StreamSettingsModal.svelte | 35 +--
.../components/Modals/TopicSettingsModal.svelte | 35 +--
web/src/lib/components/Navbar.svelte | 31 +-
web/src/lib/components/Paginator.svelte | 35 +--
web/src/lib/components/PasswordInput.svelte | 31 +-
web/src/lib/components/PeriodicInvalidator.svelte | 31 +-
web/src/lib/components/PermissionsManager.svelte | 35 +--
.../lib/components/PreventEventsPropagation.svelte | 31 +-
web/src/lib/components/RangeInput.svelte | 31 +-
.../RouteComponents/Settings/UsersTab.svelte | 35 +--
.../Settings/UsersTabActions.svelte | 31 +-
web/src/lib/components/SegmentedControl.svelte | 31 +-
web/src/lib/components/Select.svelte | 31 +-
web/src/lib/components/SlimSortableList.svelte | 35 +--
web/src/lib/components/SortableList.svelte | 35 +--
web/src/lib/components/StopPropagation.svelte | 31 +-
web/src/lib/components/ThemeController.svelte | 31 +-
web/src/lib/components/Toggler.svelte | 35 +--
web/src/lib/domain/Message.ts | 34 +--
web/src/lib/domain/MessageDetails.ts | 34 +--
web/src/lib/domain/Partition.ts | 34 +--
web/src/lib/domain/Permissions.ts | 34 +--
web/src/lib/domain/Stats.ts | 34 +--
web/src/lib/domain/Stream.ts | 34 +--
web/src/lib/domain/StreamDetails.ts | 34 +--
web/src/lib/domain/Topic.ts | 34 +--
web/src/lib/domain/TopicDetails.ts | 34 +--
web/src/lib/domain/User.ts | 34 +--
web/src/lib/domain/UserDetails.ts | 34 +--
web/src/lib/hooks/useGoPrev.ts | 34 +--
web/src/lib/queries.ts | 34 +--
web/src/lib/types/appRoutes.ts | 34 +--
web/src/lib/types/utilTypes.ts | 34 +--
web/src/lib/utils/NonNullable.ts | 34 +--
web/src/lib/utils/addOnKeyDownListener.ts | 34 +--
web/src/lib/utils/addWindowEventListener.ts | 34 +--
web/src/lib/utils/arrayMax.ts | 34 +--
web/src/lib/utils/arraySum.ts | 34 +--
web/src/lib/utils/asConst.ts | 34 +--
web/src/lib/utils/base64Utils.ts | 34 +--
web/src/lib/utils/constants/keys.ts | 34 +--
web/src/lib/utils/constants/numberSizes.ts | 34 +--
web/src/lib/utils/constants/tokens.ts | 34 +--
web/src/lib/utils/dataHas.ts | 34 +--
web/src/lib/utils/formatters/bytesFormatter.ts | 34 +--
web/src/lib/utils/formatters/dateFormatter.ts | 34 +--
web/src/lib/utils/formatters/durationFormatter.ts | 34 +--
web/src/lib/utils/formatters/uuidFormatter.ts | 34 +--
web/src/lib/utils/noTypeCheck.ts | 34 +--
web/src/lib/utils/parsers.ts | 34 +--
web/src/lib/utils/persistedStore.ts | 34 +--
web/src/lib/utils/queryParsers.ts | 34 +--
web/src/lib/utils/utilTypes.ts | 34 +--
web/src/params/i32.ts | 34 +--
web/src/routes/+error.svelte | 31 +-
web/src/routes/+layout.svelte | 31 +-
web/src/routes/+layout.ts | 34 +--
web/src/routes/auth/+layout.svelte | 31 +-
web/src/routes/auth/logout/+page.svelte | 31 +-
web/src/routes/auth/sign-in/+page.svelte | 35 +--
web/src/routes/auth/sign-in/+page.ts | 34 +--
web/src/routes/dashboard/+layout.svelte | 35 +--
web/src/routes/dashboard/+layout.ts | 34 +--
web/src/routes/dashboard/clients/+page.svelte | 31 +-
web/src/routes/dashboard/logs/+page.svelte | 31 +-
web/src/routes/dashboard/overview/+page.svelte | 35 +--
web/src/routes/dashboard/overview/+page.ts | 34 +--
.../routes/dashboard/settings/server/+page.svelte | 31 +-
web/src/routes/dashboard/settings/server/+page.ts | 34 +--
.../dashboard/settings/terminal/+page.svelte | 31 +-
.../routes/dashboard/settings/users/+page.svelte | 35 +--
web/src/routes/dashboard/settings/users/+page.ts | 34 +--
.../routes/dashboard/settings/webUI/+page.svelte | 31 +-
web/src/routes/dashboard/streams/+layout.svelte | 31 +-
web/src/routes/dashboard/streams/+layout.ts | 34 +--
web/src/routes/dashboard/streams/+page.svelte | 31 +-
.../dashboard/streams/[streamId=i32]/+page.svelte | 31 +-
.../dashboard/streams/[streamId=i32]/+page.ts | 34 +--
.../streams/[streamId=i32]/topics/+page.svelte | 31 +-
.../topics/[topicId=i32]/+page.svelte | 31 +-
.../[streamId=i32]/topics/[topicId=i32]/+page.ts | 34 +--
.../partitions/[partitionId=i32]/+page.svelte | 31 +-
.../[partitionId=i32]/messages/+page.svelte | 35 +--
.../partitions/[partitionId=i32]/messages/+page.ts | 34 +--
web/src/routes/healthz/+server.ts | 34 +--
web/src/styles/app.css | 2 +-
web/src/styles/tooltip.css | 2 +-
web/src/styles/variables.css | 4 +-
web/svelte.config.js | 34 +--
web/vite.config.ts | 34 +--
1542 files changed, 24715 insertions(+), 25534 deletions(-)
create mode 100644 .github/config/hawkeye.version
create mode 100644 licenserc.toml
