This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch fix_reconciler_rebuild
in repository https://gitbox.apache.org/repos/asf/iggy.git
from daa32883c address review changes
add 7ff58de25 feat(csharp): migrate to VSR wire protocol (#3800)
add f3d6ab744 Merge branch 'master' into fix_reconciler_rebuild
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 21 +-
.github/workflows/_test_bdd.yml | 12 +-
.github/workflows/_test_examples.yml | 8 +-
.github/workflows/coverage-baseline.yml | 17 +-
bdd/README.md | 8 +-
foreign/csharp/Directory.Packages.props | 1 +
.../ClusterRedirectionTests.cs | 27 +-
.../ConsumerGroupTests.cs | 11 +-
.../FetchMessagesTests.cs | 34 +-
.../Fixtures/IggyClusterFixture.cs | 250 ------
.../Fixtures/IggyServerFixture.cs | 256 +++---
.../Fixtures/IggyTlsServerFixture.cs | 7 +-
.../Fixtures/RedirectionClusterFixture.cs} | 17 +-
.../Fixtures/VsrCluster.cs | 438 +++++++++
.../FlushMessagesTests.cs | 61 +-
.../HeaderEncryptionIntegrationTests.cs | 74 +-
.../SkipHttpAttribute.cs => Helpers/Eventually.cs} | 33 +-
.../IggyConsumerTests.cs | 94 +-
.../IggyPublisherTests.cs | 93 +-
.../IggyTlsConnectionTests.cs | 10 +-
.../IggyTypedConsumerTests.cs | 20 +-
.../IggyTypedPublisherTests.cs | 8 +-
.../MessageEncryptionIntegrationTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/OffsetTests.cs | 27 +-
.../Iggy_SDK.Tests.Integration/PartitionsTests.cs | 6 +-
.../PersonalAccessTokenTests.cs | 2 +-
.../Iggy_SDK.Tests.Integration/RawCommandTests.cs | 12 +-
.../Iggy_SDK.Tests.Integration/SegmentsTests.cs | 12 +-
.../SendMessagesTests.cs | 143 ++-
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 5 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 12 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 37 +-
.../Iggy_SDK.Tests.Integration/UsersTests.cs | 16 +-
.../Vsr/VsrConsumerGroupTests.cs | 228 +++++
.../Vsr/VsrHandshakeTests.cs | 165 ++++
.../Vsr/VsrMessagingTests.cs | 165 ++++
.../Vsr/VsrMetadataTests.cs | 132 +++
.../Iggy_SDK/Configuration/AutoLoginSettings.cs | 15 +
.../Configuration/IggyClientConfigurator.cs | 6 +
.../Iggy_SDK/Consumers/IggyConsumer.Rented.cs | 8 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 10 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilder.cs | 5 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs | 10 +-
.../Iggy_SDK/Contracts/SendMessagesResponse.cs | 77 ++
.../Exceptions/IggyInvalidStatusCodeException.cs | 12 +-
.../VsrRequestOutcomeUnknownException.cs | 33 +
...dException.cs => VsrSessionEvictedException.cs} | 26 +-
.../csharp/Iggy_SDK/Factory/IggyClientFactory.cs | 17 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 25 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs | 5 +-
.../Implementations/HttpMessageStream.cs | 100 ++-
.../Implementations/TcpMessageStream.Vsr.cs | 978 +++++++++++++++++++++
.../IggyClient/Implementations/TcpMessageStream.cs | 499 +++++------
.../Implementations/TransientHttpRetryHandler.cs | 109 +++
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 3 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 65 +-
.../Publishers/BackgroundMessageProcessor.cs | 43 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 51 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 3 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilderOfT.cs | 9 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs | 35 +-
foreign/csharp/Iggy_SDK/Utils/BufferSizes.cs | 1 -
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 3 +
foreign/csharp/Iggy_SDK/Utils/ServerAddress.cs | 139 +++
.../{Enums/ConsumerType.cs => Vsr/Command2.cs} | 20 +-
foreign/csharp/Iggy_SDK/Vsr/ConsensusSession.cs | 223 +++++
.../Iggy_SDK/Vsr/ConsumerGroupClientState.cs | 301 +++++++
foreign/csharp/Iggy_SDK/Vsr/CredentialBounds.cs | 66 ++
.../AutoLoginSettings.cs => Vsr/EvictionReason.cs} | 37 +-
foreign/csharp/Iggy_SDK/Vsr/LoginRegister.cs | 168 ++++
foreign/csharp/Iggy_SDK/Vsr/SyncConsumerGroup.cs | 61 ++
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 61 ++
foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs | 156 ++++
foreign/csharp/Iggy_SDK/Vsr/VsrNamespace.cs | 251 ++++++
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 275 ++++++
foreign/csharp/Iggy_SDK/Vsr/VsrReplyDecoder.cs | 206 +++++
.../ClientTests/IggyClientFactoryTests.cs | 67 ++
.../ConsumerTests/IggyConsumerBuilderTests.cs | 19 +
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 76 ++
.../PublisherTests/IggyPublisherBuilderTests.cs} | 33 +-
.../PublisherTests/IggyTypedPublisherTests.cs | 4 +-
.../Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs | 7 +-
.../VsrTests/ConsensusSessionTests.cs | 218 +++++
.../VsrTests/ConsumerGroupClientStateTests.cs | 176 ++++
.../VsrTests/CredentialBoundsTests.cs | 72 ++
.../Iggy_SDK_Tests/VsrTests/LoginRegisterTests.cs | 165 ++++
.../Iggy_SDK_Tests/VsrTests/ServerAddressTests.cs | 85 ++
.../VsrTests/SyncConsumerGroupTests.cs | 93 ++
.../Iggy_SDK_Tests/VsrTests/VsrHeaderTests.cs | 292 ++++++
.../Iggy_SDK_Tests/VsrTests/VsrNamespaceTests.cs | 282 ++++++
.../Iggy_SDK_Tests/VsrTests/VsrOperationTests.cs | 167 ++++
.../VsrTests/VsrProtocolDriftTests.cs | 849 ++++++++++++++++++
.../VsrTests/VsrReplyDecoderTests.cs | 293 ++++++
.../Iggy_SDK_Tests/VsrTests/VsrTestPayloads.cs | 102 +++
foreign/csharp/README.md | 106 ++-
scripts/run-bdd-tests.sh | 6 +-
scripts/run-examples-from-readme.sh | 7 +-
97 files changed, 8461 insertions(+), 1236 deletions(-)
delete mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Fixtures/IggyClusterFixture.cs
copy foreign/csharp/{Iggy_SDK/Contracts/ClusterNodeRole.cs =>
Iggy_SDK.Tests.Integration/Fixtures/RedirectionClusterFixture.cs} (67%)
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Fixtures/VsrCluster.cs
copy
foreign/csharp/Iggy_SDK.Tests.Integration/{Attributes/SkipHttpAttribute.cs =>
Helpers/Eventually.cs} (50%)
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Vsr/VsrConsumerGroupTests.cs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Vsr/VsrHandshakeTests.cs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Vsr/VsrMessagingTests.cs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Vsr/VsrMetadataTests.cs
create mode 100644 foreign/csharp/Iggy_SDK/Contracts/SendMessagesResponse.cs
create mode 100644
foreign/csharp/Iggy_SDK/Exceptions/VsrRequestOutcomeUnknownException.cs
copy foreign/csharp/Iggy_SDK/Exceptions/{ConsumerGroupNotFoundException.cs =>
VsrSessionEvictedException.cs} (52%)
create mode 100644
foreign/csharp/Iggy_SDK/IggyClient/Implementations/TcpMessageStream.Vsr.cs
create mode 100644
foreign/csharp/Iggy_SDK/IggyClient/Implementations/TransientHttpRetryHandler.cs
create mode 100644 foreign/csharp/Iggy_SDK/Utils/ServerAddress.cs
copy foreign/csharp/Iggy_SDK/{Enums/ConsumerType.cs => Vsr/Command2.cs} (72%)
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/ConsensusSession.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/ConsumerGroupClientState.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/CredentialBounds.cs
copy foreign/csharp/Iggy_SDK/{Configuration/AutoLoginSettings.cs =>
Vsr/EvictionReason.cs} (55%)
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/LoginRegister.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/SyncConsumerGroup.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/VsrError.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/VsrNamespace.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs
create mode 100644 foreign/csharp/Iggy_SDK/Vsr/VsrReplyDecoder.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ClientTests/IggyClientFactoryTests.cs
copy foreign/csharp/{Iggy_SDK/JsonConverters/ConsumerConverter.cs =>
Iggy_SDK_Tests/PublisherTests/IggyPublisherBuilderTests.cs} (51%)
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/ConsensusSessionTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/ConsumerGroupClientStateTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/CredentialBoundsTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/LoginRegisterTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/ServerAddressTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/SyncConsumerGroupTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrHeaderTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrNamespaceTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrOperationTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrProtocolDriftTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrReplyDecoderTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/VsrTests/VsrTestPayloads.cs
