This is an automated email from the ASF dual-hosted git repository.
bciesla pushed a change to branch new-pr-ci-flow
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard 0c7cb490 chore(ci): add new CI workflows for PR validation and testing
add 4018aa36 fix(server): fix server state by storing numeric ID of the
resources (#1622)
add f9f8433b chore(repo): add ASF license header to all the files (#1627)
add b95c196b chore(ci): add new CI workflows for PR validation and testing
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 (0c7cb490)
\
N -- N -- N refs/heads/new-pr-ci-flow (b95c196b)
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:
.config/nextest.toml | 17 +
.github/CODEOWNERS | 2 +-
.github/dependabot.yml | 17 +
.github/workflows/post_publish_server.yml | 17 +
.github/workflows/publish_cli.yml | 17 +
.github/workflows/publish_sdk.yml | 17 +
.github/workflows/publish_server.yml | 19 +-
.github/workflows/release_cli.yml | 17 +
.github/workflows/release_sdk.yml | 17 +
.github/workflows/release_server.yml | 17 +
.github/workflows/sanity.yml | 17 +
.github/workflows/security.yml | 17 +
.github/workflows/test.yml | 17 +
.github/workflows/test_daily.yml | 17 +
.github/workflows/test_nightly.yml | 17 +
.github/workflows/test_pr.yml | 17 +
Cargo.lock | 640 ++++++++++++---------
Cargo.toml | 17 +
Dockerfile | 17 +
Dockerfile.ci | 17 +
Dockerfile.ci.dockerignore | 17 +
Dockerfile.cross | 17 +
Dockerfile.cross.dockerignore | 17 +
README.md | 10 +-
bench/Cargo.toml | 31 +-
bench/report/Cargo.toml | 19 +-
bench/report/src/lib.rs | 18 +
bench/report/src/plotting/chart.rs | 18 +
bench/report/src/plotting/chart_kind.rs | 18 +
bench/report/src/plotting/mod.rs | 18 +
bench/report/src/plotting/text/mod.rs | 18 +
bench/report/src/plotting/text/subtext.rs | 18 +
bench/report/src/plotting/text/title.rs | 18 +
bench/report/src/prints.rs | 18 +
bench/report/src/types/actor_kind.rs | 18 +
bench/report/src/types/benchmark_kind.rs | 18 +
bench/report/src/types/group_metrics.rs | 18 +
bench/report/src/types/group_metrics_kind.rs | 18 +
bench/report/src/types/group_metrics_summary.rs | 18 +
bench/report/src/types/hardware.rs | 18 +
bench/report/src/types/individual_metrics.rs | 18 +
.../report/src/types/individual_metrics_summary.rs | 18 +
bench/report/src/types/mod.rs | 18 +
bench/report/src/types/params.rs | 18 +
bench/report/src/types/report.rs | 18 +
bench/report/src/types/server_stats.rs | 18 +
bench/report/src/types/time_series.rs | 18 +
bench/report/src/types/transport.rs | 18 +
bench/report/src/utils.rs | 18 +
bench/src/actors/consumer.rs | 18 +
bench/src/actors/mod.rs | 18 +
bench/src/actors/producer.rs | 18 +
bench/src/actors/producing_consumer.rs | 18 +
bench/src/actors/utils.rs | 18 +
bench/src/analytics/metrics/group.rs | 18 +
bench/src/analytics/metrics/individual.rs | 18 +
bench/src/analytics/metrics/mod.rs | 18 +
bench/src/analytics/mod.rs | 18 +
bench/src/analytics/record.rs | 18 +
bench/src/analytics/report_builder.rs | 18 +
bench/src/analytics/time_series/calculator.rs | 18 +
.../analytics/time_series/calculators/latency.rs | 18 +
bench/src/analytics/time_series/calculators/mod.rs | 18 +
.../time_series/calculators/throughput.rs | 18 +
bench/src/analytics/time_series/mod.rs | 18 +
bench/src/analytics/time_series/processors/mod.rs | 18 +
.../time_series/processors/moving_average.rs | 18 +
bench/src/args/common.rs | 18 +
bench/src/args/defaults.rs | 18 +
bench/src/args/examples.rs | 18 +
bench/src/args/kind.rs | 18 +
bench/src/args/kinds/balanced/consumer_group.rs | 18 +
bench/src/args/kinds/balanced/mod.rs | 18 +
bench/src/args/kinds/balanced/producer.rs | 18 +
.../kinds/balanced/producer_and_consumer_group.rs | 18 +
bench/src/args/kinds/end_to_end/mod.rs | 18 +
.../args/kinds/end_to_end/producing_consumer.rs | 18 +
.../kinds/end_to_end/producing_consumer_group.rs | 18 +
bench/src/args/kinds/mod.rs | 18 +
bench/src/args/kinds/pinned/consumer.rs | 18 +
bench/src/args/kinds/pinned/mod.rs | 18 +
bench/src/args/kinds/pinned/producer.rs | 18 +
.../src/args/kinds/pinned/producer_and_consumer.rs | 18 +
bench/src/args/mod.rs | 18 +
bench/src/args/output.rs | 18 +
bench/src/args/props.rs | 18 +
bench/src/args/transport.rs | 18 +
bench/src/benchmarks/benchmark.rs | 18 +
bench/src/benchmarks/consumer_benchmark.rs | 18 +
bench/src/benchmarks/consumer_group_benchmark.rs | 18 +
bench/src/benchmarks/mod.rs | 18 +
.../benchmarks/producer_and_consumer_benchmark.rs | 18 +
.../producer_and_consumer_group_benchmark.rs | 18 +
bench/src/benchmarks/producer_benchmark.rs | 18 +
.../src/benchmarks/producing_consumer_benchmark.rs | 18 +
.../producing_consumer_group_benchmark.rs | 18 +
bench/src/main.rs | 18 +
bench/src/plot.rs | 18 +
bench/src/rate_limiter/mod.rs | 18 +
bench/src/runner.rs | 18 +
bench/src/utils/client_factory.rs | 18 +
bench/src/utils/cpu_name.rs | 18 +
bench/src/utils/mod.rs | 18 +
bench/src/utils/server_starter.rs | 18 +
cli/Cargo.toml | 33 +-
cli/src/args/client.rs | 18 +
cli/src/args/common.rs | 18 +
cli/src/args/consumer_group.rs | 18 +
cli/src/args/consumer_offset.rs | 18 +
cli/src/args/context.rs | 18 +
cli/src/args/message.rs | 18 +
cli/src/args/mod.rs | 18 +
cli/src/args/partition.rs | 18 +
cli/src/args/permissions/constants.rs | 18 +
cli/src/args/permissions/global.rs | 18 +
cli/src/args/permissions/mod.rs | 18 +
cli/src/args/permissions/stream.rs | 18 +
cli/src/args/permissions/topic.rs | 18 +
cli/src/args/personal_access_token.rs | 18 +
cli/src/args/stream.rs | 18 +
cli/src/args/system.rs | 18 +
cli/src/args/topic.rs | 18 +
cli/src/args/user.rs | 18 +
cli/src/credentials.rs | 18 +
cli/src/error.rs | 18 +
cli/src/logging.rs | 18 +
cli/src/main.rs | 18 +
cliff.toml | 17 +
configs/server.toml | 31 +-
dependencies.md | 1 -
docker-compose.yml | 17 +
examples/Cargo.toml | 29 +-
examples/src/basic/consumer/main.rs | 18 +
examples/src/basic/producer/main.rs | 18 +
examples/src/getting-started/consumer/main.rs | 18 +
examples/src/getting-started/producer/main.rs | 18 +
examples/src/lib.rs | 18 +
examples/src/message-envelope/consumer/main.rs | 18 +
examples/src/message-envelope/producer/main.rs | 18 +
examples/src/message-headers/consumer/main.rs | 18 +
examples/src/message-headers/producer/main.rs | 18 +
examples/src/multi-tenant/consumer/main.rs | 18 +
examples/src/multi-tenant/producer/main.rs | 18 +
examples/src/new-sdk/consumer/main.rs | 18 +
examples/src/new-sdk/producer/main.rs | 18 +
examples/src/shared/args.rs | 18 +
examples/src/shared/client.rs | 18 +
examples/src/shared/messages.rs | 18 +
examples/src/shared/messages_generator.rs | 18 +
examples/src/shared/mod.rs | 18 +
examples/src/shared/stream.rs | 18 +
examples/src/shared/system.rs | 18 +
examples/src/stream-builder/stream-basic/main.rs | 18 +
.../stream-builder/stream-consumer-config/main.rs | 18 +
.../src/stream-builder/stream-consumer/main.rs | 18 +
.../stream-builder/stream-producer-config/main.rs | 18 +
.../src/stream-builder/stream-producer/main.rs | 18 +
integration/Cargo.toml | 39 +-
integration/src/file.rs | 18 +
integration/src/http_client.rs | 18 +
integration/src/lib.rs | 18 +
integration/src/quic_client.rs | 18 +
integration/src/tcp_client.rs | 18 +
integration/src/test_server.rs | 18 +
integration/tests/archiver/disk.rs | 18 +
integration/tests/archiver/mod.rs | 18 +
integration/tests/archiver/s3.rs | 18 +
integration/tests/bench/http.rs | 18 +
integration/tests/bench/mod.rs | 18 +
integration/tests/bench/quic.rs | 18 +
integration/tests/bench/tcp.rs | 18 +
integration/tests/cli/client/mod.rs | 18 +
.../tests/cli/client/test_client_get_command.rs | 18 +
.../tests/cli/client/test_client_help_command.rs | 18 +
.../tests/cli/client/test_client_list_command.rs | 18 +
integration/tests/cli/common/command.rs | 18 +
integration/tests/cli/common/help.rs | 18 +
integration/tests/cli/common/mod.rs | 18 +
integration/tests/cli/consumer_group/mod.rs | 18 +
.../test_consumer_group_create_command.rs | 18 +
.../test_consumer_group_delete_command.rs | 18 +
.../test_consumer_group_get_command.rs | 18 +
.../test_consumer_group_help_command.rs | 18 +
.../test_consumer_group_list_command.rs | 18 +
integration/tests/cli/consumer_offset/mod.rs | 18 +
.../test_consumer_offset_get_command.rs | 18 +
.../test_consumer_offset_set_command.rs | 18 +
integration/tests/cli/context/common.rs | 18 +
integration/tests/cli/context/mod.rs | 18 +
.../tests/cli/context/test_context_applied.rs | 18 +
.../tests/cli/context/test_context_list_command.rs | 18 +
.../tests/cli/context/test_context_use_command.rs | 18 +
integration/tests/cli/general/mod.rs | 18 +
integration/tests/cli/general/test_help_command.rs | 18 +
.../tests/cli/general/test_missing_credentials.rs | 18 +
.../tests/cli/general/test_overview_command.rs | 20 +-
integration/tests/cli/general/test_quiet_mode.rs | 18 +
integration/tests/cli/message/mod.rs | 18 +
.../cli/message/test_message_flush_command.rs | 18 +
.../tests/cli/message/test_message_help_command.rs | 18 +
.../tests/cli/message/test_message_poll_command.rs | 18 +
.../message/test_message_poll_to_file_command.rs | 18 +
.../cli/message/test_message_reply_via_file.rs | 18 +
.../tests/cli/message/test_message_send_command.rs | 18 +
.../message/test_message_send_from_file_command.rs | 18 +
integration/tests/cli/mod.rs | 18 +
integration/tests/cli/partition/mod.rs | 18 +
.../cli/partition/test_partition_create_command.rs | 18 +
.../cli/partition/test_partition_delete_command.rs | 18 +
.../cli/partition/test_partition_help_command.rs | 18 +
integration/tests/cli/personal_access_token/mod.rs | 18 +
.../test_pat_create_command.rs | 18 +
.../test_pat_delete_command.rs | 18 +
.../personal_access_token/test_pat_help_command.rs | 18 +
.../personal_access_token/test_pat_list_command.rs | 18 +
.../test_pat_login_options.rs | 18 +
integration/tests/cli/stream/mod.rs | 18 +
.../tests/cli/stream/test_stream_create_command.rs | 18 +
.../tests/cli/stream/test_stream_delete_command.rs | 18 +
.../tests/cli/stream/test_stream_get_command.rs | 18 +
.../tests/cli/stream/test_stream_help_command.rs | 18 +
.../tests/cli/stream/test_stream_list_command.rs | 18 +
.../tests/cli/stream/test_stream_purge_command.rs | 18 +
.../tests/cli/stream/test_stream_update_command.rs | 18 +
integration/tests/cli/system/mod.rs | 18 +
.../tests/cli/system/test_cli_session_scenario.rs | 18 +
integration/tests/cli/system/test_login_cmd.rs | 18 +
integration/tests/cli/system/test_login_command.rs | 18 +
integration/tests/cli/system/test_logout_cmd.rs | 18 +
.../tests/cli/system/test_logout_command.rs | 18 +
integration/tests/cli/system/test_me_command.rs | 18 +
integration/tests/cli/system/test_ping_command.rs | 18 +
integration/tests/cli/system/test_snapshot_cmd.rs | 18 +
integration/tests/cli/system/test_stats_command.rs | 18 +
integration/tests/cli/topic/mod.rs | 18 +
.../tests/cli/topic/test_topic_create_command.rs | 18 +
.../tests/cli/topic/test_topic_delete_command.rs | 18 +
.../tests/cli/topic/test_topic_get_command.rs | 18 +
.../tests/cli/topic/test_topic_help_command.rs | 18 +
.../tests/cli/topic/test_topic_list_command.rs | 18 +
.../tests/cli/topic/test_topic_purge_command.rs | 18 +
.../tests/cli/topic/test_topic_update_command.rs | 18 +
integration/tests/cli/user/common.rs | 18 +
integration/tests/cli/user/mod.rs | 18 +
integration/tests/cli/user/test_login_options.rs | 18 +
.../tests/cli/user/test_user_create_command.rs | 18 +
.../tests/cli/user/test_user_delete_command.rs | 18 +
.../tests/cli/user/test_user_get_command.rs | 18 +
.../tests/cli/user/test_user_help_command.rs | 18 +
.../tests/cli/user/test_user_list_command.rs | 18 +
.../tests/cli/user/test_user_name_command.rs | 18 +
.../tests/cli/user/test_user_password_command.rs | 18 +
.../cli/user/test_user_permissions_command.rs | 18 +
.../tests/cli/user/test_user_status_command.rs | 18 +
integration/tests/config_provider/mod.rs | 18 +
integration/tests/data_integrity/mod.rs | 18 +
.../data_integrity/verify_after_server_restart.rs | 18 +
integration/tests/examples/mod.rs | 18 +
integration/tests/examples/test_basic.rs | 18 +
integration/tests/examples/test_getting_started.rs | 18 +
.../tests/examples/test_message_envelope.rs | 18 +
integration/tests/examples/test_message_headers.rs | 18 +
integration/tests/mod.rs | 18 +
integration/tests/server/http_server.rs | 18 +
integration/tests/server/mod.rs | 18 +
integration/tests/server/quic_server.rs | 18 +
.../scenarios/consumer_group_join_scenario.rs | 18 +
...h_multiple_clients_polling_messages_scenario.rs | 18 +
...with_single_client_polling_messages_scenario.rs | 18 +
.../server/scenarios/create_message_payload.rs | 18 +
.../server/scenarios/message_headers_scenario.rs | 18 +
.../server/scenarios/message_size_scenario.rs | 18 +
integration/tests/server/scenarios/mod.rs | 18 +
.../scenarios/stream_size_validation_scenario.rs | 18 +
.../tests/server/scenarios/system_scenario.rs | 18 +
.../tests/server/scenarios/user_scenario.rs | 18 +
integration/tests/server/tcp_server.rs | 18 +
integration/tests/state/file.rs | 68 ++-
integration/tests/state/mod.rs | 18 +
integration/tests/state/system.rs | 141 ++++-
integration/tests/streaming/common/mod.rs | 18 +
integration/tests/streaming/common/test_setup.rs | 18 +
integration/tests/streaming/consumer_offset.rs | 18 +
integration/tests/streaming/get_by_offset.rs | 18 +
integration/tests/streaming/get_by_timestamp.rs | 18 +
integration/tests/streaming/messages.rs | 18 +
integration/tests/streaming/mod.rs | 18 +
integration/tests/streaming/partition.rs | 18 +
integration/tests/streaming/segment.rs | 18 +
integration/tests/streaming/snapshot.rs | 18 +
integration/tests/streaming/stream.rs | 19 +-
integration/tests/streaming/system.rs | 18 +
integration/tests/streaming/topic.rs | 19 +-
integration/tests/streaming/topic_messages.rs | 18 +
justfile | 17 +
scripts/cross-docker-entrypoint.sh | 17 +
.../performance/run-standard-performance-suite.sh | 17 +
scripts/performance/utils.sh | 17 +
scripts/prepare-cross-toml.sh | 17 +
scripts/profile.sh | 17 +
scripts/run-benches.sh | 17 +
scripts/run-examples-from-readme.sh | 17 +
scripts/utils.sh | 17 +
sdk/Cargo.toml | 57 +-
sdk/src/args.rs | 18 +
sdk/src/binary/binary_client.rs | 18 +
sdk/src/binary/consumer_groups.rs | 18 +
sdk/src/binary/consumer_offsets.rs | 18 +
sdk/src/binary/mapper.rs | 18 +
sdk/src/binary/messages.rs | 18 +
sdk/src/binary/mod.rs | 18 +
sdk/src/binary/partitions.rs | 18 +
sdk/src/binary/personal_access_tokens.rs | 18 +
sdk/src/binary/streams.rs | 18 +
sdk/src/binary/system.rs | 18 +
sdk/src/binary/topics.rs | 18 +
sdk/src/binary/users.rs | 18 +
sdk/src/bytes_serializable.rs | 18 +
sdk/src/cli/client/get_client.rs | 18 +
sdk/src/cli/client/get_clients.rs | 18 +
sdk/src/cli/client/mod.rs | 18 +
.../cli/consumer_group/create_consumer_group.rs | 18 +
.../cli/consumer_group/delete_consumer_group.rs | 18 +
sdk/src/cli/consumer_group/get_consumer_group.rs | 18 +
sdk/src/cli/consumer_group/get_consumer_groups.rs | 18 +
sdk/src/cli/consumer_group/mod.rs | 18 +
sdk/src/cli/consumer_offset/get_consumer_offset.rs | 18 +
sdk/src/cli/consumer_offset/mod.rs | 18 +
sdk/src/cli/consumer_offset/set_consumer_offset.rs | 18 +
sdk/src/cli/context/common.rs | 18 +
sdk/src/cli/context/get_contexts.rs | 18 +
sdk/src/cli/context/mod.rs | 18 +
sdk/src/cli/context/use_context.rs | 18 +
sdk/src/cli/message/flush_messages.rs | 18 +
sdk/src/cli/message/mod.rs | 18 +
sdk/src/cli/message/poll_messages.rs | 18 +
sdk/src/cli/message/send_messages.rs | 18 +
sdk/src/cli/mod.rs | 18 +
sdk/src/cli/partitions/create_partitions.rs | 18 +
sdk/src/cli/partitions/delete_partitions.rs | 18 +
sdk/src/cli/partitions/mod.rs | 18 +
.../create_personal_access_token.rs | 18 +
.../delete_personal_access_tokens.rs | 18 +
.../get_personal_access_tokens.rs | 18 +
sdk/src/cli/personal_access_tokens/mod.rs | 18 +
sdk/src/cli/streams/create_stream.rs | 18 +
sdk/src/cli/streams/delete_stream.rs | 18 +
sdk/src/cli/streams/get_stream.rs | 18 +
sdk/src/cli/streams/get_streams.rs | 18 +
sdk/src/cli/streams/mod.rs | 18 +
sdk/src/cli/streams/purge_stream.rs | 18 +
sdk/src/cli/streams/update_stream.rs | 18 +
sdk/src/cli/system/login.rs | 18 +
sdk/src/cli/system/logout.rs | 18 +
sdk/src/cli/system/me.rs | 18 +
sdk/src/cli/system/mod.rs | 18 +
sdk/src/cli/system/ping.rs | 18 +
sdk/src/cli/system/session.rs | 18 +
sdk/src/cli/system/snapshot.rs | 18 +
sdk/src/cli/system/stats.rs | 18 +
sdk/src/cli/topics/create_topic.rs | 18 +
sdk/src/cli/topics/delete_topic.rs | 18 +
sdk/src/cli/topics/get_topic.rs | 18 +
sdk/src/cli/topics/get_topics.rs | 18 +
sdk/src/cli/topics/mod.rs | 18 +
sdk/src/cli/topics/purge_topic.rs | 18 +
sdk/src/cli/topics/update_topic.rs | 18 +
sdk/src/cli/users/change_password.rs | 18 +
sdk/src/cli/users/create_user.rs | 18 +
sdk/src/cli/users/delete_user.rs | 18 +
sdk/src/cli/users/get_user.rs | 18 +
sdk/src/cli/users/get_users.rs | 18 +
sdk/src/cli/users/mod.rs | 18 +
sdk/src/cli/users/update_permissions.rs | 18 +
sdk/src/cli/users/update_user.rs | 18 +
sdk/src/cli/utils/login_session_expiry.rs | 18 +
sdk/src/cli/utils/mod.rs | 18 +
sdk/src/cli_command.rs | 18 +
sdk/src/client.rs | 18 +
sdk/src/client_error.rs | 18 +
sdk/src/client_provider.rs | 18 +
sdk/src/clients/builder.rs | 18 +
sdk/src/clients/client.rs | 18 +
sdk/src/clients/consumer.rs | 18 +
sdk/src/clients/mod.rs | 18 +
sdk/src/clients/producer.rs | 18 +
sdk/src/command.rs | 18 +
sdk/src/compression/compression_algorithm.rs | 18 +
sdk/src/compression/mod.rs | 18 +
sdk/src/confirmation.rs | 18 +
sdk/src/consumer.rs | 18 +
sdk/src/consumer_ext/consumer_message_ext.rs | 18 +
sdk/src/consumer_ext/consumer_message_trait.rs | 18 +
sdk/src/consumer_ext/mod.rs | 18 +
sdk/src/consumer_groups/create_consumer_group.rs | 18 +
sdk/src/consumer_groups/delete_consumer_group.rs | 18 +
sdk/src/consumer_groups/get_consumer_group.rs | 18 +
sdk/src/consumer_groups/get_consumer_groups.rs | 18 +
sdk/src/consumer_groups/join_consumer_group.rs | 18 +
sdk/src/consumer_groups/leave_consumer_group.rs | 18 +
sdk/src/consumer_groups/mod.rs | 18 +
sdk/src/consumer_offsets/delete_consumer_offset.rs | 18 +
sdk/src/consumer_offsets/get_consumer_offset.rs | 18 +
sdk/src/consumer_offsets/mod.rs | 18 +
sdk/src/consumer_offsets/store_consumer_offset.rs | 18 +
sdk/src/diagnostic.rs | 18 +
sdk/src/error.rs | 22 +-
sdk/src/http/client.rs | 18 +
sdk/src/http/config.rs | 18 +
sdk/src/http/consumer_groups.rs | 18 +
sdk/src/http/consumer_offsets.rs | 18 +
sdk/src/http/messages.rs | 18 +
sdk/src/http/mod.rs | 18 +
sdk/src/http/partitions.rs | 18 +
sdk/src/http/personal_access_tokens.rs | 18 +
sdk/src/http/streams.rs | 18 +
sdk/src/http/system.rs | 18 +
sdk/src/http/topics.rs | 18 +
sdk/src/http/users.rs | 18 +
sdk/src/identifier.rs | 18 +
sdk/src/lib.rs | 18 +
sdk/src/locking/fast_async_lock.rs | 18 +
sdk/src/locking/mod.rs | 18 +
sdk/src/locking/tokio_lock.rs | 18 +
sdk/src/messages/flush_unsaved_buffer.rs | 18 +
sdk/src/messages/mod.rs | 18 +
sdk/src/messages/poll_messages.rs | 18 +
sdk/src/messages/send_messages.rs | 18 +
sdk/src/models/client_info.rs | 18 +
sdk/src/models/consumer_group.rs | 18 +
sdk/src/models/consumer_offset_info.rs | 18 +
sdk/src/models/header.rs | 18 +
sdk/src/models/identity_info.rs | 18 +
sdk/src/models/messages.rs | 18 +
sdk/src/models/mod.rs | 18 +
sdk/src/models/partition.rs | 18 +
sdk/src/models/permissions.rs | 18 +
sdk/src/models/personal_access_token.rs | 18 +
sdk/src/models/snapshot.rs | 18 +
sdk/src/models/stats.rs | 18 +
sdk/src/models/stream.rs | 18 +
sdk/src/models/topic.rs | 18 +
sdk/src/models/user_info.rs | 18 +
sdk/src/models/user_status.rs | 18 +
sdk/src/partitioner.rs | 18 +
sdk/src/partitions/create_partitions.rs | 18 +
sdk/src/partitions/delete_partitions.rs | 18 +
sdk/src/partitions/mod.rs | 18 +
.../create_personal_access_token.rs | 18 +
.../delete_personal_access_token.rs | 18 +
.../get_personal_access_tokens.rs | 18 +
.../login_with_personal_access_token.rs | 18 +
sdk/src/personal_access_tokens/mod.rs | 18 +
sdk/src/quic/client.rs | 18 +
sdk/src/quic/config.rs | 18 +
sdk/src/quic/mod.rs | 18 +
sdk/src/snapshot.rs | 18 +
sdk/src/stream_builder/build/build_iggy_client.rs | 18 +
.../stream_builder/build/build_iggy_consumer.rs | 18 +
.../stream_builder/build/build_iggy_producer.rs | 18 +
sdk/src/stream_builder/build/build_stream_topic.rs | 18 +
sdk/src/stream_builder/build/mod.rs | 18 +
.../stream_builder/config/config_iggy_consumer.rs | 18 +
.../stream_builder/config/config_iggy_producer.rs | 18 +
.../stream_builder/config/config_iggy_stream.rs | 18 +
sdk/src/stream_builder/config/mod.rs | 18 +
sdk/src/stream_builder/iggy_stream.rs | 18 +
sdk/src/stream_builder/iggy_stream_consumer.rs | 18 +
sdk/src/stream_builder/iggy_stream_producer.rs | 18 +
sdk/src/stream_builder/mod.rs | 18 +
sdk/src/streams/create_stream.rs | 18 +
sdk/src/streams/delete_stream.rs | 18 +
sdk/src/streams/get_stream.rs | 18 +
sdk/src/streams/get_streams.rs | 18 +
sdk/src/streams/mod.rs | 18 +
sdk/src/streams/purge_stream.rs | 18 +
sdk/src/streams/update_stream.rs | 18 +
sdk/src/system/get_client.rs | 18 +
sdk/src/system/get_clients.rs | 18 +
sdk/src/system/get_me.rs | 18 +
sdk/src/system/get_snapshot.rs | 18 +
sdk/src/system/get_stats.rs | 18 +
sdk/src/system/mod.rs | 18 +
sdk/src/system/ping.rs | 18 +
sdk/src/tcp/client.rs | 20 +-
sdk/src/tcp/config.rs | 18 +
sdk/src/tcp/mod.rs | 18 +
sdk/src/topics/create_topic.rs | 18 +
sdk/src/topics/delete_topic.rs | 18 +
sdk/src/topics/get_topic.rs | 18 +
sdk/src/topics/get_topics.rs | 18 +
sdk/src/topics/mod.rs | 18 +
sdk/src/topics/purge_topic.rs | 18 +
sdk/src/topics/update_topic.rs | 18 +
sdk/src/users/change_password.rs | 18 +
sdk/src/users/create_user.rs | 18 +
sdk/src/users/defaults.rs | 18 +
sdk/src/users/delete_user.rs | 18 +
sdk/src/users/get_user.rs | 18 +
sdk/src/users/get_users.rs | 18 +
sdk/src/users/login_user.rs | 18 +
sdk/src/users/logout_user.rs | 18 +
sdk/src/users/mod.rs | 18 +
sdk/src/users/update_permissions.rs | 18 +
sdk/src/users/update_user.rs | 18 +
sdk/src/utils/byte_size.rs | 18 +
sdk/src/utils/checksum.rs | 18 +
sdk/src/utils/crypto.rs | 18 +
sdk/src/utils/duration.rs | 18 +
sdk/src/utils/expiry.rs | 18 +
sdk/src/utils/mod.rs | 18 +
sdk/src/utils/personal_access_token_expiry.rs | 18 +
sdk/src/utils/sizeable.rs | 18 +
sdk/src/utils/text.rs | 18 +
sdk/src/utils/timestamp.rs | 18 +
sdk/src/utils/topic_size.rs | 18 +
sdk/src/validatable.rs | 18 +
server/Cargo.toml | 45 +-
server/server.http | 17 +
server/src/archiver/disk.rs | 18 +
server/src/archiver/mod.rs | 18 +
server/src/archiver/s3.rs | 18 +
server/src/args.rs | 18 +
server/src/binary/command.rs | 18 +
.../create_consumer_group_handler.rs | 31 +-
.../delete_consumer_group_handler.rs | 23 +-
.../consumer_groups/get_consumer_group_handler.rs | 18 +
.../consumer_groups/get_consumer_groups_handler.rs | 20 +-
.../consumer_groups/join_consumer_group_handler.rs | 23 +-
.../leave_consumer_group_handler.rs | 23 +-
server/src/binary/handlers/consumer_groups/mod.rs | 18 +
.../delete_consumer_offset_handler.rs | 21 +-
.../get_consumer_offset_handler.rs | 18 +
server/src/binary/handlers/consumer_offsets/mod.rs | 18 +
.../store_consumer_offset_handler.rs | 23 +-
.../messages/flush_unsaved_buffer_handler.rs | 20 +-
server/src/binary/handlers/messages/mod.rs | 18 +
.../handlers/messages/poll_messages_handler.rs | 20 +-
.../handlers/messages/send_messages_handler.rs | 20 +-
server/src/binary/handlers/mod.rs | 18 +
.../partitions/create_partitions_handler.rs | 25 +-
.../partitions/delete_partitions_handler.rs | 23 +-
server/src/binary/handlers/partitions/mod.rs | 18 +
.../create_personal_access_token_handler.rs | 22 +-
.../delete_personal_access_token_handler.rs | 21 +-
.../get_personal_access_tokens_handler.rs | 18 +
.../login_with_personal_access_token_handler.rs | 18 +
.../binary/handlers/personal_access_tokens/mod.rs | 18 +
.../handlers/streams/create_stream_handler.rs | 32 +-
.../handlers/streams/delete_stream_handler.rs | 21 +-
.../binary/handlers/streams/get_stream_handler.rs | 18 +
.../binary/handlers/streams/get_streams_handler.rs | 18 +
server/src/binary/handlers/streams/mod.rs | 18 +
.../handlers/streams/purge_stream_handler.rs | 18 +
.../handlers/streams/update_stream_handler.rs | 21 +-
.../binary/handlers/system/get_client_handler.rs | 18 +
.../binary/handlers/system/get_clients_handler.rs | 18 +
.../src/binary/handlers/system/get_me_handler.rs | 18 +
server/src/binary/handlers/system/get_snapshot.rs | 18 +
.../binary/handlers/system/get_stats_handler.rs | 18 +
server/src/binary/handlers/system/mod.rs | 18 +
server/src/binary/handlers/system/ping_handler.rs | 18 +
.../binary/handlers/topics/create_topic_handler.rs | 29 +-
.../binary/handlers/topics/delete_topic_handler.rs | 21 +-
.../binary/handlers/topics/get_topic_handler.rs | 18 +
.../binary/handlers/topics/get_topics_handler.rs | 20 +-
server/src/binary/handlers/topics/mod.rs | 18 +
.../binary/handlers/topics/purge_topic_handler.rs | 20 +-
.../binary/handlers/topics/update_topic_handler.rs | 22 +-
.../handlers/users/change_password_handler.rs | 25 +-
.../binary/handlers/users/create_user_handler.rs | 36 +-
.../binary/handlers/users/delete_user_handler.rs | 21 +-
.../src/binary/handlers/users/get_user_handler.rs | 18 +
.../src/binary/handlers/users/get_users_handler.rs | 18 +
.../binary/handlers/users/login_user_handler.rs | 18 +
.../binary/handlers/users/logout_user_handler.rs | 18 +
server/src/binary/handlers/users/mod.rs | 18 +
.../handlers/users/update_permissions_handler.rs | 23 +-
.../binary/handlers/users/update_user_handler.rs | 26 +-
server/src/binary/mapper.rs | 18 +
server/src/binary/mod.rs | 18 +
server/src/binary/sender.rs | 18 +
server/src/build.rs | 18 +
server/src/channels/commands/archive_state.rs | 18 +
.../commands/clean_personal_access_tokens.rs | 18 +
server/src/channels/commands/maintain_messages.rs | 18 +
server/src/channels/commands/mod.rs | 18 +
server/src/channels/commands/print_sysinfo.rs | 18 +
server/src/channels/commands/save_messages.rs | 18 +
server/src/channels/commands/verify_heartbeats.rs | 18 +
server/src/channels/handler.rs | 18 +
server/src/channels/mod.rs | 18 +
server/src/channels/server_command.rs | 18 +
server/src/command.rs | 18 +
.../src/compat/index_rebuilding/index_rebuilder.rs | 18 +
server/src/compat/index_rebuilding/mod.rs | 18 +
server/src/compat/mod.rs | 18 +
server/src/configs/config_provider.rs | 18 +
server/src/configs/defaults.rs | 18 +
server/src/configs/displays.rs | 18 +
server/src/configs/http.rs | 18 +
server/src/configs/mod.rs | 18 +
server/src/configs/quic.rs | 18 +
server/src/configs/resource_quota.rs | 18 +
server/src/configs/server.rs | 18 +
server/src/configs/system.rs | 18 +
server/src/configs/tcp.rs | 18 +
server/src/configs/validators.rs | 18 +
server/src/http/consumer_groups.rs | 25 +-
server/src/http/consumer_offsets.rs | 18 +
server/src/http/diagnostics.rs | 18 +
server/src/http/error.rs | 18 +
server/src/http/http_server.rs | 18 +
server/src/http/jwt/cleaner.rs | 18 +
server/src/http/jwt/json_web_token.rs | 18 +
server/src/http/jwt/jwt_manager.rs | 18 +
server/src/http/jwt/middleware.rs | 18 +
server/src/http/jwt/mod.rs | 18 +
server/src/http/jwt/storage.rs | 30 +-
server/src/http/mapper.rs | 18 +
server/src/http/messages.rs | 18 +
server/src/http/metrics.rs | 18 +
server/src/http/mod.rs | 18 +
server/src/http/partitions.rs | 18 +
server/src/http/personal_access_tokens.rs | 18 +
server/src/http/shared.rs | 18 +
server/src/http/streams.rs | 29 +-
server/src/http/system.rs | 18 +
server/src/http/topics.rs | 28 +-
server/src/http/users.rs | 33 +-
server/src/lib.rs | 18 +
server/src/log/logger.rs | 18 +
server/src/log/mod.rs | 18 +
server/src/log/tokio_console.rs | 18 +
server/src/main.rs | 18 +
server/src/quic/listener.rs | 18 +
server/src/quic/mod.rs | 18 +
server/src/quic/quic_sender.rs | 18 +
server/src/quic/quic_server.rs | 18 +
server/src/server_error.rs | 18 +
server/src/state/command.rs | 47 +-
server/src/state/entry.rs | 18 +
server/src/state/file.rs | 18 +
server/src/state/mod.rs | 18 +
server/src/state/models.rs | 344 ++++++++++-
server/src/state/system.rs | 54 +-
.../streaming/batching/appendable_batch_info.rs | 18 +
server/src/streaming/batching/batch_accumulator.rs | 18 +
server/src/streaming/batching/batch_filter.rs | 18 +
server/src/streaming/batching/iterator.rs | 18 +
server/src/streaming/batching/message_batch.rs | 18 +
server/src/streaming/batching/mod.rs | 18 +
server/src/streaming/cache/buffer.rs | 18 +
server/src/streaming/cache/memory_tracker.rs | 18 +
server/src/streaming/cache/mod.rs | 18 +
server/src/streaming/clients/client_manager.rs | 18 +
server/src/streaming/clients/mod.rs | 18 +
.../deduplication/message_deduplicator.rs | 18 +
server/src/streaming/deduplication/mod.rs | 18 +
server/src/streaming/diagnostics/metrics.rs | 18 +
server/src/streaming/diagnostics/mod.rs | 18 +
server/src/streaming/local_sizeable.rs | 18 +
server/src/streaming/mod.rs | 18 +
server/src/streaming/models/messages.rs | 18 +
server/src/streaming/models/mod.rs | 18 +
.../src/streaming/partitions/consumer_offsets.rs | 18 +
server/src/streaming/partitions/messages.rs | 18 +
server/src/streaming/partitions/mod.rs | 18 +
server/src/streaming/partitions/partition.rs | 20 +-
server/src/streaming/partitions/persistence.rs | 18 +
server/src/streaming/partitions/segments.rs | 18 +
server/src/streaming/partitions/storage.rs | 18 +
server/src/streaming/persistence/mod.rs | 18 +
server/src/streaming/persistence/persister.rs | 18 +
server/src/streaming/persistence/task.rs | 18 +
server/src/streaming/personal_access_tokens/mod.rs | 18 +
.../personal_access_token.rs | 18 +
server/src/streaming/polling_consumer.rs | 18 +
server/src/streaming/segments/indexes/index.rs | 18 +
.../src/streaming/segments/indexes/index_reader.rs | 18 +
.../src/streaming/segments/indexes/index_writer.rs | 18 +
server/src/streaming/segments/indexes/mod.rs | 18 +
server/src/streaming/segments/logs/log_reader.rs | 18 +
server/src/streaming/segments/logs/log_writer.rs | 18 +
server/src/streaming/segments/logs/mod.rs | 18 +
.../src/streaming/segments/logs/persister_task.rs | 18 +
server/src/streaming/segments/mod.rs | 18 +
server/src/streaming/segments/reading_messages.rs | 18 +
server/src/streaming/segments/segment.rs | 20 +-
server/src/streaming/segments/writing_messages.rs | 18 +
server/src/streaming/session.rs | 18 +
server/src/streaming/storage.rs | 18 +
server/src/streaming/streams/messages.rs | 18 +
server/src/streaming/streams/mod.rs | 18 +
server/src/streaming/streams/partitions.rs | 18 +
server/src/streaming/streams/persistence.rs | 18 +
server/src/streaming/streams/segments.rs | 18 +
server/src/streaming/streams/storage.rs | 18 +
server/src/streaming/streams/stream.rs | 20 +-
server/src/streaming/streams/topics.rs | 18 +
server/src/streaming/systems/clients.rs | 18 +
server/src/streaming/systems/consumer_groups.rs | 48 +-
server/src/streaming/systems/consumer_offsets.rs | 18 +
server/src/streaming/systems/info.rs | 18 +
server/src/streaming/systems/messages.rs | 30 +-
server/src/streaming/systems/mod.rs | 18 +
server/src/streaming/systems/partitions.rs | 26 +-
.../streaming/systems/personal_access_tokens.rs | 18 +
server/src/streaming/systems/snapshot/mod.rs | 18 +
server/src/streaming/systems/snapshot/procdump.rs | 18 +
server/src/streaming/systems/stats.rs | 18 +
server/src/streaming/systems/storage.rs | 28 +-
server/src/streaming/systems/streams.rs | 18 +
server/src/streaming/systems/system.rs | 18 +
server/src/streaming/systems/topics.rs | 18 +
server/src/streaming/systems/users.rs | 24 +-
server/src/streaming/topics/consumer_group.rs | 18 +
server/src/streaming/topics/consumer_groups.rs | 18 +
server/src/streaming/topics/consumer_offsets.rs | 18 +
server/src/streaming/topics/messages.rs | 18 +
server/src/streaming/topics/mod.rs | 18 +
server/src/streaming/topics/partitions.rs | 18 +
server/src/streaming/topics/persistence.rs | 18 +
server/src/streaming/topics/segments.rs | 18 +
server/src/streaming/topics/storage.rs | 18 +
server/src/streaming/topics/topic.rs | 20 +-
server/src/streaming/users/mod.rs | 18 +
server/src/streaming/users/permissioner.rs | 18 +
.../users/permissioner_rules/consumer_groups.rs | 18 +
.../users/permissioner_rules/consumer_offsets.rs | 18 +
.../streaming/users/permissioner_rules/messages.rs | 18 +
.../src/streaming/users/permissioner_rules/mod.rs | 18 +
.../users/permissioner_rules/partitions.rs | 18 +
.../streaming/users/permissioner_rules/streams.rs | 18 +
.../streaming/users/permissioner_rules/system.rs | 18 +
.../streaming/users/permissioner_rules/topics.rs | 18 +
.../streaming/users/permissioner_rules/users.rs | 18 +
server/src/streaming/users/user.rs | 18 +
server/src/streaming/utils/crypto.rs | 18 +
server/src/streaming/utils/file.rs | 18 +
server/src/streaming/utils/hash.rs | 18 +
server/src/streaming/utils/head_tail_buf.rs | 18 +
server/src/streaming/utils/mod.rs | 18 +
server/src/streaming/utils/random_id.rs | 18 +
server/src/tcp/connection_handler.rs | 18 +
server/src/tcp/mod.rs | 18 +
server/src/tcp/sender.rs | 18 +
server/src/tcp/tcp_listener.rs | 18 +
server/src/tcp/tcp_sender.rs | 18 +
server/src/tcp/tcp_server.rs | 18 +
server/src/tcp/tcp_socket.rs | 18 +
server/src/tcp/tcp_tls_listener.rs | 18 +
server/src/tcp/tcp_tls_sender.rs | 18 +
server/src/versioning.rs | 18 +
tools/Cargo.toml | 23 +-
tools/src/data-seeder/main.rs | 18 +
tools/src/data-seeder/seeder.rs | 18 +
757 files changed, 14584 insertions(+), 586 deletions(-)
mode change 100755 => 100644 server/src/log/logger.rs
