Path Lines of Code foreign/csharp/Benchmarks/Program.cs 87 foreign/csharp/Benchmarks/SendMessage.cs 65 foreign/csharp/Iggy_SDK/AssemblyInfo.cs 4 foreign/csharp/Iggy_SDK/Configuration/IMessageStreamConfigurator.cs 12 foreign/csharp/Iggy_SDK/Configuration/MessageBatchingSettings.cs 8 foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs 7 foreign/csharp/Iggy_SDK/Configuration/MessageStreamConfigurator.cs 26 foreign/csharp/Iggy_SDK/Configuration/TlsConfiguration.cs 7 foreign/csharp/Iggy_SDK/ConnectionStream/IConnectionStream.cs 8 foreign/csharp/Iggy_SDK/ConnectionStream/TcpConnectionStream.cs 20 foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs 20 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/AuthResponse.cs 2 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/ChangePasswordRequest.cs 9 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreatePersonalAccessTokenRequest.cs 6 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreateUserRequest.cs 9 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/DeletePersonalAccessTokenRequest.cs 5 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/GlobalPermissions.cs 14 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginUserRequest.cs 8 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginWIthPersonalAccessToken.cs 5 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/Permissions.cs 6 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/PersonalAccessTokenResponse.cs 6 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/RawPersonalAccessToken.cs 5 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/TokenInfo.cs 2 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserPermissionsRequest.cs 8 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserRequest.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UserResponse.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/ClientInfo.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/ConsumerGroupInfo.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/ConsumerGroupMembers.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/ConsumerGroupResponse.cs 9 foreign/csharp/Iggy_SDK/Contracts/Http/CreateConsumerGroupRequest.cs 11 foreign/csharp/Iggy_SDK/Contracts/Http/CreatePartitionsRequest.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/CreateStreamRequest.cs 6 foreign/csharp/Iggy_SDK/Contracts/Http/DeleteConsumerGroup.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/DeletePartitionsRequest.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/JoinConsumerGroupRequest.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/LeaveConsumerGroupRequest.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/MessageFetchRequest.cs 12 foreign/csharp/Iggy_SDK/Contracts/Http/MessageResponse.cs 13 foreign/csharp/Iggy_SDK/Contracts/Http/MessageResponseGeneric.cs 13 foreign/csharp/Iggy_SDK/Contracts/Http/MessageSendRequest.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/MessageSendRequestGeneric.cs 9 foreign/csharp/Iggy_SDK/Contracts/Http/OffsetRequest.cs 9 foreign/csharp/Iggy_SDK/Contracts/Http/OffsetResponse.cs 7 foreign/csharp/Iggy_SDK/Contracts/Http/PartitionResponse.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/PollMessagesRequest.cs 12 foreign/csharp/Iggy_SDK/Contracts/Http/PolledMessages.cs 14 foreign/csharp/Iggy_SDK/Contracts/Http/PolledMessagesGeneric.cs 14 foreign/csharp/Iggy_SDK/Contracts/Http/Stats.cs 26 foreign/csharp/Iggy_SDK/Contracts/Http/StatsResponse.cs 54 foreign/csharp/Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs 13 foreign/csharp/Iggy_SDK/Contracts/Http/StreamPermissions.cs 11 foreign/csharp/Iggy_SDK/Contracts/Http/StreamResponse.cs 11 foreign/csharp/Iggy_SDK/Contracts/Http/TopicPermissions.cs 8 foreign/csharp/Iggy_SDK/Contracts/Http/TopicRequest.cs 10 foreign/csharp/Iggy_SDK/Contracts/Http/TopicResponse.cs 14 foreign/csharp/Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs 5 foreign/csharp/Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs 8 foreign/csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs 646 foreign/csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs 6 foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs 6 foreign/csharp/Iggy_SDK/Enums/IdKind.cs 20 foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs 9 foreign/csharp/Iggy_SDK/Enums/MessageState.cs 8 foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs 7 foreign/csharp/Iggy_SDK/Enums/Protocol.cs 7 foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs 7 foreign/csharp/Iggy_SDK/Enums/UserStatus.cs 6 foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs 138 foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs 13 foreign/csharp/Iggy_SDK/Exceptions/FeatureUnavailableException.cs 7 foreign/csharp/Iggy_SDK/Exceptions/InvalidBaseAdressException.cs 7 foreign/csharp/Iggy_SDK/Exceptions/InvalidResponseException.cs 7 foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs 7 foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs 7 foreign/csharp/Iggy_SDK/Extensions/Extensions.cs 111 foreign/csharp/Iggy_SDK/Factory/HttpMessageStreamBuilder.cs 53 foreign/csharp/Iggy_SDK/Factory/MessageStreamFactory.cs 77 foreign/csharp/Iggy_SDK/Factory/TcpMessageStreamBuilder.cs 54 foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs 18 foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs 15 foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs 228 foreign/csharp/Iggy_SDK/Identifier.cs 55 foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs 5 foreign/csharp/Iggy_SDK/IggyClient/IIggyConsumer.cs 12 foreign/csharp/Iggy_SDK/IggyClient/IIggyConsumerGroup.cs 13 foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs 7 foreign/csharp/Iggy_SDK/IggyClient/IIggyPartition.cs 7 foreign/csharp/Iggy_SDK/IggyClient/IIggyPersonalAccessToken.cs 9 foreign/csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs 12 foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs 10 foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs 10 foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs 15 foreign/csharp/Iggy_SDK/IggyClient/IIggyUtils.cs 8 foreign/csharp/Iggy_SDK/IggyClient/Implementations/HttpMessageStream.cs 589 foreign/csharp/Iggy_SDK/IggyClient/Implementations/TcpMessageStream.cs 968 foreign/csharp/Iggy_SDK/JsonConfiguration/AuthResponseConverter.cs 25 foreign/csharp/Iggy_SDK/JsonConfiguration/CreateTopicConverter.cs 27 foreign/csharp/Iggy_SDK/JsonConfiguration/JsonConverterFactory.cs 122 foreign/csharp/Iggy_SDK/JsonConfiguration/MessageConverter.cs 54 foreign/csharp/Iggy_SDK/JsonConfiguration/MessageResponseConverter.cs 92 foreign/csharp/Iggy_SDK/JsonConfiguration/MessageResponseGenericConverter.cs 94 foreign/csharp/Iggy_SDK/JsonConfiguration/MessagesConverter.cs 52 foreign/csharp/Iggy_SDK/JsonConfiguration/PersonAccessTokenResponseConverter.cs 31 foreign/csharp/Iggy_SDK/JsonConfiguration/StatsResponseConverter.cs 96 foreign/csharp/Iggy_SDK/JsonConfiguration/StreamResponseConverter.cs 66 foreign/csharp/Iggy_SDK/JsonConfiguration/ToSnakeCaseNamingPolicy.cs 7 foreign/csharp/Iggy_SDK/JsonConfiguration/TopicResponseConverter.cs 127 foreign/csharp/Iggy_SDK/JsonConfiguration/UInt128Converter.cs 19 foreign/csharp/Iggy_SDK/JsonConfiguration/UserResponseConverter.cs 15 foreign/csharp/Iggy_SDK/Kinds/Consumer.cs 39 foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs 88 foreign/csharp/Iggy_SDK/Kinds/PollingStrategy.cs 47 foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs 745 foreign/csharp/Iggy_SDK/Messages/HttpMessage.cs 8 foreign/csharp/Iggy_SDK/Messages/Message.cs 8 foreign/csharp/Iggy_SDK/MessagesDispatcher/HttpMessageInvoker.cs 38 foreign/csharp/Iggy_SDK/MessagesDispatcher/IMessageInvoker.cs 7 foreign/csharp/Iggy_SDK/MessagesDispatcher/MessageSenderDispatcher.cs 174 foreign/csharp/Iggy_SDK/MessagesDispatcher/TcpMessageInvoker.cs 51 foreign/csharp/Iggy_SDK/StringHandlers/MessageRequestInterpolationHandler.cs 50 foreign/csharp/Iggy_SDK/Utils/BufferSizes.cs 6 foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs 44 foreign/csharp/Iggy_SDK/Utils/TcpMessageStreamHelpers.cs 103 foreign/csharp/Iggy_SDK_Tests/BehaviorTests/ConsumerGroupPolling/Hooks/IggyDockerHooks.cs 35 foreign/csharp/Iggy_SDK_Tests/BehaviorTests/ConsumerGroupPolling/Steps/MultipleConsumersPollingSteps.cs 119 foreign/csharp/Iggy_SDK_Tests/ContractTests/TcpContract.cs 731 foreign/csharp/Iggy_SDK_Tests/E2ETests/ClientsE2E.cs 33 foreign/csharp/Iggy_SDK_Tests/E2ETests/ConsumerGroupE2E.cs 108 foreign/csharp/Iggy_SDK_Tests/E2ETests/FetchMessagesE2E.cs 117 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/ClientsFixtureBootstrap.cs 36 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/ConsumerGroupFixtureBootstrap.cs 18 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/FetchMessagesFixtureBootstrap.cs 42 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/GeneralFixtureBootstrap.cs 9 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/OffsetFixtureBootstrap.cs 18 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/PATFixtureBootstrap.cs 15 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/PartitionsFixtureBootstrap.cs 18 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/PollMessagesFixtureBootstrap.cs 48 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/SendMessagesFixtureBootstrap.cs 25 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/StreamsFixtureBootstrap.cs 13 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/TopicsFixtureBootstrap.cs 16 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Bootstraps/UsersFixtureBootstrap.cs 16 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/Configs/IggyFixtureClientConfigs.cs 37 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IIggyBootstrap.cs 6 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyBaseFixture.cs 77 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyClientsFixture.cs 10 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyConsumerGroupFixture.cs 10 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyFetchMessagesFixture.cs 10 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyGeneralFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyOffsetFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyPATFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyPartitionFixture.cs 12 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyPollMessagesFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggySendMessagesFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyStreamFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyTcpUsersFixture.cs 21 foreign/csharp/Iggy_SDK_Tests/E2ETests/Fixtures/IggyTopicFixture.cs 11 foreign/csharp/Iggy_SDK_Tests/E2ETests/OffsetE2E.cs 42 foreign/csharp/Iggy_SDK_Tests/E2ETests/PATE2E.cs 75 foreign/csharp/Iggy_SDK_Tests/E2ETests/PartitionsE2E.cs 66 foreign/csharp/Iggy_SDK_Tests/E2ETests/PollMessagesE2E.cs 48 foreign/csharp/Iggy_SDK_Tests/E2ETests/SendMessagesE2E.cs 62 foreign/csharp/Iggy_SDK_Tests/E2ETests/StreamsE2E.cs 77 foreign/csharp/Iggy_SDK_Tests/E2ETests/TopicsE2E.cs 106 foreign/csharp/Iggy_SDK_Tests/E2ETests/UsersE2E.cs 121 foreign/csharp/Iggy_SDK_Tests/E2ETests/UtilsE2E.cs 26 foreign/csharp/Iggy_SDK_Tests/MapperTests/BinaryMapper.cs 290 foreign/csharp/Iggy_SDK_Tests/Usings.cs 1 foreign/csharp/Iggy_SDK_Tests/UtilityTests/HeaderValueTests.cs 379 foreign/csharp/Iggy_SDK_Tests/UtilityTests/IdentifiersByteSerializationTests.cs 26 foreign/csharp/Iggy_SDK_Tests/UtilityTests/ToSnakeCaseMessagePolicyTests.cs 28 foreign/csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs 135 foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs 6 foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs 13 foreign/csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs 13 foreign/csharp/Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs 94 foreign/csharp/Iggy_SDK_Tests/Utils/Messages/MessageFactory.cs 243 foreign/csharp/Iggy_SDK_Tests/Utils/Offsets/OffsetFactory.cs 63 foreign/csharp/Iggy_SDK_Tests/Utils/Partitions/PartitionFactory.cs 50 foreign/csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs 31 foreign/csharp/Iggy_SDK_Tests/Utils/SpecFlowTypes/ConsumerPollStreamTopicId.cs 7 foreign/csharp/Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs 32 foreign/csharp/Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs 40 foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs 10 foreign/csharp/Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs 79 foreign/csharp/Iggy_SDK_Tests/Utils/Users/PermissionsFactory.cs 147 foreign/csharp/Iggy_SDK_Tests/Utils/Users/UsersFactory.cs 59 foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs 10 foreign/csharp/Iggy_Sample_Consumer/Program.cs 189 foreign/csharp/Iggy_Sample_Producer/MessageGenerator.cs 62 foreign/csharp/Iggy_Sample_Producer/Program.cs 192 foreign/csharp/Shared/Envelope.cs 23 foreign/csharp/Shared/ISerializableMessage.cs 7 foreign/csharp/Shared/Orders.cs 123 foreign/java/java-sdk/build.gradle.kts 86 foreign/java/java-sdk/src/main/java/rs/iggy/Iggy.java 9 foreign/java/java-sdk/src/main/java/rs/iggy/NonNullApi.java 11 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/ConsumerGroupsClient.java 34 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/ConsumerOffsetsClient.java 17 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/IggyBaseClient.java 12 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/IggyClient.java 10 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/IggyClientBuilder.java 14 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/MessagesClient.java 21 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/PartitionsClient.java 13 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/PersonalAccessTokensClient.java 12 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/StreamsClient.java 22 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/SystemClient.java 12 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/TopicsClient.java 70 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/UsersClient.java 31 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/ConsumerGroupsHttpClient.java 52 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/ConsumerOffsetsHttpClient.java 34 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/IggyHttpClient.java 61 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/InternalHttpClient.java 119 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/MessagesHttpClient.java 39 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/ObjectMapperFactory.java 22 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/PartitionsHttpClient.java 28 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/PersonalAccessTokensHttpClient.java 46 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/StreamsHttpClient.java 46 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/SystemHttpClient.java 41 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/TopicsHttpClient.java 85 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/UsersHttpClient.java 78 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/error/IggyHttpError.java 8 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/error/IggyHttpException.java 11 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/http/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/BytesDeserializer.java 345 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/BytesSerializer.java 179 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/ConsumerGroupsTcpClient.java 83 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/ConsumerOffsetTcpClient.java 40 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/IggyTcpClient.java 62 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/InternalTcpClient.java 74 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/MessagesTcpClient.java 42 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/PartitionsTcpClient.java 27 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/PersonalAccessTokensTcpClient.java 53 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/StreamsTcpClient.java 66 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/SystemTcpClient.java 51 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/TopicsTcpClient.java 86 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/UsersTcpClient.java 115 foreign/java/java-sdk/src/main/java/rs/iggy/clients/blocking/tcp/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/consumergroup/Consumer.java 27 foreign/java/java-sdk/src/main/java/rs/iggy/consumergroup/ConsumerGroup.java 8 foreign/java/java-sdk/src/main/java/rs/iggy/consumergroup/ConsumerGroupDetails.java 17 foreign/java/java-sdk/src/main/java/rs/iggy/consumergroup/ConsumerGroupMember.java 8 foreign/java/java-sdk/src/main/java/rs/iggy/consumergroup/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/consumeroffset/ConsumerOffsetInfo.java 8 foreign/java/java-sdk/src/main/java/rs/iggy/consumeroffset/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/ConsumerId.java 13 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/Identifier.java 41 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/StreamId.java 13 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/TopicId.java 13 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/UserId.java 13 foreign/java/java-sdk/src/main/java/rs/iggy/identifier/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/message/BigIntegerMessageId.java 25 foreign/java/java-sdk/src/main/java/rs/iggy/message/BytesMessageId.java 26 foreign/java/java-sdk/src/main/java/rs/iggy/message/HeaderKind.java 33 foreign/java/java-sdk/src/main/java/rs/iggy/message/HeaderValue.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/message/Message.java 12 foreign/java/java-sdk/src/main/java/rs/iggy/message/MessageId.java 17 foreign/java/java-sdk/src/main/java/rs/iggy/message/MessageState.java 19 foreign/java/java-sdk/src/main/java/rs/iggy/message/Partitioning.java 24 foreign/java/java-sdk/src/main/java/rs/iggy/message/PartitioningKind.java 17 foreign/java/java-sdk/src/main/java/rs/iggy/message/PolledMessage.java 14 foreign/java/java-sdk/src/main/java/rs/iggy/message/PolledMessages.java 9 foreign/java/java-sdk/src/main/java/rs/iggy/message/PollingKind.java 15 foreign/java/java-sdk/src/main/java/rs/iggy/message/PollingStrategy.java 19 foreign/java/java-sdk/src/main/java/rs/iggy/message/UuidMessageId.java 29 foreign/java/java-sdk/src/main/java/rs/iggy/message/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/partition/Partition.java 11 foreign/java/java-sdk/src/main/java/rs/iggy/partition/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/personalaccesstoken/PersonalAccessTokenInfo.java 5 foreign/java/java-sdk/src/main/java/rs/iggy/personalaccesstoken/RawPersonalAccessToken.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/stream/StreamBase.java 11 foreign/java/java-sdk/src/main/java/rs/iggy/stream/StreamDetails.java 17 foreign/java/java-sdk/src/main/java/rs/iggy/stream/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/system/ClientInfo.java 10 foreign/java/java-sdk/src/main/java/rs/iggy/system/ClientInfoDetails.java 16 foreign/java/java-sdk/src/main/java/rs/iggy/system/ConsumerGroupInfo.java 7 foreign/java/java-sdk/src/main/java/rs/iggy/system/Stats.java 27 foreign/java/java-sdk/src/main/java/rs/iggy/system/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/topic/CompressionAlgorithm.java 20 foreign/java/java-sdk/src/main/java/rs/iggy/topic/Topic.java 15 foreign/java/java-sdk/src/main/java/rs/iggy/topic/TopicDetails.java 31 foreign/java/java-sdk/src/main/java/rs/iggy/topic/package-info.java 3 foreign/java/java-sdk/src/main/java/rs/iggy/user/GlobalPermissions.java 14 foreign/java/java-sdk/src/main/java/rs/iggy/user/IdentityInfo.java 4 foreign/java/java-sdk/src/main/java/rs/iggy/user/Permissions.java 10 foreign/java/java-sdk/src/main/java/rs/iggy/user/StreamPermissions.java 15 foreign/java/java-sdk/src/main/java/rs/iggy/user/TokenInfo.java 4 foreign/java/java-sdk/src/main/java/rs/iggy/user/TopicPermissions.java 8 foreign/java/java-sdk/src/main/java/rs/iggy/user/UserInfo.java 9 foreign/java/java-sdk/src/main/java/rs/iggy/user/UserInfoDetails.java 14 foreign/java/java-sdk/src/main/java/rs/iggy/user/UserStatus.java 23 foreign/java/java-sdk/src/main/java/rs/iggy/user/package-info.java 3 foreign/java/settings.gradle.kts 6 foreign/node/commitlint.config.js 7 foreign/node/eslint.config.mjs 53 foreign/node/src/client.e2e.ts 31 foreign/node/src/client/client.debug.ts 2 foreign/node/src/client/client.socket.ts 171 foreign/node/src/client/client.ts 84 foreign/node/src/client/client.type.ts 39 foreign/node/src/client/client.utils.ts 44 foreign/node/src/client/index.ts 6 foreign/node/src/client/tcp.client.ts 11 foreign/node/src/client/tls.client.ts 14 foreign/node/src/debug-send.ts 54 foreign/node/src/debug.ts 75 foreign/node/src/index.ts 9 foreign/node/src/quic.lib-test.js 34 foreign/node/src/stream/consumer-stream.ts 89 foreign/node/src/stream/index.ts 1 foreign/node/src/tcp.e2e.ts 69 foreign/node/src/tcp.sm.utils.ts 32 foreign/node/src/tls.system.e2e.ts 17 foreign/node/src/type.utils.ts 12 foreign/node/src/wire/client/client.utils.ts 31 foreign/node/src/wire/client/get-client.command.ts 16 foreign/node/src/wire/client/get-clients.command.ts 19 foreign/node/src/wire/client/get-me.command.ts 9 foreign/node/src/wire/client/index.ts 3 foreign/node/src/wire/command-set.ts 140 foreign/node/src/wire/command.code.ts 50 foreign/node/src/wire/command.utils.ts 12 foreign/node/src/wire/consumer-group/create-group.command.ts 31 foreign/node/src/wire/consumer-group/delete-group.command.ts 17 foreign/node/src/wire/consumer-group/get-group.command.ts 22 foreign/node/src/wire/consumer-group/get-groups.command.ts 22 foreign/node/src/wire/consumer-group/group.utils.ts 44 foreign/node/src/wire/consumer-group/index.ts 6 foreign/node/src/wire/consumer-group/join-group.command.ts 17 foreign/node/src/wire/consumer-group/leave-group.command.ts 17 foreign/node/src/wire/error.code.ts 126 foreign/node/src/wire/error.utils.ts 6 foreign/node/src/wire/identifier.utils.ts 33 foreign/node/src/wire/index.ts 12 foreign/node/src/wire/message/.#message.utils.ts 1 foreign/node/src/wire/message/header.type.ts 82 foreign/node/src/wire/message/header.utils.ts 244 foreign/node/src/wire/message/index.ts 5 foreign/node/src/wire/message/message.utils.ts 70 foreign/node/src/wire/message/partitioning.utils.ts 71 foreign/node/src/wire/message/poll-messages.command.ts 31 foreign/node/src/wire/message/poll.utils.ts 172 foreign/node/src/wire/message/send-messages.command.ts 19 foreign/node/src/wire/number.utils.ts 55 foreign/node/src/wire/offset/get-offset.command.ts 27 foreign/node/src/wire/offset/index.ts 3 foreign/node/src/wire/offset/offset.utils.ts 54 foreign/node/src/wire/offset/store-offset.command.ts 18 foreign/node/src/wire/partition/create-partition.command.ts 17 foreign/node/src/wire/partition/delete-partition.command.ts 17 foreign/node/src/wire/partition/index.ts 2 foreign/node/src/wire/partition/partition.utils.ts 16 foreign/node/src/wire/serialize.utils.ts 1 foreign/node/src/wire/session/index.ts 3 foreign/node/src/wire/session/login-with-token.command.ts 25 foreign/node/src/wire/session/login.command.ts 61 foreign/node/src/wire/session/login.type.ts 3 foreign/node/src/wire/session/logout.command.ts 10 foreign/node/src/wire/stream/create-stream.command.ts 26 foreign/node/src/wire/stream/delete-stream.command.ts 14 foreign/node/src/wire/stream/get-stream.command.ts 17 foreign/node/src/wire/stream/get-streams.command.ts 19 foreign/node/src/wire/stream/index.ts 6 foreign/node/src/wire/stream/purge-stream.command.ts 14 foreign/node/src/wire/stream/stream.utils.ts 28 foreign/node/src/wire/stream/update-stream.command.ts 24 foreign/node/src/wire/system/get-stats.command.ts 99 foreign/node/src/wire/system/index.ts 2 foreign/node/src/wire/system/ping.command.ts 10 foreign/node/src/wire/token/create-token.command.ts 26 foreign/node/src/wire/token/delete-token.command.ts 21 foreign/node/src/wire/token/get-tokens.command.ts 9 foreign/node/src/wire/token/index.ts 3 foreign/node/src/wire/token/token.utils.ts 49 foreign/node/src/wire/topic/create-topic.command.ts 59 foreign/node/src/wire/topic/delete-topic.command.ts 21 foreign/node/src/wire/topic/get-topic.command.ts 21 foreign/node/src/wire/topic/get-topics.command.ts 17 foreign/node/src/wire/topic/index.ts 6 foreign/node/src/wire/topic/purge-topic.command.ts 18 foreign/node/src/wire/topic/topic.utils.ts 103 foreign/node/src/wire/topic/update-topic.command.ts 49 foreign/node/src/wire/user/change-password.command.ts 30 foreign/node/src/wire/user/create-user.command.ts 35 foreign/node/src/wire/user/delete-user.command.ts 14 foreign/node/src/wire/user/get-user.command.ts 15 foreign/node/src/wire/user/get-users.command.ts 9 foreign/node/src/wire/user/index.ts 7 foreign/node/src/wire/user/permissions.utils.ts 192 foreign/node/src/wire/user/update-permissions.command.ts 23 foreign/node/src/wire/user/update-user.command.ts 39 foreign/node/src/wire/user/user.utils.ts 63 foreign/node/src/wire/uuid.utils.ts 3