Path	Lines of Code
core/integration/src/test_server.rs	446
core/integration/tests/archiver/disk.rs	115
core/integration/tests/archiver/mod.rs	52
core/integration/tests/archiver/s3.rs	36
core/integration/tests/bench/http.rs	61
core/integration/tests/bench/mod.rs	135
core/integration/tests/bench/quic.rs	61
core/integration/tests/bench/tcp.rs	61
core/integration/tests/cli/client/mod.rs	20
core/integration/tests/cli/client/test_client_get_command.rs	116
core/integration/tests/cli/client/test_client_help_command.rs	40
core/integration/tests/cli/client/test_client_list_command.rs	127
core/integration/tests/cli/common/command.rs	87
core/integration/tests/cli/common/help.rs	46
core/integration/tests/cli/common/mod.rs	200
core/integration/tests/cli/consumer_group/mod.rs	22
core/integration/tests/cli/consumer_group/test_consumer_group_create_command.rs	267
core/integration/tests/cli/consumer_group/test_consumer_group_delete_command.rs	284
core/integration/tests/cli/consumer_group/test_consumer_group_get_command.rs	292
core/integration/tests/cli/consumer_group/test_consumer_group_help_command.rs	42
core/integration/tests/cli/consumer_group/test_consumer_group_list_command.rs	289
core/integration/tests/cli/consumer_offset/mod.rs	19
core/integration/tests/cli/consumer_offset/test_consumer_offset_get_command.rs	322
core/integration/tests/cli/consumer_offset/test_consumer_offset_set_command.rs	330
core/integration/tests/cli/context/common.rs	67
core/integration/tests/cli/context/mod.rs	21
core/integration/tests/cli/context/test_context_applied.rs	142
core/integration/tests/cli/context/test_context_list_command.rs	167
core/integration/tests/cli/context/test_context_use_command.rs	132
core/integration/tests/cli/general/mod.rs	21
core/integration/tests/cli/general/test_help_command.rs	189
core/integration/tests/cli/general/test_missing_credentials.rs	46
core/integration/tests/cli/general/test_overview_command.rs	65
core/integration/tests/cli/general/test_quiet_mode.rs	42
core/integration/tests/cli/message/mod.rs	24
core/integration/tests/cli/message/test_message_flush_command.rs	244
core/integration/tests/cli/message/test_message_help_command.rs	41
core/integration/tests/cli/message/test_message_poll_command.rs	425
core/integration/tests/cli/message/test_message_poll_to_file_command.rs	235
core/integration/tests/cli/message/test_message_reply_via_file.rs	84
core/integration/tests/cli/message/test_message_send_command.rs	433
core/integration/tests/cli/message/test_message_send_from_file_command.rs	247
core/integration/tests/cli/mod.rs	30
core/integration/tests/cli/partition/mod.rs	20
core/integration/tests/cli/partition/test_partition_create_command.rs	269
core/integration/tests/cli/partition/test_partition_delete_command.rs	265
core/integration/tests/cli/partition/test_partition_help_command.rs	42
core/integration/tests/cli/personal_access_token/mod.rs	23
core/integration/tests/cli/personal_access_token/test_pat_create_command.rs	158
core/integration/tests/cli/personal_access_token/test_pat_delete_command.rs	117
core/integration/tests/cli/personal_access_token/test_pat_help_command.rs	41
core/integration/tests/cli/personal_access_token/test_pat_list_command.rs	139
core/integration/tests/cli/personal_access_token/test_pat_login_options.rs	34
core/integration/tests/cli/stream/mod.rs	24
core/integration/tests/cli/stream/test_stream_create_command.rs	138
core/integration/tests/cli/stream/test_stream_delete_command.rs	145
core/integration/tests/cli/stream/test_stream_get_command.rs	144
core/integration/tests/cli/stream/test_stream_help_command.rs	44
core/integration/tests/cli/stream/test_stream_list_command.rs	139
core/integration/tests/cli/stream/test_stream_purge_command.rs	185
core/integration/tests/cli/stream/test_stream_update_command.rs	148
core/integration/tests/cli/system/mod.rs	30
core/integration/tests/cli/system/test_cli_session_scenario.rs	75
core/integration/tests/cli/system/test_login_cmd.rs	105
core/integration/tests/cli/system/test_login_command.rs	64
core/integration/tests/cli/system/test_logout_cmd.rs	54
core/integration/tests/cli/system/test_logout_command.rs	57
core/integration/tests/cli/system/test_me_command.rs	184
core/integration/tests/cli/system/test_ping_command.rs	101
core/integration/tests/cli/system/test_snapshot_cmd.rs	173
core/integration/tests/cli/system/test_stats_command.rs	209
core/integration/tests/cli/topic/mod.rs	24
core/integration/tests/cli/topic/test_topic_create_command.rs	325
core/integration/tests/cli/topic/test_topic_delete_command.rs	214
core/integration/tests/cli/topic/test_topic_get_command.rs	235
core/integration/tests/cli/topic/test_topic_help_command.rs	44
core/integration/tests/cli/topic/test_topic_list_command.rs	206
core/integration/tests/cli/topic/test_topic_purge_command.rs	252
core/integration/tests/cli/topic/test_topic_update_command.rs	424
core/integration/tests/cli/user/common.rs	51
core/integration/tests/cli/user/mod.rs	28
core/integration/tests/cli/user/test_login_options.rs	77
core/integration/tests/cli/user/test_user_create_command.rs	366
core/integration/tests/cli/user/test_user_delete_command.rs	162
core/integration/tests/cli/user/test_user_get_command.rs	265
core/integration/tests/cli/user/test_user_help_command.rs	46
core/integration/tests/cli/user/test_user_list_command.rs	143
core/integration/tests/cli/user/test_user_name_command.rs	172
core/integration/tests/cli/user/test_user_password_command.rs	232
core/integration/tests/cli/user/test_user_permissions_command.rs	332
core/integration/tests/cli/user/test_user_status_command.rs	189
core/integration/tests/config_provider/mod.rs	93
core/integration/tests/data_integrity/mod.rs	18
core/integration/tests/data_integrity/verify_after_server_restart.rs	148
core/integration/tests/mod.rs	106
core/integration/tests/server/http_server.rs	67
core/integration/tests/server/mod.rs	21
core/integration/tests/server/quic_server.rs	96
core/integration/tests/server/scenarios/consumer_group_join_scenario.rs	135
core/integration/tests/server/scenarios/consumer_group_with_multiple_clients_polling_messages_scenario.rs	225
core/integration/tests/server/scenarios/consumer_group_with_single_client_polling_messages_scenario.rs	188
core/integration/tests/server/scenarios/create_message_payload.rs	143
core/integration/tests/server/scenarios/message_headers_scenario.rs	135
core/integration/tests/server/scenarios/message_size_scenario.rs	235
core/integration/tests/server/scenarios/mod.rs	92
core/integration/tests/server/scenarios/stream_size_validation_scenario.rs	211
core/integration/tests/server/scenarios/system_scenario.rs	681
core/integration/tests/server/scenarios/user_scenario.rs	188
core/integration/tests/server/tcp_server.rs	133
core/integration/tests/state/file.rs	144
core/integration/tests/state/mod.rs	74
core/integration/tests/state/system.rs	251
core/integration/tests/streaming/common/mod.rs	18
core/integration/tests/streaming/common/test_setup.rs	124
core/integration/tests/streaming/consumer_offset.rs	77
core/integration/tests/streaming/get_by_offset.rs	316
core/integration/tests/streaming/get_by_timestamp.rs	291
core/integration/tests/streaming/messages.rs	298
core/integration/tests/streaming/mod.rs	49
core/integration/tests/streaming/partition.rs	214
core/integration/tests/streaming/segment.rs	642
core/integration/tests/streaming/snapshot.rs	51
core/integration/tests/streaming/stream.rs	172
core/integration/tests/streaming/system.rs	114
core/integration/tests/streaming/topic.rs	255
core/integration/tests/streaming/topic_messages.rs	232
foreign/csharp/Iggy_SDK_Tests/BehaviorTests/ConsumerGroupPolling/Features/MultiConsumerMessagePolling.feature	9
foreign/java/java-sdk/src/test/java/rs/iggy/IggyTest.java	14
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/ConsumerGroupsClientBaseTest.java	60
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/ConsumerOffsetsClientBaseTest.java	39
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/IntegrationTest.java	42
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/MessagesClientBaseTest.java	47
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/PartitionsClientBaseTest.java	26
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/PersonalAccessTokensBaseTest.java	36
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/StreamClientBaseTest.java	42
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/SystemClientBaseTest.java	17
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/TopicsClientBaseTest.java	63
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/UsersClientBaseTest.java	83
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/ConsumerGroupsHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/ConsumerOffsetsHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/HttpClientFactory.java	10
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/MessagesHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/PartitionsHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/PersonalAccessTokensHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/StreamHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/SystemHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/TopicsHttpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/http/UsersHttpClientTest.java	18
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/BytesSerializerTest.java	61
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/ConsumerGroupsTcpClientTest.java	26
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/ConsumerOffsetsTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/MessagesTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/PartitionsTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/PersonalAccessTokensTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/StreamTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/SystemTcpClientTest.java	27
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/TcpClientFactory.java	10
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/TopicsTcpClientTest.java	9
foreign/java/java-sdk/src/test/java/rs/iggy/clients/blocking/tcp/UsersTcpClientTest.java	16
foreign/java/java-sdk/src/test/resources/logback-test.xml	15
foreign/node/src/e2e/tcp.client.e2e.ts	30
foreign/node/src/e2e/tcp.consumer-group.e2e.ts	95
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts	74
foreign/node/src/e2e/tcp.parallel.e2e.ts	47
foreign/node/src/e2e/tcp.send-message.e2e.ts	103
foreign/node/src/e2e/tcp.stream.e2e.ts	44
foreign/node/src/e2e/tcp.system.e2e.ts	37
foreign/node/src/e2e/tcp.token.e2e.ts	28
foreign/node/src/e2e/tcp.topic.e2e.ts	68
foreign/node/src/e2e/tcp.user.e2e.ts	80
foreign/node/src/wire/consumer-group/create-group.command.test.ts	37
foreign/node/src/wire/consumer-group/group.command.test.ts	40
foreign/node/src/wire/identifier.utils.test.ts	33
foreign/node/src/wire/message/header.utils.test.ts	15
foreign/node/src/wire/message/send-messages.command.test.ts	56
foreign/node/src/wire/partition/partition.utils.test.ts	21
foreign/node/src/wire/session/login-with-token.command.test.ts	27
foreign/node/src/wire/session/login.command.test.ts	45
foreign/node/src/wire/stream/create-stream.command.test.ts	35
foreign/node/src/wire/token/create-token.command.test.ts	35
foreign/node/src/wire/token/delete-token.command.test.ts	32
foreign/node/src/wire/topic/create-topic.command.test.ts	65
foreign/node/src/wire/user/create-user.command.test.ts	55
foreign/node/src/wire/user/permissions.utils.test.ts	25