This is an automated email from the ASF dual-hosted git repository.
bashirbekov pushed a change to branch feat/add-background-send
in repository https://gitbox.apache.org/repos/asf/iggy.git
from e810456d test parallel
add 9caa542d chore(ci): Remove archived actions-rs/* actions (#1858)
add a8b3ef74 chore(csharp): add csharp ci (#1857)
add cd949eeb Merge remote-tracking branch 'origin/master' into
feat/add-background-send
No new revisions were added by this update.
Summary of changes:
.github/changed-files-config.json | 6 ++
.github/workflows/ci-check-common.yml | 7 +-
.github/workflows/ci-check-csharp-sdk.yml | 61 ++++++++++++
.github/workflows/ci-check-pr.yml | 10 +-
.github/workflows/ci-check-rust.yml | 109 ++++++++-------------
.github/workflows/ci-prod-rust.yml | 9 +-
.github/workflows/ci-test-rust-optional.yml | 9 +-
.github/workflows/ci-test-rust.yml | 18 ++--
.github/workflows/publish_cli.yml | 7 +-
.../{publish_sdk.yml => publish_csharp_sdk.yml} | 86 +++++++---------
.github/workflows/publish_sdk.yml | 7 +-
.github/workflows/publish_server.yml | 9 +-
.github/workflows/release_cli.yml | 9 +-
.github/workflows/release_server.yml | 18 ++--
.github/workflows/security.yml | 9 +-
.github/workflows/test_daily.yml | 9 +-
.github/workflows/test_nightly.yml | 9 +-
foreign/csharp/Benchmarks/Benchmarks.csproj | 2 +
foreign/csharp/Benchmarks/Program.cs | 14 +--
foreign/csharp/Benchmarks/SendMessage.cs | 11 +--
foreign/csharp/Iggy_SDK/AssemblyInfo.cs | 6 +-
.../Configuration/IMessageStreamConfigurator.cs | 4 +-
.../Configuration/MessageBatchingSettings.cs | 2 +-
.../Configuration/MessagePollingSettings.cs | 5 +-
.../Configuration/MessageStreamConfigurator.cs | 4 +-
.../Iggy_SDK/Configuration/TlsConfiguration.cs | 2 +-
.../Iggy_SDK/ConnectionStream/IConnectionStream.cs | 2 +-
.../ConnectionStream/TcpConnectionStream.cs | 2 +-
.../ConnectionStream/TcpTslConnectionStream.cs | 2 +-
.../Iggy_SDK/Contracts/Http/Auth/AuthResponse.cs | 2 +-
.../Contracts/Http/Auth/ChangePasswordRequest.cs | 2 +-
.../Http/Auth/CreatePersonalAccessTokenRequest.cs | 2 +-
.../Contracts/Http/Auth/CreateUserRequest.cs | 4 +-
.../Http/Auth/DeletePersonalAccessTokenRequest.cs | 2 +-
.../Contracts/Http/Auth/GlobalPermissions.cs | 2 +-
.../Contracts/Http/Auth/LoginUserRequest.cs | 2 +-
.../Http/Auth/LoginWIthPersonalAccessToken.cs | 2 +-
.../Iggy_SDK/Contracts/Http/Auth/Permissions.cs | 2 +-
.../Http/Auth/PersonalAccessTokenResponse.cs | 2 +-
.../Contracts/Http/Auth/RawPersonalAccessToken.cs | 2 +-
.../Iggy_SDK/Contracts/Http/Auth/TokenInfo.cs | 2 +-
.../Http/Auth/UpdateUserPermissionsRequest.cs | 2 +-
.../Contracts/Http/Auth/UpdateUserRequest.cs | 4 +-
.../Iggy_SDK/Contracts/Http/Auth/UserResponse.cs | 4 +-
.../csharp/Iggy_SDK/Contracts/Http/CacheMetrics.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Http/ClientInfo.cs | 2 +-
.../Iggy_SDK/Contracts/Http/ConsumerGroupInfo.cs | 2 +-
.../Contracts/Http/ConsumerGroupMembers.cs | 2 +-
.../Contracts/Http/ConsumerGroupResponse.cs | 2 +-
.../Contracts/Http/CreateConsumerGroupRequest.cs | 2 +-
.../Contracts/Http/CreatePartitionsRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/CreateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/DeleteConsumerGroup.cs | 2 +-
.../Contracts/Http/DeletePartitionsRequest.cs | 2 +-
.../Contracts/Http/FlushUnsavedBufferRequest.cs | 2 +-
.../Contracts/Http/JoinConsumerGroupRequest.cs | 2 +-
.../Contracts/Http/LeaveConsumerGroupRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/MessageFetchRequest.cs | 4 +-
.../Iggy_SDK/Contracts/Http/MessageResponse.cs | 6 +-
.../Contracts/Http/MessageResponseGeneric.cs | 6 +-
.../Iggy_SDK/Contracts/Http/MessageSendRequest.cs | 6 +-
.../Contracts/Http/MessageSendRequestGeneric.cs | 5 +-
.../Iggy_SDK/Contracts/Http/OffsetRequest.cs | 4 +-
.../Iggy_SDK/Contracts/Http/OffsetResponse.cs | 2 +-
.../Iggy_SDK/Contracts/Http/PartitionResponse.cs | 2 +-
.../Iggy_SDK/Contracts/Http/PollMessagesRequest.cs | 6 +-
.../Iggy_SDK/Contracts/Http/PolledMessages.cs | 2 +-
.../Contracts/Http/PolledMessagesGeneric.cs | 2 +-
.../Iggy_SDK/Contracts/Http/SnapshotRequest.cs | 4 +-
foreign/csharp/Iggy_SDK/Contracts/Http/Stats.cs | 2 +-
.../Iggy_SDK/Contracts/Http/StatsResponse.cs | 4 +-
.../Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs | 4 +-
.../Iggy_SDK/Contracts/Http/StreamPermissions.cs | 2 +-
.../Iggy_SDK/Contracts/Http/StreamResponse.cs | 2 +-
.../Iggy_SDK/Contracts/Http/TopicPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Http/TopicRequest.cs | 4 +-
.../Iggy_SDK/Contracts/Http/TopicResponse.cs | 4 +-
.../Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs | 4 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 20 ++--
.../csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 3 +-
foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/MessageState.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/Protocol.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SnapshotCompression.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SystemSnapshotType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/UserStatus.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs | 2 +-
.../Exceptions/FeatureUnavailableException.cs | 2 +-
.../Exceptions/InvalidBaseAdressException.cs | 2 +-
.../Exceptions/InvalidResponseException.cs | 2 +-
.../Exceptions/TcpInvalidResponseException.cs | 2 +-
.../csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs | 2 +-
foreign/csharp/Iggy_SDK/Extensions/Extensions.cs | 4 +-
.../Iggy_SDK/Factory/HttpMessageStreamBuilder.cs | 14 +--
.../Iggy_SDK/Factory/MessageStreamFactory.cs | 19 ++--
.../Iggy_SDK/Factory/TcpMessageStreamBuilder.cs | 16 +--
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 4 +-
foreign/csharp/Iggy_SDK/Identifier.cs | 4 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs | 2 +-
.../csharp/Iggy_SDK/IggyClient/IIggyConsumer.cs | 5 +-
.../Iggy_SDK/IggyClient/IIggyConsumerGroup.cs | 5 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs | 5 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPartition.cs | 5 +-
.../IggyClient/IIggyPersonalAccessToken.cs | 5 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 7 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 5 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs | 5 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 5 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs | 4 +-
.../Implementations/HttpMessageStream.cs | 27 ++---
.../IggyClient/Implementations/TcpMessageStream.cs | 32 +++---
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 6 +-
.../JsonConfiguration/AuthResponseConverter.cs | 7 +-
.../JsonConfiguration/CreateTopicConverter.cs | 6 +-
.../JsonConfiguration/JsonConverterFactory.cs | 3 +-
.../Iggy_SDK/JsonConfiguration/MessageConverter.cs | 8 +-
.../JsonConfiguration/MessageResponseConverter.cs | 10 +-
.../MessageResponseGenericConverter.cs | 10 +-
.../JsonConfiguration/MessagesConverter.cs | 9 +-
.../PersonAccessTokenResponseConverter.cs | 7 +-
.../JsonConfiguration/StatsResponseConverter.cs | 20 ++--
.../JsonConfiguration/StreamResponseConverter.cs | 6 +-
.../JsonConfiguration/ToSnakeCaseNamingPolicy.cs | 4 +-
.../JsonConfiguration/TopicResponseConverter.cs | 8 +-
.../Iggy_SDK/JsonConfiguration/UInt128Converter.cs | 2 +-
.../JsonConfiguration/UserResponseConverter.cs | 5 +-
foreign/csharp/Iggy_SDK/Kinds/Consumer.cs | 4 +-
foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs | 3 +-
foreign/csharp/Iggy_SDK/Kinds/PollingStrategy.cs | 4 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 16 +--
foreign/csharp/Iggy_SDK/Messages/Message.cs | 6 +-
foreign/csharp/Iggy_SDK/Messages/MessageHeader.cs | 2 +-
.../MessagesDispatcher/HttpMessageInvoker.cs | 8 +-
.../Iggy_SDK/MessagesDispatcher/IMessageInvoker.cs | 5 +-
.../MessagesDispatcher/MessageSenderDispatcher.cs | 12 +--
.../MessagesDispatcher/TcpMessageInvoker.cs | 12 +--
.../MessageRequestInterpolationHandler.cs | 4 +-
foreign/csharp/Iggy_SDK/Utils/BufferSizes.cs | 2 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 6 +-
.../Iggy_SDK_Tests/ContractTests/TcpContract.cs | 31 +++---
.../Iggy_SDK_Tests/E2ETests/ConsumerGroupE2E.cs | 17 ++--
.../Iggy_SDK_Tests/E2ETests/FetchMessagesE2E.cs | 17 ++--
.../Bootstraps/ConsumerGroupFixtureBootstrap.cs | 12 +--
.../Bootstraps/FetchMessagesFixtureBootstrap.cs | 14 ++-
.../Bootstraps/FlushMessagesFixtureBootstrap.cs | 15 ++-
.../Fixtures/Bootstraps/GeneralFixtureBootstrap.cs | 5 +-
.../Fixtures/Bootstraps/OffsetFixtureBootstrap.cs | 11 +--
.../Fixtures/Bootstraps/PATFixtureBootstrap.cs | 6 +-
.../Bootstraps/PartitionsFixtureBootstrap.cs | 11 +--
.../Bootstraps/PollMessagesFixtureBootstrap.cs | 17 ++--
.../Bootstraps/SendMessagesFixtureBootstrap.cs | 11 +--
.../Fixtures/Bootstraps/StreamsFixtureBootstrap.cs | 8 +-
.../Fixtures/Bootstraps/SystemFixtureBootstrap.cs | 10 +-
.../Fixtures/Bootstraps/TopicsFixtureBootstrap.cs | 10 +-
.../Fixtures/Bootstraps/UsersFixtureBootstrap.cs | 8 +-
.../Fixtures/Configs/IggyFixtureClientConfigs.cs | 6 +-
.../E2ETests/Fixtures/IIggyBootstrap.cs | 4 +-
.../E2ETests/Fixtures/IggyBaseFixture.cs | 20 ++--
.../E2ETests/Fixtures/IggyConsumerGroupFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyFetchMessagesFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyFlushMessagesFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyGeneralFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyOffsetFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyPATFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyPartitionFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyPollMessagesFixture.cs | 6 +-
.../E2ETests/Fixtures/IggySendMessagesFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyStreamFixture.cs | 6 +-
.../E2ETests/Fixtures/IggySystemFixture.cs | 6 +-
.../E2ETests/Fixtures/IggyTcpUsersFixture.cs | 7 +-
.../E2ETests/Fixtures/IggyTopicFixture.cs | 6 +-
.../E2ETests/Fixtures/Models/IggyClientModel.cs | 4 +-
.../Iggy_SDK_Tests/E2ETests/FlushMessagesE2E.cs | 15 ++-
.../csharp/Iggy_SDK_Tests/E2ETests/OffsetE2E.cs | 14 +--
foreign/csharp/Iggy_SDK_Tests/E2ETests/PATE2E.cs | 15 ++-
.../Iggy_SDK_Tests/E2ETests/PartitionsE2E.cs | 17 ++--
.../Iggy_SDK_Tests/E2ETests/PollMessagesE2E.cs | 18 ++--
.../Iggy_SDK_Tests/E2ETests/SendMessagesE2E.cs | 16 +--
.../csharp/Iggy_SDK_Tests/E2ETests/StreamsE2E.cs | 14 ++-
.../csharp/Iggy_SDK_Tests/E2ETests/SystemE2E.cs | 10 +-
.../csharp/Iggy_SDK_Tests/E2ETests/TopicsE2E.cs | 13 ++-
foreign/csharp/Iggy_SDK_Tests/E2ETests/UsersE2E.cs | 18 ++--
.../csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj | 2 +
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 46 ++++-----
.../UtilityTests/HeaderValueTests.cs | 6 +-
.../IdentifiersByteSerializationTests.cs | 5 +-
.../UtilityTests/ToSnakeCaseMessagePolicyTests.cs | 4 +-
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 6 +-
.../Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs | 2 +-
.../Utils/DummyObj/DummyObjFactory.cs | 4 +-
.../Utils/Errors/ErrorModelFactory.cs | 4 +-
.../Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs | 5 +-
.../Utils/Messages/MessageFactory.cs | 23 +++--
.../Iggy_SDK_Tests/Utils/Offsets/OffsetFactory.cs | 7 +-
.../Utils/Partitions/PartitionFactory.cs | 5 +-
.../csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs | 2 +-
.../SpecFlowTypes/ConsumerPollStreamTopicId.cs | 14 +--
.../Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs | 6 +-
.../Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs | 4 +-
.../Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs | 14 +--
.../Utils/Users/PermissionsFactory.cs | 14 +--
.../Iggy_SDK_Tests/Utils/Users/UsersFactory.cs | 9 +-
foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs | 2 +-
.../Iggy_Sample_Consumer.csproj | 2 +
foreign/csharp/Iggy_Sample_Consumer/Program.cs | 16 +--
.../Iggy_Sample_Producer.csproj | 2 +
.../Iggy_Sample_Producer/MessageGenerator.cs | 4 +-
foreign/csharp/Iggy_Sample_Producer/Program.cs | 53 +++++-----
foreign/csharp/Shared/Envelope.cs | 4 +-
foreign/csharp/Shared/ISerializableMessage.cs | 2 +-
foreign/csharp/Shared/Orders.cs | 2 +-
foreign/csharp/Shared/Shared.csproj | 2 +
222 files changed, 885 insertions(+), 874 deletions(-)
create mode 100644 .github/workflows/ci-check-csharp-sdk.yml
copy .github/workflows/{publish_sdk.yml => publish_csharp_sdk.yml} (54%)
