This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch store_consumer_offset
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b2d1189ef Merge branch 'master' into store_consumer_offset
add 27f0f11c6 feat(consensus): wire up view change protocol in simulator
(#3092)
add af9273081 fix(connectors): support default credential provider chain
for iceberg sink (#3045)
add fcc5a447d feat(bench): prettier table output (#3090)
add afd328fcb fix(ci): fix comfy table problem when building WASM targets
(#3107)
add 44eea4097 chore: add third-party attribution for bundled Gradle
Wrapper (#3109)
add 5a2939a17 feat(ci): dependency-DAG-based test scoping for Rust CI
(#3095)
add d4cdfcaf8 fix(sdk): inline iobuf into iggy_binary_protocol (#3110)
add aa3456603 fix(ci): include binary packages in DAG-scoped builds for
CARGO_BIN_EXE support (#3113)
add 4f9d9ce77 fix(ci): fix DAG-scoped builds for connector plugins and
multi-crate PRs (#3120)
add 56a40445a chore(go): update sdk dependencies (#3115)
add 5fef170dc fix(go): update stats field and its deserialization logic to
align with rust SDK (#3032)
add 35f6f06a4 feat(ci): harden Rust crate publish chain after rc1 incident
(#3111)
add 54c60a827 fix(test): replace log-based container readiness checks with
HTTP healthcheck endpoints (#3093)
add 8568bcbae chore: bump iggy-web-ui to 0.3.0 (#3121)
add 08be9a637 feat(helm): add helm-docs, yamllint, and helmfmt for chart
quality (#3070)
add f551f5e97 deps(python): bump pytest minimum to 9.0.3 (#3122)
add b956a5d39 fix(docs): remove unsupported verbosity in benchmark command
examples (#3114)
add f2dbabdcc fix(cli): Ensure home directory exists when writing contexts
(#3069)
add 170bbee16 chore(deps): update workspace dependencies (#3123)
add 01d4dd94e fix(ci): gate release tags on proven registry availability
(#3124)
add 3e0c9e438 fix(go): correct buffer size for CreateUser and
UpdatePermissions serialization (#3097)
add 735e1fce1 fix(ci): harden publish pipeline (#3125)
add f5350d999 chore(sdk): update rust client to 0.10.0 (#3126)
add 15336a2cc partially working
add 30f9ea3bd merge master
No new revisions were added by this update.
Summary of changes:
.../frontend/Trunk.toml => .config/rail.toml | 22 +-
.github/actions/rust/post-merge/action.yml | 258 ++++++----
.github/actions/rust/pre-merge/action.yml | 132 ++++-
.github/actions/utils/create-git-tag/action.yml | 220 +++++++++
.github/actions/utils/setup-helm-tools/action.yml | 51 +-
.github/actions/utils/wait-for-crate/action.yml | 191 ++++++++
.github/actions/utils/wait-for-url/action.yml | 147 ++++++
.github/config/components.yml | 31 ++
.github/workflows/_publish_rust_crates.yml | 336 +++++++++----
.github/workflows/_test.yml | 3 +
.github/workflows/post-merge.yml | 4 +-
.github/workflows/publish.yml | 539 +++++++++++++++------
.pre-commit-config.yaml | 24 +
Cargo.lock | 257 ++++------
Cargo.toml | 30 +-
DEPENDENCIES.md | 66 ++-
LICENSE | 32 +-
README.md | 14 +-
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 12 +-
bdd/python/pyproject.toml | 4 +-
bdd/python/uv.lock | 18 +-
bdd/rust/Cargo.toml | 1 +
core/ai/mcp/Cargo.toml | 1 +
core/ai/mcp/src/service/mod.rs | 4 +-
core/bench/Cargo.toml | 2 +
core/bench/dashboard/frontend/Cargo.toml | 1 +
core/bench/dashboard/server/Cargo.toml | 1 +
core/bench/dashboard/shared/Cargo.toml | 1 +
core/bench/report/Cargo.toml | 3 +
core/bench/report/src/prints.rs | 199 +++++++-
core/bench/report/src/utils.rs | 9 +
core/bench/runner/Cargo.toml | 1 +
.../src/actors/consumer/benchmark_consumer.rs | 222 ++++++++-
core/bench/src/actors/consumer/client/interface.rs | 1 +
.../actors/consumer/typed_benchmark_consumer.rs | 2 +
.../src/actors/producer/benchmark_producer.rs | 225 ++++++++-
core/bench/src/actors/producer/client/interface.rs | 1 +
.../actors/producer/typed_benchmark_producer.rs | 2 +
.../benchmark_producing_consumer.rs | 230 ++++++++-
.../typed_benchmark_producing_consumer.rs | 3 +
core/bench/src/args/common.rs | 4 +
core/bench/src/benchmarks/common.rs | 6 +
core/bench/src/runner.rs | 3 +-
core/binary_protocol/Cargo.toml | 3 +-
.../src/consensus/iobuf.rs} | 0
core/binary_protocol/src/consensus/message.rs | 48 +-
core/binary_protocol/src/consensus/mod.rs | 14 +
core/cli/src/commands/binary_context/common.rs | 3 +-
core/clock/Cargo.toml | 1 +
core/common/Cargo.toml | 1 -
core/common/src/lib.rs | 1 -
core/common/src/types/send_messages2.rs | 4 +-
core/connectors/runtime/Cargo.toml | 1 +
core/connectors/sdk/Cargo.toml | 1 +
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 1 +
core/connectors/sinks/http_sink/Cargo.toml | 1 +
core/connectors/sinks/iceberg_sink/Cargo.toml | 1 +
core/connectors/sinks/iceberg_sink/src/lib.rs | 4 +-
core/connectors/sinks/iceberg_sink/src/props.rs | 93 +++-
core/connectors/sinks/iceberg_sink/src/sink.rs | 41 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 1 +
core/connectors/sinks/mongodb_sink/Cargo.toml | 1 +
core/connectors/sinks/postgres_sink/Cargo.toml | 1 +
core/connectors/sinks/quickwit_sink/Cargo.toml | 1 +
core/connectors/sinks/stdout_sink/Cargo.toml | 1 +
.../sources/elasticsearch_source/Cargo.toml | 1 +
core/connectors/sources/influxdb_source/Cargo.toml | 1 +
core/connectors/sources/postgres_source/Cargo.toml | 1 +
core/connectors/sources/random_source/Cargo.toml | 1 +
core/consensus/Cargo.toml | 2 +-
core/consensus/src/impls.rs | 143 +++++-
core/consensus/src/observability.rs | 27 ++
core/consensus/src/plane_helpers.rs | 2 +-
core/harness_derive/Cargo.toml | 1 +
core/integration/Cargo.toml | 1 +
.../tests/connectors/fixtures/iceberg/container.rs | 49 +-
.../tests/connectors/fixtures/iceberg/mod.rs | 4 +-
.../connectors/fixtures/influxdb/container.rs | 9 +-
core/integration/tests/connectors/fixtures/mod.rs | 4 +-
.../connectors/fixtures/quickwit/container.rs | 8 +-
.../default_credentials_config}/config.toml | 6 +-
.../tests/connectors/iceberg/iceberg_sink.rs | 54 ++-
.../sink_default_credentials.toml} | 2 +-
core/iobuf/Cargo.toml | 26 -
core/journal/Cargo.toml | 2 +-
core/journal/src/prepare_journal.rs | 2 +-
core/message_bus/Cargo.toml | 1 +
core/metadata/Cargo.toml | 2 +-
core/metadata/src/impls/metadata.rs | 4 +-
core/metadata/src/impls/recovery.rs | 2 +-
core/partitions/Cargo.toml | 2 +-
core/partitions/src/iggy_partition.rs | 66 ++-
core/partitions/src/journal.rs | 2 +-
core/partitions/src/lib.rs | 2 +-
core/partitions/src/messages_writer.rs | 2 +-
core/partitions/src/types.rs | 2 +-
core/sdk/Cargo.toml | 2 +-
core/server-ng/Cargo.toml | 1 +
core/server/Cargo.toml | 1 +
core/shard/Cargo.toml | 1 +
core/shard/src/lib.rs | 487 ++++++++++++++++++-
core/shard/src/router.rs | 65 ++-
core/simulator/Cargo.toml | 2 +-
core/simulator/src/client.rs | 2 +-
core/simulator/src/deps.rs | 2 +-
core/simulator/src/lib.rs | 197 +++++++-
core/simulator/src/packet.rs | 6 +-
core/simulator/src/replica.rs | 6 +
core/tools/Cargo.toml | 1 +
examples/go/go.mod | 2 +-
examples/go/go.sum | 6 +-
examples/python/uv.lock | 8 +-
examples/rust/Cargo.toml | 1 +
.../go/binary_serialization/stats_serializer.go | 90 ----
.../binary_serialization/stats_serializer_test.go | 127 -----
foreign/go/client/tcp/tcp_utilities.go | 7 +-
foreign/go/contracts/stats.go | 141 +++++-
foreign/go/contracts/stats_test.go | 211 ++++++++
foreign/go/go.mod | 38 +-
foreign/go/go.sum | 115 ++---
foreign/go/internal/command/user.go | 6 +-
foreign/go/internal/command/user_test.go | 209 ++++++++
foreign/java/LICENSE | 28 +-
foreign/python/pyproject.toml | 8 +-
foreign/python/uv.lock | 31 +-
helm/charts/iggy/.yamllint.yml | 65 +++
helm/charts/iggy/README.md | 198 +++++---
helm/charts/iggy/{README.md => README.md.gotmpl} | 144 +++---
helm/charts/iggy/templates/_helpers.tpl | 42 +-
helm/charts/iggy/templates/deployment.yaml | 120 ++---
helm/charts/iggy/templates/hpa.yaml | 22 +-
helm/charts/iggy/templates/iggy-pvc.yaml | 6 +-
helm/charts/iggy/templates/ingress.yaml | 80 +--
helm/charts/iggy/templates/service.yaml | 6 +-
helm/charts/iggy/templates/servicemonitor.yaml | 6 +-
helm/charts/iggy/values.yaml | 156 +++---
scripts/bump-version.sh | 8 +-
scripts/ci/markdownlint.sh | 7 +-
scripts/ci/setup-helm-tools.sh | 24 +-
scripts/ci/test-helm.sh | 46 ++
scripts/extract-version.sh | 116 ++++-
scripts/verify-crates-publish.sh | 295 +++++++++++
web/package-lock.json | 4 +-
web/package.json | 2 +-
145 files changed, 5593 insertions(+), 1526 deletions(-)
copy core/bench/dashboard/frontend/Trunk.toml => .config/rail.toml (73%)
create mode 100644 .github/actions/utils/create-git-tag/action.yml
create mode 100644 .github/actions/utils/wait-for-crate/action.yml
create mode 100644 .github/actions/utils/wait-for-url/action.yml
rename core/{iobuf/src/lib.rs => binary_protocol/src/consensus/iobuf.rs} (100%)
copy core/{connectors/sinks/iceberg_sink =>
integration/tests/connectors/iceberg/default_credentials_config}/config.toml
(82%)
copy core/integration/tests/connectors/{elasticsearch/sink.toml =>
iceberg/sink_default_credentials.toml} (92%)
delete mode 100644 core/iobuf/Cargo.toml
delete mode 100644 foreign/go/binary_serialization/stats_serializer.go
delete mode 100644 foreign/go/binary_serialization/stats_serializer_test.go
create mode 100644 foreign/go/contracts/stats_test.go
create mode 100644 foreign/go/internal/command/user_test.go
create mode 100644 helm/charts/iggy/.yamllint.yml
copy helm/charts/iggy/{README.md => README.md.gotmpl} (71%)
create mode 100755 scripts/verify-crates-publish.sh
