Path	Lines of Code
core/bench/Cargo.toml	49
core/bench/report/Cargo.toml	34
core/bench/report/src/lib.rs	120
core/bench/report/src/plotting/chart.rs	237
core/bench/report/src/plotting/chart_kind.rs	25
core/bench/report/src/plotting/mod.rs	20
core/bench/report/src/plotting/text/mod.rs	19
core/bench/report/src/plotting/text/subtext.rs	138
core/bench/report/src/plotting/text/title.rs	30
core/bench/report/src/prints.rs	177
core/bench/report/src/types/actor_kind.rs	40
core/bench/report/src/types/benchmark_kind.rs	60
core/bench/report/src/types/group_metrics.rs	101
core/bench/report/src/types/group_metrics_kind.rs	44
core/bench/report/src/types/group_metrics_summary.rs	54
core/bench/report/src/types/hardware.rs	48
core/bench/report/src/types/individual_metrics.rs	103
core/bench/report/src/types/individual_metrics_summary.rs	60
core/bench/report/src/types/mod.rs	31
core/bench/report/src/types/numeric_parameter.rs	171
core/bench/report/src/types/params.rs	75
core/bench/report/src/types/report.rs	43
core/bench/report/src/types/server_stats.rs	143
core/bench/report/src/types/time_series.rs	49
core/bench/report/src/types/transport.rs	32
core/bench/report/src/utils.rs	57
core/bench/src/actors/consumer.rs	346
core/bench/src/actors/mod.rs	20
core/bench/src/actors/producer.rs	210
core/bench/src/actors/producing_consumer.rs	363
core/bench/src/analytics/metrics/group.rs	155
core/bench/src/analytics/metrics/individual.rs	165
core/bench/src/analytics/metrics/mod.rs	19
core/bench/src/analytics/mod.rs	21
core/bench/src/analytics/record.rs	26
core/bench/src/analytics/report_builder.rs	170
core/bench/src/analytics/time_series/calculator.rs	118
core/bench/src/analytics/time_series/calculators/latency.rs	62
core/bench/src/analytics/time_series/calculators/mod.rs	29
core/bench/src/analytics/time_series/calculators/throughput.rs	116
core/bench/src/analytics/time_series/mod.rs	20
core/bench/src/analytics/time_series/processors/mod.rs	22
core/bench/src/analytics/time_series/processors/moving_average.rs	52
core/bench/src/args/common.rs	354
core/bench/src/args/defaults.rs	44
core/bench/src/args/examples.rs	137
core/bench/src/args/kind.rs	156
core/bench/src/args/kinds/balanced/consumer_group.rs	73
core/bench/src/args/kinds/balanced/mod.rs	20
core/bench/src/args/kinds/balanced/producer.rs	71
core/bench/src/args/kinds/balanced/producer_and_consumer_group.rs	85
core/bench/src/args/kinds/end_to_end/mod.rs	19
core/bench/src/args/kinds/end_to_end/producing_consumer.rs	70
core/bench/src/args/kinds/end_to_end/producing_consumer_group.rs	87
core/bench/src/args/kinds/mod.rs	20
core/bench/src/args/kinds/pinned/consumer.rs	68
core/bench/src/args/kinds/pinned/mod.rs	20
core/bench/src/args/kinds/pinned/producer.rs	70
core/bench/src/args/kinds/pinned/producer_and_consumer.rs	83
core/bench/src/args/mod.rs	25
core/bench/src/args/output.rs	39
core/bench/src/args/props.rs	50
core/bench/src/args/transport.rs	157
core/bench/src/benchmarks/balanced_consumer_group.rs	56
core/bench/src/benchmarks/balanced_producer.rs	59
core/bench/src/benchmarks/balanced_producer_and_consumer_group.rs	66
core/bench/src/benchmarks/benchmark.rs	164
core/bench/src/benchmarks/common.rs	353
core/bench/src/benchmarks/end_to_end_producing_consumer.rs	58
core/bench/src/benchmarks/end_to_end_producing_consumer_group.rs	61
core/bench/src/benchmarks/mod.rs	29
core/bench/src/benchmarks/pinned_consumer.rs	54
core/bench/src/benchmarks/pinned_producer.rs	59
core/bench/src/benchmarks/pinned_producer_and_consumer.rs	64
core/bench/src/main.rs	90
core/bench/src/plot.rs	31
core/bench/src/runner.rs	116
core/bench/src/utils/batch_generator.rs	97
core/bench/src/utils/client_factory.rs	37
core/bench/src/utils/cpu_name.rs	32
core/bench/src/utils/finish_condition.rs	151
core/bench/src/utils/mod.rs	322
core/bench/src/utils/rate_limiter.rs	24
core/bench/src/utils/server_starter.rs	145
core/cli/Cargo.toml	56
core/cli/src/args/client.rs	35
core/cli/src/args/common.rs	104
core/cli/src/args/consumer_group.rs	68
core/cli/src/args/consumer_offset.rs	51
core/cli/src/args/context.rs	36
core/cli/src/args/message.rs	166
core/cli/src/args/mod.rs	178
core/cli/src/args/partition.rs	44
core/cli/src/args/permissions/constants.rs	45
core/cli/src/args/permissions/global.rs	385
core/cli/src/args/permissions/mod.rs	164
core/cli/src/args/permissions/stream.rs	570
core/cli/src/args/permissions/topic.rs	337
core/cli/src/args/personal_access_token.rs	46
core/cli/src/args/segment.rs	35
core/cli/src/args/stream.rs	63
core/cli/src/args/system.rs	46
core/cli/src/args/topic.rs	99
core/cli/src/args/user.rs	100
core/cli/src/credentials.rs	131
core/cli/src/error.rs	27
core/cli/src/logging.rs	71
core/cli/src/main.rs	377
core/configs/server.toml	426
core/integration/Cargo.toml	52
core/integration/src/file.rs	29
core/integration/src/http_client.rs	40
core/integration/src/lib.rs	26
core/integration/src/quic_client.rs	41
core/integration/src/tcp_client.rs	55
core/sdk/Cargo.toml	84
core/sdk/src/args.rs	279
core/sdk/src/binary/binary_client.rs	22
core/sdk/src/binary/consumer_groups.rs	128
core/sdk/src/binary/consumer_offsets.rs	87
core/sdk/src/binary/mapper.rs	917
core/sdk/src/binary/messages.rs	89
core/sdk/src/binary/mod.rs	81
core/sdk/src/binary/partitions.rs	58
core/sdk/src/binary/personal_access_tokens.rs	70
core/sdk/src/binary/segments.rs	44
core/sdk/src/binary/streams.rs	88
core/sdk/src/binary/system.rs	79
core/sdk/src/binary/topics.rs	136
core/sdk/src/binary/users.rs	145
core/sdk/src/bytes_serializable.rs	31
core/sdk/src/cli/client/get_client.rs	91
core/sdk/src/cli/client/get_clients.rs	109
core/sdk/src/cli/client/mod.rs	19
core/sdk/src/cli/consumer_group/create_consumer_group.rs	81
core/sdk/src/cli/consumer_group/delete_consumer_group.rs	67
core/sdk/src/cli/consumer_group/get_consumer_group.rs	102
core/sdk/src/cli/consumer_group/get_consumer_groups.rs	32
core/sdk/src/cli/consumer_group/mod.rs	21
core/sdk/src/cli/consumer_offset/get_consumer_offset.rs	113
core/sdk/src/cli/consumer_offset/mod.rs	19
core/sdk/src/cli/consumer_offset/set_consumer_offset.rs	83
core/sdk/src/cli/context/common.rs	233
core/sdk/src/cli/context/get_contexts.rs	86
core/sdk/src/cli/context/mod.rs	20
core/sdk/src/cli/context/use_context.rs	58
core/sdk/src/cli/message/flush_messages.rs	84
core/sdk/src/cli/message/mod.rs	20
core/sdk/src/cli/message/poll_messages.rs	234
core/sdk/src/cli/message/send_messages.rs	178
core/sdk/src/cli/mod.rs	30
core/sdk/src/cli/partitions/create_partitions.rs	81
core/sdk/src/cli/partitions/delete_partitions.rs	81
core/sdk/src/cli/partitions/mod.rs	19
core/sdk/src/cli/personal_access_tokens/create_personal_access_token.rs	108
core/sdk/src/cli/personal_access_tokens/delete_personal_access_tokens.rs	67
core/sdk/src/cli/personal_access_tokens/get_personal_access_tokens.rs	85
core/sdk/src/cli/personal_access_tokens/mod.rs	20
core/sdk/src/cli/segments/delete_segments.rs	91
core/sdk/src/cli/segments/mod.rs	18
core/sdk/src/cli/streams/create_stream.rs	67
core/sdk/src/cli/streams/delete_stream.rs	53
core/sdk/src/cli/streams/get_stream.rs	73
core/sdk/src/cli/streams/get_streams.rs	101
core/sdk/src/cli/streams/mod.rs	23
core/sdk/src/cli/streams/purge_stream.rs	53
core/sdk/src/cli/streams/update_stream.rs	59
core/sdk/src/cli/system/login.rs	91
core/sdk/src/cli/system/logout.rs	55
core/sdk/src/cli/system/me.rs	62
core/sdk/src/cli/system/mod.rs	24
core/sdk/src/cli/system/ping.rs	81
core/sdk/src/cli/system/session.rs	60
core/sdk/src/cli/system/snapshot.rs	90
core/sdk/src/cli/system/stats.rs	35
core/sdk/src/cli/topics/create_topic.rs	100
core/sdk/src/cli/topics/delete_topic.rs	62
core/sdk/src/cli/topics/get_topic.rs	100
core/sdk/src/cli/topics/get_topics.rs	33
core/sdk/src/cli/topics/mod.rs	23
core/sdk/src/cli/topics/purge_topic.rs	61
core/sdk/src/cli/topics/update_topic.rs	93
core/sdk/src/cli/users/change_password.rs	91
core/sdk/src/cli/users/create_user.rs	75
core/sdk/src/cli/users/delete_user.rs	53
core/sdk/src/cli/users/get_user.rs	183
core/sdk/src/cli/users/get_users.rs	95
core/sdk/src/cli/users/mod.rs	24
core/sdk/src/cli/users/update_permissions.rs	66
core/sdk/src/cli/users/update_user.rs	87
core/sdk/src/cli/utils/login_session_expiry.rs	19
core/sdk/src/cli/utils/mod.rs	18
core/sdk/src/cli_command.rs	35
core/sdk/src/client.rs	591
core/sdk/src/client_error.rs	31
core/sdk/src/client_provider.rs	182
core/sdk/src/clients/builder.rs	190
core/sdk/src/clients/client.rs	701
core/sdk/src/clients/consumer.rs	1017
core/sdk/src/clients/mod.rs	21
core/sdk/src/clients/producer.rs	675
core/sdk/src/command.rs	117
core/sdk/src/compression/compression_algorithm.rs	101
core/sdk/src/compression/mod.rs	18
core/sdk/src/confirmation.rs	48
core/sdk/src/consumer.rs	119
core/sdk/src/consumer_ext/consumer_message_ext.rs	29
core/sdk/src/consumer_ext/consumer_message_trait.rs	26
core/sdk/src/consumer_ext/mod.rs	31
core/sdk/src/consumer_groups/create_consumer_group.rs	110
core/sdk/src/consumer_groups/delete_consumer_group.rs	78
core/sdk/src/consumer_groups/get_consumer_group.rs	78
core/sdk/src/consumer_groups/get_consumer_groups.rs	69
core/sdk/src/consumer_groups/join_consumer_group.rs	78
core/sdk/src/consumer_groups/leave_consumer_group.rs	78
core/sdk/src/consumer_groups/mod.rs	24
core/sdk/src/consumer_offsets/delete_consumer_offset.rs	112
core/sdk/src/consumer_offsets/get_consumer_offset.rs	116
core/sdk/src/consumer_offsets/mod.rs	20
core/sdk/src/consumer_offsets/store_consumer_offset.rs	121
core/sdk/src/diagnostic.rs	33
core/sdk/src/error.rs	480
core/sdk/src/http/client.rs	279
core/sdk/src/http/config.rs	50
core/sdk/src/http/consumer_groups.rs	124
core/sdk/src/http/consumer_offsets.rs	102
core/sdk/src/http/messages.rs	117
core/sdk/src/http/mod.rs	65
core/sdk/src/http/partitions.rs	65
core/sdk/src/http/personal_access_tokens.rs	82
core/sdk/src/http/segments.rs	53
core/sdk/src/http/streams.rs	99
core/sdk/src/http/system.rs	96
core/sdk/src/http/topics.rs	150
core/sdk/src/http/users.rs	160
core/sdk/src/identifier.rs	328
core/sdk/src/lib.rs	59
core/sdk/src/locking/fast_async_lock.rs	55
core/sdk/src/locking/mod.rs	48
core/sdk/src/locking/tokio_lock.rs	56
core/sdk/src/messages/flush_unsaved_buffer.rs	121
core/sdk/src/messages/mod.rs	33
core/sdk/src/messages/partitioning.rs	41
core/sdk/src/messages/partitioning_kind.rs	55
core/sdk/src/messages/poll_messages.rs	289
core/sdk/src/messages/polled_messages.rs	107
core/sdk/src/messages/polling_kind.rs	67
core/sdk/src/messages/polling_strategy.rs	46
core/sdk/src/messages/send_messages.rs	363
core/sdk/src/models/client_info.rs	41
core/sdk/src/models/consumer_group.rs	39
core/sdk/src/models/consumer_offset_info.rs	24
core/sdk/src/models/identity_info.rs	29
core/sdk/src/models/messaging/index.rs	23
core/sdk/src/models/messaging/index_view.rs	58
core/sdk/src/models/messaging/indexes.rs	156
core/sdk/src/models/messaging/message.rs	300
core/sdk/src/models/messaging/message_header.rs	155
core/sdk/src/models/messaging/message_header_view.rs	95
core/sdk/src/models/messaging/message_view.rs	157
core/sdk/src/models/messaging/messages_batch.rs	280
core/sdk/src/models/messaging/mod.rs	42
core/sdk/src/models/messaging/user_headers.rs	154
core/sdk/src/models/mod.rs	31
core/sdk/src/models/partition.rs	29
core/sdk/src/models/permissions.rs	79
core/sdk/src/models/personal_access_token.rs	28
core/sdk/src/models/snapshot.rs	25
core/sdk/src/models/stats.rs	143
core/sdk/src/models/stream.rs	39
core/sdk/src/models/topic.rs	51
core/sdk/src/models/user_info.rs	39
core/sdk/src/models/user_status.rs	40
core/sdk/src/partitioner.rs	29
core/sdk/src/partitions/create_partitions.rs	91
core/sdk/src/partitions/delete_partitions.rs	91
core/sdk/src/partitions/mod.rs	20
core/sdk/src/personal_access_tokens/create_personal_access_token.rs	89
core/sdk/src/personal_access_tokens/delete_personal_access_token.rs	78
core/sdk/src/personal_access_tokens/get_personal_access_tokens.rs	49
core/sdk/src/personal_access_tokens/login_with_personal_access_token.rs	75
core/sdk/src/personal_access_tokens/mod.rs	21
core/sdk/src/prelude.rs	73
core/sdk/src/quic/client.rs	509
core/sdk/src/quic/config.rs	156
core/sdk/src/quic/mod.rs	19
core/sdk/src/segments/delete_segments.rs	103
core/sdk/src/segments/mod.rs	18
core/sdk/src/snapshot.rs	154
core/sdk/src/stream_builder/build/build_iggy_client.rs	25
core/sdk/src/stream_builder/build/build_iggy_consumer.rs	67
core/sdk/src/stream_builder/build/build_iggy_producer.rs	63
core/sdk/src/stream_builder/build/build_stream_topic.rs	91
core/sdk/src/stream_builder/build/mod.rs	25
core/sdk/src/stream_builder/config/config_iggy_consumer.rs	371
core/sdk/src/stream_builder/config/config_iggy_producer.rs	279
core/sdk/src/stream_builder/config/config_iggy_stream.rs	146
core/sdk/src/stream_builder/config/mod.rs	23
core/sdk/src/stream_builder/iggy_stream.rs	57
core/sdk/src/stream_builder/iggy_stream_consumer.rs	58
core/sdk/src/stream_builder/iggy_stream_producer.rs	54
core/sdk/src/stream_builder/mod.rs	28
core/sdk/src/streams/create_stream.rs	93
core/sdk/src/streams/delete_stream.rs	55
core/sdk/src/streams/get_stream.rs	55
core/sdk/src/streams/get_streams.rs	49
core/sdk/src/streams/mod.rs	24
core/sdk/src/streams/purge_stream.rs	58
core/sdk/src/streams/update_stream.rs	85
core/sdk/src/system/get_client.rs	68
core/sdk/src/system/get_clients.rs	49
core/sdk/src/system/get_me.rs	49
core/sdk/src/system/get_snapshot.rs	91
core/sdk/src/system/get_stats.rs	49
core/sdk/src/system/mod.rs	23
core/sdk/src/system/ping.rs	50
core/sdk/src/tcp/client.rs	615
core/sdk/src/tcp/config.rs	110
core/sdk/src/tcp/mod.rs	19
core/sdk/src/topics/create_topic.rs	159
core/sdk/src/topics/delete_topic.rs	69
core/sdk/src/topics/get_topic.rs	69
core/sdk/src/topics/get_topics.rs	55
core/sdk/src/topics/mod.rs	25
core/sdk/src/topics/purge_topic.rs	69
core/sdk/src/topics/update_topic.rs	143
core/sdk/src/users/change_password.rs	107
core/sdk/src/users/create_user.rs	140
core/sdk/src/users/defaults.rs	27
core/sdk/src/users/delete_user.rs	55
core/sdk/src/users/get_user.rs	55
core/sdk/src/users/get_users.rs	49
core/sdk/src/users/login_user.rs	158
core/sdk/src/users/logout_user.rs	50
core/sdk/src/users/mod.rs	27
core/sdk/src/users/update_permissions.rs	88
core/sdk/src/users/update_user.rs	120
core/sdk/src/utils/byte_size.rs	107
core/sdk/src/utils/checksum.rs	20
core/sdk/src/utils/crypto.rs	48
core/sdk/src/utils/duration.rs	158
core/sdk/src/utils/expiry.rs	174
core/sdk/src/utils/mod.rs	27
core/sdk/src/utils/personal_access_token_expiry.rs	19
core/sdk/src/utils/sizeable.rs	21
core/sdk/src/utils/text.rs	30
core/sdk/src/utils/timestamp.rs	124
core/sdk/src/utils/topic_size.rs	155
core/sdk/src/validatable.rs	20
core/server/Cargo.toml	139
core/server/server.http	289
core/server/src/archiver/disk.rs	90
core/server/src/archiver/mod.rs	101
core/server/src/archiver/s3.rs	183
core/server/src/args.rs	30
core/server/src/binary/command.rs	395
core/server/src/binary/handlers/consumer_groups/create_consumer_group_handler.rs	97
core/server/src/binary/handlers/consumer_groups/delete_consumer_group_handler.rs	85
core/server/src/binary/handlers/consumer_groups/get_consumer_group_handler.rs	67
core/server/src/binary/handlers/consumer_groups/get_consumer_groups_handler.rs	66
core/server/src/binary/handlers/consumer_groups/join_consumer_group_handler.rs	70
core/server/src/binary/handlers/consumer_groups/leave_consumer_group_handler.rs	70
core/server/src/binary/handlers/consumer_groups/mod.rs	24
core/server/src/binary/handlers/consumer_offsets/delete_consumer_offset_handler.rs	70
core/server/src/binary/handlers/consumer_offsets/get_consumer_offset_handler.rs	73
core/server/src/binary/handlers/consumer_offsets/mod.rs	21
core/server/src/binary/handlers/consumer_offsets/store_consumer_offset_handler.rs	69
core/server/src/binary/handlers/messages/flush_unsaved_buffer_handler.rs	69
core/server/src/binary/handlers/messages/mod.rs	21
core/server/src/binary/handlers/messages/poll_messages_handler.rs	103
core/server/src/binary/handlers/messages/send_messages_handler.rs	115
core/server/src/binary/handlers/mod.rs	28
core/server/src/binary/handlers/partitions/create_partitions_handler.rs	87
core/server/src/binary/handlers/partitions/delete_partitions_handler.rs	86
core/server/src/binary/handlers/partitions/mod.rs	20
core/server/src/binary/handlers/personal_access_tokens/create_personal_access_token_handler.rs	93
core/server/src/binary/handlers/personal_access_tokens/delete_personal_access_token_handler.rs	79
core/server/src/binary/handlers/personal_access_tokens/get_personal_access_tokens_handler.rs	65
core/server/src/binary/handlers/personal_access_tokens/login_with_personal_access_token_handler.rs	69
core/server/src/binary/handlers/personal_access_tokens/mod.rs	22
core/server/src/binary/handlers/segments/delete_segments_handler.rs	68
core/server/src/binary/handlers/segments/mod.rs	18
core/server/src/binary/handlers/streams/create_stream_handler.rs	85
core/server/src/binary/handlers/streams/delete_stream_handler.rs	73
core/server/src/binary/handlers/streams/get_stream_handler.rs	65
core/server/src/binary/handlers/streams/get_streams_handler.rs	62
core/server/src/binary/handlers/streams/mod.rs	24
core/server/src/binary/handlers/streams/purge_stream_handler.rs	72
core/server/src/binary/handlers/streams/update_stream_handler.rs	73
core/server/src/binary/handlers/system/get_client_handler.rs	65
core/server/src/binary/handlers/system/get_clients_handler.rs	64
core/server/src/binary/handlers/system/get_me_handler.rs	66
core/server/src/binary/handlers/system/get_snapshot.rs	58
core/server/src/binary/handlers/system/get_stats_handler.rs	61
core/server/src/binary/handlers/system/mod.rs	24
core/server/src/binary/handlers/system/ping_handler.rs	63
core/server/src/binary/handlers/topics/create_topic_handler.rs	94
core/server/src/binary/handlers/topics/delete_topic_handler.rs	73
core/server/src/binary/handlers/topics/get_topic_handler.rs	64
core/server/src/binary/handlers/topics/get_topics_handler.rs	66
core/server/src/binary/handlers/topics/mod.rs	24
core/server/src/binary/handlers/topics/purge_topic_handler.rs	77
core/server/src/binary/handlers/topics/update_topic_handler.rs	86
core/server/src/binary/handlers/users/change_password_handler.rs	90
core/server/src/binary/handlers/users/create_user_handler.rs	99
core/server/src/binary/handlers/users/delete_user_handler.rs	77
core/server/src/binary/handlers/users/get_user_handler.rs	63
core/server/src/binary/handlers/users/get_users_handler.rs	63
core/server/src/binary/handlers/users/login_user_handler.rs	67
core/server/src/binary/handlers/users/logout_user_handler.rs	63
core/server/src/binary/handlers/users/mod.rs	27
core/server/src/binary/handlers/users/update_permissions_handler.rs	71
core/server/src/binary/handlers/users/update_user_handler.rs	83
core/server/src/binary/handlers/utils.rs	36
core/server/src/binary/macros.rs	76
core/server/src/binary/mapper.rs	263
core/server/src/binary/mod.rs	24
core/server/src/binary/sender.rs	90
core/server/src/build.rs	43
core/server/src/channels/commands/archive_state.rs	126
core/server/src/channels/commands/clean_personal_access_tokens.rs	124
core/server/src/channels/commands/maintain_messages.rs	496
core/server/src/channels/commands/mod.rs	23
core/server/src/channels/commands/print_sysinfo.rs	108
core/server/src/channels/commands/save_messages.rs	106
core/server/src/channels/commands/verify_heartbeats.rs	138
core/server/src/channels/handler.rs	42
core/server/src/channels/mod.rs	20
core/server/src/channels/server_command.rs	36
core/server/src/compat/index_rebuilding/index_rebuilder.rs	85
core/server/src/compat/index_rebuilding/mod.rs	18
core/server/src/compat/mod.rs	18
core/server/src/configs/cache_indexes.rs	35
core/server/src/configs/config_provider.rs	284
core/server/src/configs/defaults.rs	495
core/server/src/configs/displays.rs	344
core/server/src/configs/http.rs	127
core/server/src/configs/mod.rs	28
core/server/src/configs/quic.rs	44
core/server/src/configs/server.rs	165
core/server/src/configs/system.rs	237
core/server/src/configs/tcp.rs	46
core/server/src/configs/validators.rs	304
core/server/src/http/consumer_groups.rs	157
core/server/src/http/consumer_offsets.rs	119
core/server/src/http/diagnostics.rs	64
core/server/src/http/error.rs	109
core/server/src/http/http_server.rs	170
core/server/src/http/jwt/cleaner.rs	39
core/server/src/http/jwt/json_web_token.rs	48
core/server/src/http/jwt/jwt_manager.rs	270
core/server/src/http/jwt/middleware.rs	94
core/server/src/http/jwt/mod.rs	23
core/server/src/http/jwt/storage.rs	145
core/server/src/http/mapper.rs	235
core/server/src/http/messages.rs	141
core/server/src/http/metrics.rs	34
core/server/src/http/mod.rs	34
core/server/src/http/partitions.rs	125
core/server/src/http/personal_access_tokens.rs	164
core/server/src/http/shared.rs	31
core/server/src/http/streams.rs	229
core/server/src/http/system.rs	134
core/server/src/http/topics.rs	269
core/server/src/http/users.rs	356
core/server/src/lib.rs	47
core/server/src/log/logger.rs	377
core/server/src/log/mod.rs	21
core/server/src/log/tokio_console.rs	45
core/server/src/main.rs	161
core/server/src/quic/listener.rs	154
core/server/src/quic/mod.rs	21
core/server/src/quic/quic_sender.rs	56
core/server/src/quic/quic_server.rs	103
core/server/src/server_error.rs	84
core/server/src/state/command.rs	163
core/server/src/state/entry.rs	96
core/server/src/state/file.rs	362
core/server/src/state/mod.rs	69
core/server/src/state/models.rs	357
core/server/src/state/system.rs	528
core/server/src/streaming/clients/client_manager.rs	53
core/server/src/streaming/clients/mod.rs	18
core/server/src/streaming/deduplication/message_deduplicator.rs	82
core/server/src/streaming/deduplication/mod.rs	18
core/server/src/streaming/diagnostics/metrics.rs	118
core/server/src/streaming/diagnostics/mod.rs	18
core/server/src/streaming/local_sizeable.rs	24
core/server/src/streaming/mod.rs	33
core/server/src/streaming/partitions/consumer_offsets.rs	207
core/server/src/streaming/partitions/messages.rs	611
core/server/src/streaming/partitions/mod.rs	24
core/server/src/streaming/partitions/partition.rs	178
core/server/src/streaming/partitions/persistence.rs	105
core/server/src/streaming/partitions/segments.rs	115
core/server/src/streaming/partitions/storage.rs	410
core/server/src/streaming/persistence/mod.rs	20
core/server/src/streaming/persistence/persister.rs	176
core/server/src/streaming/persistence/task.rs	121
core/server/src/streaming/personal_access_tokens/mod.rs	18
core/server/src/streaming/personal_access_tokens/personal_access_token.rs	119
core/server/src/streaming/polling_consumer.rs	41
core/server/src/streaming/segments/indexes/index_reader.rs	334
core/server/src/streaming/segments/indexes/index_writer.rs	114
core/server/src/streaming/segments/indexes/indexes_mut.rs	259
core/server/src/streaming/segments/indexes/mod.rs	23
core/server/src/streaming/segments/messages/messages_reader.rs	170
core/server/src/streaming/segments/messages/messages_writer.rs	156
core/server/src/streaming/segments/messages/mod.rs	49
core/server/src/streaming/segments/messages/persister_task.rs	196
core/server/src/streaming/segments/messages_accumulator.rs	113
core/server/src/streaming/segments/mod.rs	34
core/server/src/streaming/segments/reading_messages.rs	304
core/server/src/streaming/segments/segment.rs	358
core/server/src/streaming/segments/types/message_header_view_mut.rs	25
core/server/src/streaming/segments/types/message_view_mut.rs	100
core/server/src/streaming/segments/types/messages_batch_mut.rs	100
core/server/src/streaming/segments/types/messages_batch_set.rs	277
core/server/src/streaming/segments/types/mod.rs	25
core/server/src/streaming/segments/writing_messages.rs	161
core/server/src/streaming/session.rs	64
core/server/src/streaming/storage.rs	192
core/server/src/streaming/streams/messages.rs	24
core/server/src/streaming/streams/mod.rs	25
core/server/src/streaming/streams/partitions.rs	27
core/server/src/streaming/streams/persistence.rs	74
core/server/src/streaming/streams/segments.rs	24
core/server/src/streaming/streams/storage.rs	201
core/server/src/streaming/streams/stream.rs	81
core/server/src/streaming/streams/topics.rs	303
core/server/src/streaming/systems/clients.rs	104
core/server/src/streaming/systems/consumer_groups.rs	290
core/server/src/streaming/systems/consumer_offsets.rs	99
core/server/src/streaming/systems/info.rs	117
core/server/src/streaming/systems/messages.rs	227
core/server/src/streaming/systems/mod.rs	33
core/server/src/streaming/systems/partitions.rs	108
core/server/src/streaming/systems/personal_access_tokens.rs	166
core/server/src/streaming/systems/segments.rs	85
core/server/src/streaming/systems/snapshot/mod.rs	181
core/server/src/streaming/systems/snapshot/procdump.rs	200
core/server/src/streaming/systems/stats.rs	28
core/server/src/streaming/systems/storage.rs	91
core/server/src/streaming/systems/streams.rs	465
core/server/src/streaming/systems/system.rs	256
core/server/src/streaming/systems/topics.rs	283
core/server/src/streaming/systems/users.rs	479
core/server/src/streaming/topics/consumer_group.rs	268
core/server/src/streaming/topics/consumer_groups.rs	395
core/server/src/streaming/topics/consumer_offsets.rs	120
core/server/src/streaming/topics/messages.rs	332
core/server/src/streaming/topics/mod.rs	27
core/server/src/streaming/topics/partitions.rs	120
core/server/src/streaming/topics/persistence.rs	63
core/server/src/streaming/topics/segments.rs	28
core/server/src/streaming/topics/storage.rs	254
core/server/src/streaming/topics/topic.rs	247
core/server/src/streaming/users/mod.rs	20
core/server/src/streaming/users/permissioner.rs	89
core/server/src/streaming/users/permissioner_rules/consumer_groups.rs	69
core/server/src/streaming/users/permissioner_rules/consumer_offsets.rs	45
core/server/src/streaming/users/permissioner_rules/messages.rs	115
core/server/src/streaming/users/permissioner_rules/mod.rs	26
core/server/src/streaming/users/permissioner_rules/partitions.rs	37
core/server/src/streaming/users/permissioner_rules/segments.rs	29
core/server/src/streaming/users/permissioner_rules/streams.rs	74
core/server/src/streaming/users/permissioner_rules/system.rs	38
core/server/src/streaming/users/permissioner_rules/topics.rs	130
core/server/src/streaming/users/permissioner_rules/users.rs	58
core/server/src/streaming/users/user.rs	126
core/server/src/streaming/utils/crypto.rs	24
core/server/src/streaming/utils/file.rs	42
core/server/src/streaming/utils/hash.rs	34
core/server/src/streaming/utils/head_tail_buf.rs	50
core/server/src/streaming/utils/memory_pool.rs	585
core/server/src/streaming/utils/mod.rs	26
core/server/src/streaming/utils/pooled_buffer.rs	161
core/server/src/streaming/utils/random_id.rs	25
core/server/src/tcp/connection_handler.rs	114
core/server/src/tcp/mod.rs	26
core/server/src/tcp/sender.rs	117
core/server/src/tcp/tcp_listener.rs	82
core/server/src/tcp/tcp_sender.rs	53
core/server/src/tcp/tcp_server.rs	37
core/server/src/tcp/tcp_socket.rs	78
core/server/src/tcp/tcp_tls_listener.rs	106
core/server/src/tcp/tcp_tls_sender.rs	55
core/server/src/versioning.rs	96
core/tools/Cargo.toml	32
core/tools/src/data-seeder/main.rs	69
core/tools/src/data-seeder/seeder.rs	186