This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch integration_tests_basics
in repository https://gitbox.apache.org/repos/asf/iggy.git
from bb58cc20c get_me fix
add b29bcd5f9 feat(php): implement initial version of PHP SDK (#3235)
add 6b9eda354 chore(deps): bump workspace; migrate sqlx 0.9 + keyring 4
(#3324)
add dab617880 ci: share runner disk cleanup across PHP, Rust, BDD,
coverage (#3330)
add 0fff3cfb3 ci: fold free-disk-space into setup-rust-with-cache (#3332)
add 6db91326a ci: run PR Title workflow on ubuntu-24.04-arm (#3329)
add d66287a83 fix(cli): swap libdbus-backed keyring for pure-Rust zbus
(#3326)
add 0df7d3808 ci: broaden dependabot coverage, add cooldown and PR caps
(#3322)
add a2316a070 feat(python): add package cooldown and pyrefly (#3323)
add bcb220166 chore(deps): Bump System.IO.Hashing from 8.0.0 to 10.0.8
(#3360)
add 8937da418 chore(deps): Bump the minor-and-patch group with 16 updates
(#3358)
add 420047743 chore(server-ng): extract compio executor and io_uring
diagnostics into shared crate (#3331)
add 3bfc41809 feat(connectors): add Apache Doris sink connector (#3215)
add aa8b71917 ci(connectors): raise vm.max_map_count for Doris in coverage
job (#3365)
add 397533f4b ci(php): pin supported PHP version (#3333)
add c5579df62 docs: clarify compression placeholders (#3366)
add 971067a68 chore(deps): bump googletest from 1.17.0 to 1.17.0.bcr.2 in
/foreign/cpp (#3336)
add 7316b09a5 fix(js): publish npm prereleases under a channel tag, not
latest (#3370)
add 3c4808944 chore(repo): improve issue/PR templates and trim triage docs
(#3372)
add f139f0e5b ci: gate Docker :edge refresh by cargo-rail DAG (#3369)
add 2c286679a feat(php): add SDK examples component (#3368)
add 9bfe6753a chore(deps): bump go, docker, bazel and github-actions deps
(#3363)
add 438b48ad5 feat(cpp): Create fixture for clean up and add purge_*
functions (#3320)
add df31f680d chore(deps): bump npm packages and node docker image (#3361)
add e7b2d7e65 feat(sdk): support sending raw requests for custom commands
(#3373)
add 216139b49 chore(deps): bump github.com/onsi/gomega from 1.40.0 to
1.41.0 in /bdd/go in the minor-and-patch group across 1 directory (#3378)
add 65020fce7 chore(deps): update and pin .net nuget versions (#3375)
add 719fe7baa Merge branch 'master' into integration_tests_basics
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 16 +
.github/ISSUE_TEMPLATE/bug_report.yml | 47 +
.github/ISSUE_TEMPLATE/feature_request.yml | 34 +-
.github/actions/node-npm/post-merge/action.yml | 21 +-
.github/actions/php/pre-merge/action.yml | 160 ++
.../actions/python-maturin/pre-merge/action.yml | 7 +-
.github/actions/rust/pre-merge/action.yml | 25 +-
.github/actions/utils/docker-buildx/action.yml | 2 +-
.github/actions/utils/docker-login/action.yml | 113 ++
.github/actions/utils/free-disk-space/action.yml | 53 +
.../actions/utils/setup-rust-with-cache/action.yml | 3 +
.github/config/components.yml | 21 +
.github/config/publish.yml | 24 +
.github/dependabot.yml | 226 ++-
.github/workflows/_build_rust_artifacts.yml | 6 -
.github/workflows/_detect.yml | 11 +-
.github/workflows/_test.yml | 7 +
.github/workflows/_test_bdd.yml | 8 -
.github/workflows/_test_examples.yml | 41 +
.github/workflows/coverage-baseline.yml | 17 +-
.github/workflows/issue-labeler.yml | 105 ++
.github/workflows/post-merge.yml | 20 +-
.github/workflows/pr-title.yml | 3 +-
.github/workflows/pr-triage-apply.yml | 11 +-
.github/workflows/pre-merge.yml | 21 +-
.github/workflows/publish.yml | 2 +-
.pre-commit-config.yaml | 24 +
CONTRIBUTING.md | 145 +-
Cargo.lock | 1088 ++++++++------
Cargo.toml | 39 +-
PULL_REQUEST_TEMPLATE.md | 7 +-
README.md | 5 +-
bdd/Dockerfile | 2 +-
bdd/README.md | 3 +-
bdd/csharp/Dockerfile | 2 +-
bdd/go/Dockerfile | 2 +-
bdd/go/go.mod | 20 +-
bdd/go/go.sum | 71 +-
bdd/java/Dockerfile | 2 +-
bdd/node/Dockerfile | 2 +-
bdd/python/pylock.toml | 42 +
bdd/python/pyproject.toml | 10 +
bdd/python/requirements.txt | 4 -
bdd/python/tests/conftest.py | 11 +-
bdd/python/uv.lock | 54 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 26 +-
.../src/plotting/text/title.rs => cli/build.rs} | 34 +-
.../create_personal_access_token.rs | 2 +-
.../delete_personal_access_tokens.rs | 2 +-
core/cli/src/commands/binary_system/session.rs | 48 +-
core/cli/src/credentials.rs | 5 +-
core/cli/src/main.rs | 9 +
core/common/Cargo.toml | 2 +-
core/common/src/lib.rs | 1 +
.../transport.rs => common/src/types/http.rs} | 35 +-
core/common/src/types/mod.rs | 1 +
.../configs/src/configs_impl/typed_env_provider.rs | 2 +-
core/connectors/README.md | 1 +
.../example_config/connectors/doris_sink.toml | 54 +
core/connectors/sinks/README.md | 1 +
.../random_source => sinks/doris_sink}/Cargo.toml | 21 +-
core/connectors/sinks/doris_sink/README.md | 99 ++
core/connectors/sinks/doris_sink/config.toml | 54 +
core/connectors/sinks/doris_sink/src/lib.rs | 1545 ++++++++++++++++++++
core/connectors/sinks/postgres_sink/src/lib.rs | 4 +-
core/connectors/sources/postgres_source/src/lib.rs | 83 +-
core/integration/Cargo.toml | 19 +-
.../poll_metadata.rs => integration/build.rs} | 21 +-
core/integration/tests/cli/common/keyring.rs | 52 +
core/integration/tests/cli/common/mod.rs | 2 +
.../test_pat_login_options.rs | 5 +-
.../integration/tests/cli/system/test_login_cmd.rs | 3 +-
.../tests/cli/system/test_logout_cmd.rs | 3 +-
.../tests/connectors/doris/doris_sink.rs | 492 +++++++
.../tests/connectors/{delta => doris}/mod.rs | 2 +-
.../tests/connectors/{delta => doris}/sink.toml | 2 +-
.../tests/connectors/fixtures/doris/container.rs | 717 +++++++++
.../connectors/fixtures/{iceberg => doris}/mod.rs | 3 +-
core/integration/tests/connectors/fixtures/mod.rs | 5 +
.../connectors/fixtures/postgres/container.rs | 2 +-
.../tests/connectors/fixtures/postgres/sink.rs | 11 +-
.../tests/connectors/fixtures/postgres/source.rs | 24 +-
core/integration/tests/connectors/mod.rs | 1 +
core/integration/tests/sdk/mod.rs | 1 +
core/integration/tests/sdk/raw.rs | 108 ++
core/sdk/Cargo.toml | 2 +-
core/sdk/README.md | 2 +-
core/sdk/src/clients/client.rs | 85 +-
core/sdk/src/http/http_client.rs | 30 +-
core/sdk/src/http/http_transport.rs | 12 +-
core/sdk/src/http/mod.rs | 2 +-
core/sdk/src/prelude.rs | 10 +-
core/server-ng/src/main.rs | 11 +-
core/server/config.toml | 8 +-
core/server/src/bootstrap.rs | 40 +-
core/server/src/diagnostics.rs | 321 +---
core/{server => server_common}/src/diagnostics.rs | 85 +-
core/server_common/src/executor.rs | 132 ++
core/server_common/src/lib.rs | 3 +
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 8 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 10 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 4 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.Shared.csproj | 1 +
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 10 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 10 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 4 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 10 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 10 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 4 +-
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 4 +-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/package-lock.json | 694 +++------
examples/node/package.json | 6 +-
examples/php/README.md | 39 +
.../php/basic/consumer.php | 13 +-
.../php/basic/producer.php | 20 +-
.../php/getting-started/consumer.php | 25 +-
.../php/getting-started/producer.php | 20 +-
examples/php/src/common.php | 91 ++
examples/python/basic/consumer.py | 10 +-
examples/python/basic/producer.py | 14 +-
examples/python/getting-started/consumer.py | 16 +-
examples/python/getting-started/producer.py | 20 +-
examples/python/pylock.toml | 42 +
examples/python/pyproject.toml | 10 +
examples/python/uv.lock | 54 +-
examples/rust/README.md | 2 +-
foreign/cpp/MODULE.bazel | 6 +-
foreign/cpp/MODULE.bazel.lock | 198 ++-
foreign/cpp/src/client.rs | 71 +-
foreign/cpp/src/lib.rs | 4 +-
foreign/cpp/tests/client/low_level_e2e.cpp | 459 +++---
foreign/cpp/tests/common/test_helpers.hpp | 184 ++-
foreign/cpp/tests/consumer_group/low_level_e2e.cpp | 332 ++---
foreign/cpp/tests/message/low_level_e2e.cpp | 511 +++----
foreign/cpp/tests/partition/low_level_e2e.cpp | 236 ++-
foreign/cpp/tests/stream/low_level_e2e.cpp | 620 ++++++--
foreign/cpp/tests/topic/low_level_e2e.cpp | 628 ++++++--
foreign/csharp/Directory.Packages.props | 22 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/node/package-lock.json | 503 +++++--
foreign/node/package.json | 8 +-
foreign/node/tsconfig.json | 4 +-
.../php/.cargo/config.toml | 9 +-
foreign/php/.gitignore | 4 +
{core/harness_derive => foreign/php}/Cargo.toml | 21 +-
foreign/php/Dockerfile.test | 62 +
foreign/{csharp => php}/LICENSE | 2 +-
NOTICE => foreign/php/NOTICE | 0
foreign/php/README.md | 210 +++
foreign/php/composer.json | 15 +
foreign/{python => php}/docker-compose.test.yml | 40 +-
foreign/php/iggy-php.stubs.php | 477 ++++++
foreign/php/phpunit.xml.dist | 11 +
.../php/scripts/test.sh | 29 +-
foreign/php/src/client.rs | 388 +++++
foreign/php/src/consumer.rs | 261 ++++
.../php/src/error.rs | 8 +-
foreign/php/src/identifier.rs | 91 ++
.../src/clients/mod.rs => foreign/php/src/lib.rs | 51 +-
foreign/php/src/receive_message.rs | 167 +++
.../src/http/mod.rs => foreign/php/src/runtime.rs | 33 +-
foreign/{python => php}/src/send_message.rs | 65 +-
foreign/{python => php}/src/stream.rs | 18 +-
foreign/{python => php}/src/topic.rs | 24 +-
foreign/php/tests/IggySdkTest.php | 579 ++++++++
foreign/php/tests/TlsTest.php | 86 ++
foreign/php/tests/bootstrap.php | 187 +++
foreign/python/Cargo.toml | 4 +-
foreign/python/pylock.toml | 172 +--
foreign/python/pyproject.toml | 25 +-
foreign/python/uv.lock | 190 +--
scripts/ci/edge-affected-images.sh | 135 ++
scripts/run-examples-from-readme.sh | 48 +-
web/package-lock.json | 424 +++---
web/package.json | 24 +-
182 files changed, 11683 insertions(+), 3920 deletions(-)
create mode 100644 .github/actions/php/pre-merge/action.yml
create mode 100644 .github/actions/utils/docker-login/action.yml
create mode 100644 .github/actions/utils/free-disk-space/action.yml
create mode 100644 .github/workflows/issue-labeler.yml
delete mode 100644 bdd/python/requirements.txt
copy core/{bench/report/src/plotting/text/title.rs => cli/build.rs} (51%)
copy core/{bench/report/src/types/transport.rs => common/src/types/http.rs}
(58%)
create mode 100644
core/connectors/runtime/example_config/connectors/doris_sink.toml
copy core/connectors/{sources/random_source => sinks/doris_sink}/Cargo.toml
(84%)
create mode 100644 core/connectors/sinks/doris_sink/README.md
create mode 100644 core/connectors/sinks/doris_sink/config.toml
create mode 100644 core/connectors/sinks/doris_sink/src/lib.rs
copy core/{common/src/types/message/poll_metadata.rs => integration/build.rs}
(73%)
create mode 100644 core/integration/tests/cli/common/keyring.rs
create mode 100644 core/integration/tests/connectors/doris/doris_sink.rs
copy core/integration/tests/connectors/{delta => doris}/mod.rs (98%)
copy core/integration/tests/connectors/{delta => doris}/sink.toml (94%)
create mode 100644
core/integration/tests/connectors/fixtures/doris/container.rs
copy core/integration/tests/connectors/fixtures/{iceberg => doris}/mod.rs (86%)
create mode 100644 core/integration/tests/sdk/raw.rs
copy core/{server => server_common}/src/diagnostics.rs (86%)
create mode 100644 core/server_common/src/executor.rs
create mode 100644 examples/php/README.md
copy
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/common/generator/DataBatch.java
=> examples/php/basic/consumer.php (75%)
copy
foreign/java/bench/src/main/java/org/apache/iggy/bench/common/exception/BenchmarkException.java
=> examples/php/basic/producer.php (71%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/message/PollingKind.java =>
examples/php/getting-started/consumer.php (74%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/tcp/PartitionsTcpClientTest.java
=> examples/php/getting-started/producer.php (69%)
create mode 100644 examples/php/src/common.php
copy core/integration/tests/connectors/runtime/benchmark.toml =>
foreign/php/.cargo/config.toml (81%)
create mode 100644 foreign/php/.gitignore
copy {core/harness_derive => foreign/php}/Cargo.toml (68%)
create mode 100644 foreign/php/Dockerfile.test
copy foreign/{csharp => php}/LICENSE (99%)
copy NOTICE => foreign/php/NOTICE (100%)
create mode 100644 foreign/php/README.md
create mode 100644 foreign/php/composer.json
copy foreign/{python => php}/docker-compose.test.yml (63%)
create mode 100644 foreign/php/iggy-php.stubs.php
create mode 100644 foreign/php/phpunit.xml.dist
copy scripts/dashboard/build_release.sh => foreign/php/scripts/test.sh (58%)
create mode 100644 foreign/php/src/client.rs
create mode 100644 foreign/php/src/consumer.rs
copy core/common/src/http/messages/flush_unsaved_buffer.rs =>
foreign/php/src/error.rs (82%)
create mode 100644 foreign/php/src/identifier.rs
copy core/sdk/src/clients/mod.rs => foreign/php/src/lib.rs (50%)
create mode 100644 foreign/php/src/receive_message.rs
copy core/server/src/http/mod.rs => foreign/php/src/runtime.rs (61%)
copy foreign/{python => php}/src/send_message.rs (56%)
copy foreign/{python => php}/src/stream.rs (87%)
copy foreign/{python => php}/src/topic.rs (80%)
create mode 100644 foreign/php/tests/IggySdkTest.php
create mode 100644 foreign/php/tests/TlsTest.php
create mode 100644 foreign/php/tests/bootstrap.php
create mode 100755 scripts/ci/edge-affected-images.sh
