This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch integration_tests
in repository https://gitbox.apache.org/repos/asf/iggy.git
from fb8b3a54f fix sort and format
add cecffeb0a ci: prepend ~/.cargo/bin to PATH after rustup show (#3251)
add b6d162d39 chore(repo,ci): fix macOS pre-merge, bump versions (#3248)
add d158089aa feat(ci): label PR review state via slash commands and
lifecycle (#3231)
add a5f85ea47 ci: declare explicit read-only permissions on reusable
workflows (#3243)
add d2e26067e ci: allow org members to drive PR triage commands (#3255)
add 62fb33add test(sdk): validate handle_response status and length edge
cases (#3202)
add 50724fd18 fix(ci): stop publish failing on existing immutable edge
tags (#3259)
add 5e98ec900 ci: make PR triage react to reviews and survive transient
errors (#3260)
add 56112a2a5 ci: add PR welcome comment, widen changes-requested gate
(#3261)
add 607767e71 chore(deps-dev): bump svelte from 5.55.5 to 5.55.7 in /web
(#3263)
add fd4dbf6f1 chore(deps): bump devalue from 5.6.4 to 5.8.1 in /web (#3262)
add 6a71d204a fix(ci): handle fork-PR triage commands via workflow_run
handoff (#3268)
add 1ae123f43 feat(java): add actor and data batch generator for java
bench (#3218)
add 059dfcd42 Merge branch 'master' into integration_tests
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 2 +-
.../actions/utils/setup-rust-with-cache/action.yml | 11 +-
.github/workflows/_build_python_wheels.yml | 3 +
.github/workflows/_build_rust_artifacts.yml | 3 +
.github/workflows/_detect.yml | 5 +-
.github/workflows/pr-triage-apply.yml | 716 +++++++++++++++++++++
.github/workflows/pr-triage-collect.yml | 59 ++
.github/workflows/pre-merge.yml | 2 +-
.github/workflows/publish.yml | 81 ++-
CONTRIBUTING.md | 134 ++++
Cargo.lock | 50 +-
Cargo.toml | 10 +-
bdd/python/uv.lock | 2 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 4 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/tcp/tcp_client.rs | 52 ++
core/server/Cargo.toml | 2 +-
examples/python/uv.lock | 2 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/go/contracts/version.go | 2 +-
.../tcp/async/TcpAsyncPinnedProducerActor.java | 121 ++++
.../runners/tcp/async/TcpAsyncPinnedProducer.java | 94 +++
.../tcp/async/TcpAsyncPinnedProducer.java | 51 --
.../iggy/bench/cli/PinnedProducerCommand.java | 2 +-
.../apache/iggy/bench/common/enums/ActorKind.java} | 22 +-
.../iggy/bench/common/enums/BenchmarkKind.java} | 35 +-
.../apache/iggy/bench/common/enums/GroupKind.java} | 23 +-
.../iggy/bench/common/enums/TransportKind.java} | 21 +-
.../{ => common}/exception/BenchmarkException.java | 2 +-
.../common/generator/BenchmarkBatchGenerator.java | 75 +++
.../provision/ResourceProvisioner.java | 6 +-
.../iggy/bench/models/cli/GlobalCliArgs.java | 2 +-
.../bench/models/cli/PinnedProducerCliArgs.java | 2 +-
.../generator/DataBatch.java} | 6 +-
.../provision/ProvisionedResources.java | 2 +-
foreign/java/gradle.properties | 2 +-
foreign/node/package.json | 2 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/uv.lock | 2 +-
scripts/bump-version.sh | 76 ++-
web/package-lock.json | 92 ++-
web/package.json | 6 +-
65 files changed, 1603 insertions(+), 235 deletions(-)
create mode 100644 .github/workflows/pr-triage-apply.yml
create mode 100644 .github/workflows/pr-triage-collect.yml
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/benchmarks/actors/tcp/async/TcpAsyncPinnedProducerActor.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/benchmarks/runners/tcp/async/TcpAsyncPinnedProducer.java
delete mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/benchmarks/tcp/async/TcpAsyncPinnedProducer.java
copy
foreign/java/{java-sdk/src/test/java/org/apache/iggy/identifier/StreamIdTest.java
=> bench/src/main/java/org/apache/iggy/bench/common/enums/ActorKind.java} (69%)
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/message/BigIntegerMessageId.java
=> bench/src/main/java/org/apache/iggy/bench/common/enums/BenchmarkKind.java}
(58%)
copy
foreign/java/{java-sdk/src/test/java/org/apache/iggy/identifier/StreamIdTest.java
=> bench/src/main/java/org/apache/iggy/bench/common/enums/GroupKind.java} (66%)
copy
foreign/java/{java-sdk/src/test/java/org/apache/iggy/identifier/StreamIdTest.java
=> bench/src/main/java/org/apache/iggy/bench/common/enums/TransportKind.java}
(73%)
rename foreign/java/bench/src/main/java/org/apache/iggy/bench/{ =>
common}/exception/BenchmarkException.java (95%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/common/generator/BenchmarkBatchGenerator.java
rename foreign/java/bench/src/main/java/org/apache/iggy/bench/{ =>
common}/provision/ResourceProvisioner.java (95%)
copy
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/{provision/ProvisionedResources.java
=> common/generator/DataBatch.java} (81%)
rename foreign/java/bench/src/main/java/org/apache/iggy/bench/models/{ =>
common}/provision/ProvisionedResources.java (94%)
