This is an automated email from the ASF dual-hosted git repository.
slbotbm pushed a change to branch cpp-high-level-client-4
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 016c6beba fixes
omit 277aa1e90 fixes
omit 241767d8f fix tests
omit 7b24ee138 rebase complete
omit a5118eae8 fix ci
omit aa5793a61 fix(cpp): use shared BDD client after rebase
omit 8f7319c11 style(cpp): format rebased BDD context
omit 6f93791b4 fixes
omit 0b9ad764a fix ci
omit b4b14d929 fix ci
omit ab39e84fb fix linting
omit 51acecf3f fix lockfile
omit ed719a240 fixes for tests
omit 9c0c38ef1 fix(cpp): preserve resolved master compatibility
omit 6d6ee4a1b add contributions from #3995
omit 19f67f147 refactor(cpp): reuse the high-level consumer API
omit 6d9eafd01 test(cpp): cover the consumer offset calls
omit 26551e22e test(cpp): cover consumer isolation and group polling
omit c2b667916 feat(cpp): let poll and offset calls take a typed consumer
omit 94e86fa44 feat(cpp): add a Consumer type to the bridge
omit bdf87dc80 refactor(cpp): rename the opaque Consumer to IggyConsumer
omit 5b9195f9e remove purge apis
omit ef4078180 remove unnnecessary function in header
omit 289e76fcb doc fixes
omit 421a1cfe1 docs and test migration
omit aacdedee9 expose high level functions
add c17312606 feat(swift): add connection strings, examples and BDD suite
(#4679)
add 763c8edd9 fix(sdk): resume stopped partitions and keep readiness waits
current (#4693)
add 430d976cc feat(java): let clients close without Netty's 2 s quiet
period (#4704)
add 997f75362 expose high level functions
add ad2f1d449 docs and test migration
add 6aba8f9e7 doc fixes
add c924d65ce remove unnnecessary function in header
add 857948c09 remove purge apis
add 012db3b90 refactor(cpp): rename the opaque Consumer to IggyConsumer
add 79667695f feat(cpp): add a Consumer type to the bridge
add 0163effcd feat(cpp): let poll and offset calls take a typed consumer
add e060c206b test(cpp): cover consumer isolation and group polling
add 6df8eb7ab test(cpp): cover the consumer offset calls
add 178cb1d15 refactor(cpp): reuse the high-level consumer API
add c0ac5cbc9 add contributions from #3995
add 6dc086d40 fix(cpp): preserve resolved master compatibility
add 86ad679e6 fixes for tests
add bfa9cfa7f fix lockfile
add c0a9bbe00 fix linting
add b30c11f4a fix ci
add 21c1965fd fix ci
add 82812fd49 fixes
add dc14c0e32 style(cpp): format rebased BDD context
add c3acc8948 fix(cpp): use shared BDD client after rebase
add e2a68a6d2 fix ci
add 58ad46b2a rebase complete
add 0ba0240bc fix tests
add 129098d18 fixes
add 5687461bd fixes
add 330093b82 fixes
add a079bdcfb ci fixes
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (016c6beba)
\
N -- N -- N refs/heads/cpp-high-level-client-4 (a079bdcfb)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-runtime/SKILL.md | 2 +
.dockerignore | 2 +
.github/actions/swift/pre-merge/action.yml | 7 +-
.github/actions/utils/setup-swift/action.yml | 16 +-
.github/config/components.yml | 15 +-
.github/workflows/_test_examples.yml | 16 +
Cargo.lock | 9 +-
Cargo.toml | 5 +-
README.md | 2 +-
bdd/README.md | 14 +-
bdd/cpp/Dockerfile | 2 +-
bdd/docker-compose.yml | 27 +-
bdd/python/uv.lock | 2 +-
bdd/swift/Dockerfile | 21 +-
bdd/swift/runner/Package.resolved | 78 ----
bdd/swift/runner/Sources/Gherkin.swift | 109 -----
bdd/swift/runner/Sources/Steps.swift | 356 ----------------
bdd/swift/runner/Sources/main.swift | 92 ----
.../swift => bdd/swift/tests}/Package.resolved | 0
bdd/swift/{runner => tests}/Package.swift | 8 +-
.../Sources/iggy-bdd/DeferredPollingSteps.swift | 265 ++++++++++++
bdd/swift/tests/Sources/iggy-bdd/Gherkin.swift | 102 +++++
.../tests/Sources/iggy-bdd/MessagingSteps.swift | 216 ++++++++++
.../Sources/iggy-bdd/MetadataChangesSteps.swift | 265 ++++++++++++
.../Sources/iggy-bdd/ResourceOptionsSteps.swift | 289 +++++++++++++
bdd/swift/tests/Sources/iggy-bdd/Runner.swift | 267 ++++++++++++
bdd/swift/tests/Sources/iggy-bdd/main.swift | 80 ++++
core/common/Cargo.toml | 3 +-
core/common/src/traits/binary_transport.rs | 60 ++-
core/common/src/types/message/commit_outcome.rs | 3 +
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/src/sink.rs | 77 +++-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/producer.rs | 15 +
core/sdk/src/clients/reader.rs | 8 +-
core/sdk/src/clients/reader/cluster_tests.rs | 40 ++
core/sdk/src/clients/reader/worker.rs | 116 ++++-
core/sdk/src/consumer_ext/consumer_message_ext.rs | 3 +-
core/sdk/tests/send_future_depth.rs | 78 ++++
core/server/Cargo.toml | 2 +-
core/shard/src/lib.rs | 61 ++-
core/shard/src/poll/deferred.rs | 115 ++++-
core/shard/src/poll/deferred_tests.rs | 188 ++++++++
core/simulator/src/lib.rs | 3 +
core/simulator/src/readiness_mirror_tests.rs | 166 ++++++++
examples/node/package-lock.json | 2 +-
examples/python/uv.lock | 2 +-
examples/swift/README.md | 67 +++
.../swift/getting-started}/Package.resolved | 0
.../swift/getting-started}/Package.swift | 20 +-
.../Sources/Common/ExampleOptions.swift | 90 ++++
.../getting-started/Sources/consumer/main.swift | 50 +++
.../getting-started/Sources/producer/main.swift | 50 +++
foreign/cpp/Cargo.toml | 2 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/include/iggy.hpp | 25 ++
foreign/cpp/src/lib.rs | 4 +-
foreign/cpp/src/messages.rs | 12 -
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 20 +-
.../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 3 +
.../csharp/Iggy_SDK/Consumers/PartitionReader.cs | 26 +-
foreign/csharp/Iggy_SDK/Consumers/ReadException.cs | 14 +
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../ConsumerTests/ConsumerOnReaderTests.cs | 135 +++++-
.../Iggy_SDK_Tests/ConsumerTests/ReaderCluster.cs | 10 +
foreign/csharp/README.md | 14 +-
foreign/go/client/reader/reader.go | 20 +-
foreign/go/client/reader/reader_test.go | 81 +++-
foreign/go/contracts/version.go | 2 +-
foreign/java/README.md | 21 +
.../kotlin/iggy.java-common-conventions.gradle.kts | 3 +
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 13 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 43 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 17 +-
.../iggy/client/async/tcp/EventLoopShutdown.java | 109 +++++
.../client/blocking/tcp/IggyTcpClientBuilder.java | 24 ++
.../tcp/AsyncIggyTcpClientEventLoopGroupTest.java | 38 +-
.../tcp/AsyncIggyTcpClientFailoverSignInTest.java | 3 +-
.../tcp/AsyncIggyTcpClientLoginRoutingTest.java | 3 +-
.../tcp/AsyncIggyTcpClientSessionRulesTest.java | 3 +-
.../client/async/tcp/EventLoopShutdownTest.java | 127 ++++++
foreign/node/README.md | 12 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 2 +-
foreign/node/src/stream/iggy-consumer.ts | 8 +-
foreign/node/src/stream/partition-reader.test.ts | 83 ++++
foreign/node/src/stream/partition-reader.ts | 25 +-
foreign/php/Cargo.toml | 2 +-
foreign/php/iggy-php.stubs.php | 22 +-
foreign/php/src/consumer.rs | 14 +-
foreign/php/src/error.rs | 9 +
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 13 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 37 ++
foreign/python/src/consumer.rs | 7 +-
foreign/python/uv.lock | 2 +-
foreign/swift/README.md | 69 ++-
.../Sources/Iggy/Client/ConnectionString.swift | 471 +++++++++++++++++++++
foreign/swift/Sources/Iggy/Client/IggyClient.swift | 7 +
.../swift/Sources/Iggy/Consumer/IggyConsumer.swift | 24 +-
.../Sources/Iggy/Consumer/PartitionReader.swift | 22 +-
foreign/swift/Sources/Iggy/Iggy.swift | 2 +-
.../swift/Tests/IggyE2ETests/ClientE2ETests.swift | 20 +
.../Tests/IggyTests/ConnectionStringTests.swift | 238 +++++++++++
foreign/swift/Tests/IggyTests/ConsumerTests.swift | 35 ++
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 8 +-
scripts/run-bdd-tests.sh | 5 -
scripts/run-examples-from-readme.sh | 27 +-
109 files changed, 4565 insertions(+), 875 deletions(-)
delete mode 100644 bdd/swift/runner/Package.resolved
delete mode 100644 bdd/swift/runner/Sources/Gherkin.swift
delete mode 100644 bdd/swift/runner/Sources/Steps.swift
delete mode 100644 bdd/swift/runner/Sources/main.swift
copy {foreign/swift => bdd/swift/tests}/Package.resolved (100%)
copy bdd/swift/{runner => tests}/Package.swift (75%)
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/DeferredPollingSteps.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/Gherkin.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/MessagingSteps.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/MetadataChangesSteps.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/ResourceOptionsSteps.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/Runner.swift
create mode 100644 bdd/swift/tests/Sources/iggy-bdd/main.swift
create mode 100644 core/sdk/tests/send_future_depth.rs
create mode 100644 core/simulator/src/readiness_mirror_tests.rs
create mode 100644 examples/swift/README.md
copy {foreign/swift => examples/swift/getting-started}/Package.resolved (100%)
rename {bdd/swift/runner => examples/swift/getting-started}/Package.swift (63%)
create mode 100644
examples/swift/getting-started/Sources/Common/ExampleOptions.swift
create mode 100644 examples/swift/getting-started/Sources/consumer/main.swift
create mode 100644 examples/swift/getting-started/Sources/producer/main.swift
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/EventLoopShutdown.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/EventLoopShutdownTest.java
create mode 100644 foreign/swift/Sources/Iggy/Client/ConnectionString.swift
create mode 100644 foreign/swift/Tests/IggyTests/ConnectionStringTests.swift
