This is an automated email from the ASF dual-hosted git repository.
lukaszzborek pushed a change to branch dotnet-vsr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 31fd870b3 Merge branch 'master' into dotnet-vsr
add aa26d54f4 refactor(csharp): remove unused wire protocol configurations
and clean up related tests
add 32e463972 Merge branch 'master' into dotnet-vsr
add 6f2e854b0 feat(csharp): update SendMessagesAsync to return
SendMessagesResponse
add 37885f3b7 Merge remote-tracking branch 'origin/dotnet-vsr' into
dotnet-vsr
add b2ee81d4c feat(tests): introduce RedirectionClusterFixture and update
test configurations
add 039a91ca9 refactor(python): readme improvements (#3825)
add 360ee7ed6 fix(server-ng): close server-ng SDK-visible behavior gaps
(#3828)
add 02c24b399 feat(python): run Python SDK tests only against the VSR
server (#3838)
add 550e9f9fa Merge branch 'refs/heads/master' into dotnet-vsr
add e79cf5323 fix(tests): update default NodeCount in IggyServerFixture to
1
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 47 +-
.../actions/python-maturin/pre-merge/action.yml | 42 +-
.github/config/components.yml | 2 +-
.github/workflows/_test.yml | 2 +-
.github/workflows/_test_bdd.yml | 35 +-
.github/workflows/_test_examples.yml | 27 +-
.github/workflows/coverage-baseline.yml | 50 +-
core/integration/tests/server/mod.rs | 11 +
.../integration/tests/server/poll_semantics_vsr.rs | 246 ++++++
core/integration/tests/server/purge_vsr.rs | 51 ++
.../server/scenarios/purge_delete_scenario.rs | 153 +++-
.../tests/server/scenarios/system_scenario.rs | 21 +-
.../tests/server/topic_admission_vsr.rs | 272 +++++++
core/metadata/src/impls/metadata.rs | 67 +-
core/metadata/src/stm/stream.rs | 83 +-
core/partitions/src/iggy_partition.rs | 832 ++++++++++++++++++++-
core/partitions/src/journal.rs | 160 +++-
core/partitions/src/offset_storage.rs | 196 +++++
core/partitions/src/state_transfer.rs | 51 +-
core/server-ng/src/bootstrap.rs | 42 +-
core/server-ng/src/dispatch.rs | 313 ++++++--
core/server-ng/src/http/handlers.rs | 21 +-
core/server-ng/src/partition_helpers.rs | 10 +
core/server-ng/src/partition_reconciler.rs | 92 ++-
core/server-ng/src/responses.rs | 208 +++---
core/server-ng/src/segment_cleaner.rs | 98 ++-
core/shard/src/lib.rs | 92 ++-
core/shard/src/metrics.rs | 19 +
core/shard/src/router.rs | 28 +
.../Attributes/ServerAttributes.cs | 50 --
.../ClusterRedirectionTests.cs | 29 +-
.../FetchMessagesTests.cs | 35 +-
.../Fixtures/IggyClusterFixture.cs | 250 -------
.../Fixtures/IggyServerFixture.cs | 236 ++----
.../Fixtures/IggyTlsServerFixture.cs | 4 +
.../Fixtures/RedirectionClusterFixture.cs} | 17 +-
.../Fixtures/VsrCluster.cs | 425 +++++++----
.../FlushMessagesTests.cs | 61 +-
.../IggyConsumerTests.cs | 1 -
.../IggyPublisherTests.cs | 1 -
.../IggyTlsConnectionTests.cs | 6 +-
.../SendMessagesTests.cs | 143 +++-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 7 +-
.../Vsr/VsrConsumerGroupTests.cs | 2 -
.../Vsr/VsrHandshakeTests.cs | 2 -
.../Vsr/VsrMessagingTests.cs | 2 -
.../Vsr/VsrMetadataTests.cs | 2 -
.../Configuration/IggyClientConfigurator.cs | 8 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilder.cs | 13 -
.../Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs | 1 -
.../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 7 -
.../Iggy_SDK/Contracts/SendMessagesResponse.cs | 77 ++
foreign/csharp/Iggy_SDK/Enums/WireProtocol.cs | 35 -
.../csharp/Iggy_SDK/Factory/IggyClientFactory.cs | 20 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 25 +-
.../Implementations/HttpMessageStream.cs | 100 ++-
.../Implementations/TcpMessageStream.Vsr.cs | 57 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 299 ++------
.../Implementations/TransientHttpRetryHandler.cs | 109 +++
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 87 ++-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 49 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 13 -
.../Iggy_SDK/Publishers/IggyPublisherBuilderOfT.cs | 1 -
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 7 -
.../csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs | 35 +-
foreign/csharp/Iggy_SDK/Utils/BufferSizes.cs | 1 -
foreign/csharp/Iggy_SDK/Vsr/LoginRegister.cs | 4 +-
.../ClientTests/IggyClientFactoryTests.cs | 49 +-
.../ConsumerTests/IggyConsumerBuilderTests.cs | 39 +-
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 76 ++
.../PublisherTests/IggyPublisherBuilderTests.cs | 32 +-
.../PublisherTests/IggyTypedPublisherTests.cs | 4 +-
.../Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs | 7 +-
.../Iggy_SDK_Tests/VsrTests/LoginRegisterTests.cs | 6 -
foreign/csharp/README.md | 26 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/README.md | 119 ++-
foreign/python/tests/test_message_operations.py | 17 +-
foreign/python/tests/test_tls.py | 11 +-
foreign/python/tests/test_topic.py | 18 +-
foreign/python/tests/utils.py | 33 +-
scripts/run-bdd-tests.sh | 8 +-
scripts/run-examples-from-readme.sh | 11 +-
scripts/utils.sh | 21 +-
84 files changed, 4199 insertions(+), 1774 deletions(-)
create mode 100644 core/integration/tests/server/poll_semantics_vsr.rs
create mode 100644 core/integration/tests/server/purge_vsr.rs
create mode 100644 core/integration/tests/server/topic_admission_vsr.rs
delete mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Attributes/ServerAttributes.cs
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/Contracts/SendMessagesResponse.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Enums/WireProtocol.cs
create mode 100644
foreign/csharp/Iggy_SDK/IggyClient/Implementations/TransientHttpRetryHandler.cs
