This is an automated email from the ASF dual-hosted git repository.
mmodzelewski pushed a change to branch java-vsr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from fc0d5cfa7 fixes
add 7ff58de25 feat(csharp): migrate to VSR wire protocol (#3800)
new f2c2df995 Merge branch 'master' into java-vsr
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 21 +-
.github/workflows/_test_bdd.yml | 12 +-
.github/workflows/_test_examples.yml | 10 +-
.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, 8462 insertions(+), 1237 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
