This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch bump-actions
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 699a90843 chore(deps): bump GitHub Actions to Node.js 24-compatible
versions
add 52b198637 feat(consensus): add ClientTable with WAL-backed commit path
and view-change safety (#3023)
add 051475a76 revert(test): remove shared_server, add nextest CI retries
(#3088)
add 70b8d361d chore(security): fix Dependabot security vulnerabilities
(#3087)
add e7be6ddd1 feat(server): support A2A protocol (#2656)
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 6d445213d feat(partitions): add consensus per partition and extra
(#3071)
add 2d6562b7f feat(consensus): add session registration protocol with
combined login+register (#3108)
add 36307999b feat(consensus): impl consensus group mechanism (#3138)
add 572b5ba3a feat(bench): redesign benchmarks dashboard with landing +
compare mode (#3145)
add 832c34164 refactor(bench): unify benchmarks list and fix best-pick
selection (#3146)
add ccb5f004d fix(bench): anchor hero display to showcase pick, fix gitref
links (#3147)
add 9b0540038 fix(bench): fix mobile layout, compare URL, and shared
branded loader (#3148)
add 54fe2bb9f chore(deps): update workspace dependencies (#3149)
add f4222f09c fix(configs): make environment variable name suggestions
deterministic (#3142)
add 515941209 fix(connectors): increase poll budget in fetch_rows_as to
fix flaky restart test (#3106)
add c6ddfb44a chore: bump Rust to 1.95 (#3153)
add 7a22ed5b8 fix(csharp): use OS ephemeral ports in IggyClusterFixture to
fix flaky CI (#3155)
add 9d513d770 feat(message_bus): implement async fire-and-forget transport
for VSR consensus (#3134)
add 0b290b00c ci(csharp): auto-retry flaky integration tests (#3160)
add 037edec4c chore(deps): bump ctor, cucumber, libc, rustls + security
patches (#3161)
add aa4762fd5 docs: redesign header with theme-aware logo and SDK badges
(#3162)
add 868ae6296 docs: Add trendshift's github ranking badge to README (#3170)
add 7de9d093f chore(deps): bump python-dotenv from 1.2.1 to 1.2.2 in
/foreign/python (#3150)
add e1b1b22a7 fix(go,csharp): remove duplicate consumer groups in
DeserializeClient/MapClient (#3164)
add 499a26d88 feat(connectors): implement Delta Lake Sink Connector (#2889)
add 48a297dfa chore(web): update dependencies (#3185)
add cca0e04e7 feat(configs): add ServerNgConfig schema with message_bus
section (#3189)
add eb20ac5ae feat(java): Implement CLI and resource provisioner for
pinned producer benchmark (#3159)
add 57646b233 chore(deps): bump mako from 1.3.10 to 1.3.11 in /bdd/python
(#3137)
add 4ced67c28 chore(deps): bump GitHub Actions to Node.js 24-compatible
versions
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 (699a90843)
\
N -- N -- N refs/heads/bump-actions (4ced67c28)
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:
.config/nextest.toml | 15 +-
.../frontend/Trunk.toml => .config/rail.toml | 22 +-
.github/actions/csharp-dotnet/pre-merge/action.yml | 2 +-
.github/actions/node-npm/pre-merge/action.yml | 7 +-
.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/server-start/action.yml | 10 +-
.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/coverage-baseline.yml | 2 +-
.github/workflows/post-merge.yml | 4 +-
.github/workflows/publish.yml | 539 +++-
.pre-commit-config.yaml | 24 +
.typos.toml | 2 +
Cargo.lock | 1962 +++++++++---
Cargo.toml | 44 +-
DEPENDENCIES.md | 189 +-
Dockerfile | 2 +-
LICENSE | 32 +-
README.md | 67 +-
assets/benchmarking_platform.png | Bin 326093 -> 1165558
bytes
bdd/docker-compose.yml | 70 +-
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 12 +-
bdd/java/Dockerfile | 2 +-
bdd/python/Dockerfile | 2 +-
bdd/python/pyproject.toml | 4 +-
bdd/python/uv.lock | 24 +-
bdd/rust/Cargo.toml | 1 +
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Cargo.toml | 1 +
core/ai/mcp/Dockerfile | 2 +-
core/ai/mcp/src/service/mod.rs | 4 +-
core/bench/Cargo.toml | 2 +
core/bench/dashboard/frontend/Cargo.toml | 3 +-
core/bench/dashboard/frontend/assets/iggy-dark.png | Bin 92329 -> 0 bytes
.../bench/dashboard/frontend/assets/iggy-dark.svg | 2 +-
.../bench/dashboard/frontend/assets/iggy-light.png | Bin 72996 -> 0 bytes
.../bench/dashboard/frontend/assets/iggy-light.svg | 2 +-
.../bench/dashboard/frontend/assets/og-image.png | Bin
core/bench/dashboard/frontend/assets/style.css | 3260 +++++++++++++++-----
core/bench/dashboard/frontend/index.dev.html | 59 +-
core/bench/dashboard/frontend/index.html | 59 +-
core/bench/dashboard/frontend/index.prod.html | 59 +-
.../frontend/src/components/app_content.rs | 581 ++--
.../dashboard/frontend/src/components/chart/mod.rs | 1 +
.../frontend/src/components/chart/single_chart.rs | 41 +-
.../frontend/src/components/chart/tail_chart.rs | 421 +++
.../frontend/src/components/chart/trend_chart.rs | 6 +-
.../frontend/src/components/embed_modal.rs | 1 +
.../dashboard/frontend/src/components/footer.rs | 51 +-
.../src/components/layout/benchmark_meta.rs | 216 ++
.../frontend/src/components/layout/hero.rs | 650 ++++
.../frontend/src/components/layout/logo.rs | 35 -
.../frontend/src/components/layout/main_content.rs | 309 +-
.../frontend/src/components/layout/mod.rs | 6 +-
.../frontend/src/components/layout/sidebar.rs | 510 +--
.../frontend/src/components/layout/sweep_view.rs | 290 ++
.../frontend/src/components/layout/top_app_bar.rs | 455 +++
.../frontend/src/components/layout/topbar.rs | 240 --
.../dashboard/frontend/src/components/loader.rs | 64 +
.../bench/dashboard/frontend/src/components/mod.rs | 1 +
.../selectors/benchmark_kind_selector.rs | 190 --
.../components/selectors/benchmark_search_box.rs | 44 -
.../src/components/selectors/benchmark_selector.rs | 172 --
.../src/components/selectors/benchmarks_list.rs | 260 ++
.../components/selectors/dense_benchmark_row.rs | 163 +
.../src/components/selectors/gitref_selector.rs | 63 -
.../src/components/selectors/hardware_selector.rs | 61 -
.../selectors/measurement_type_selector.rs | 9 +
.../frontend/src/components/selectors/mod.rs | 10 +-
.../components/selectors/param_filters_panel.rs | 216 ++
.../selectors/recent_benchmarks_selector.rs | 258 --
.../src/components/selectors/view_mode_selector.rs | 103 -
.../dashboard/frontend/src/components/theme/mod.rs | 1 -
.../frontend/src/components/theme/theme_toggle.rs | 57 -
.../components/tooltips/benchmark_info_tooltip.rs | 23 +-
.../components/tooltips/server_stats_tooltip.rs | 2 -
core/bench/dashboard/frontend/src/format.rs | 178 ++
core/bench/dashboard/frontend/src/main.rs | 9 +-
core/bench/dashboard/frontend/src/router.rs | 2 +
.../dashboard/frontend/src/state/benchmark.rs | 605 +++-
core/bench/dashboard/frontend/src/state/ui.rs | 490 ++-
core/bench/dashboard/frontend/src/version.rs | 180 ++
core/bench/dashboard/server/Cargo.toml | 1 +
core/bench/dashboard/server/Dockerfile | 2 +-
core/bench/dashboard/shared/Cargo.toml | 1 +
core/bench/report/Cargo.toml | 3 +
core/bench/report/src/plotting/chart.rs | 23 +-
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 | 6 +-
core/bench/src/benchmarks/benchmark.rs | 2 +-
core/bench/src/benchmarks/common.rs | 6 +
core/bench/src/runner.rs | 3 +-
core/binary_protocol/Cargo.toml | 4 +-
core/binary_protocol/src/codes.rs | 4 +
core/binary_protocol/src/consensus/header.rs | 106 +-
.../src/consensus/iobuf.rs} | 66 +-
core/binary_protocol/src/consensus/message.rs | 64 +-
core/binary_protocol/src/consensus/mod.rs | 18 +-
core/binary_protocol/src/consensus/operation.rs | 84 +-
core/binary_protocol/src/dispatch.rs | 116 +-
core/binary_protocol/src/framing.rs | 342 +-
core/binary_protocol/src/lib.rs | 3 +-
core/binary_protocol/src/primitives/mod.rs | 1 +
.../partition_assignment.rs} | 60 +-
.../create_partitions_with_assignments.rs | 126 +
.../binary_protocol/src/requests/partitions/mod.rs | 3 +
.../topics/create_topic_with_assignments.rs | 131 +
core/binary_protocol/src/requests/topics/mod.rs | 2 +
.../src/requests/users/login_register.rs | 216 ++
.../src/requests/users/login_register_with_pat.rs | 203 ++
core/binary_protocol/src/requests/users/mod.rs | 4 +
.../users/{login_user.rs => login_register.rs} | 59 +-
core/binary_protocol/src/responses/users/mod.rs | 2 +
core/cli/src/commands/binary_context/common.rs | 3 +-
core/clock/Cargo.toml | 1 +
core/common/Cargo.toml | 1 -
core/common/src/error/iggy_error.rs | 2 +
core/common/src/lib.rs | 1 -
.../http_config/http_client_config.rs | 4 +
.../http_config/http_client_config_builder.rs | 6 +
.../common/src/types/message/messages_batch_mut.rs | 4 +-
core/common/src/types/send_messages2.rs | 4 +-
.../configs/src/configs_impl/typed_env_provider.rs | 13 +-
core/configs/src/lib.rs | 2 +
core/configs/src/server_config/cluster.rs | 29 +-
core/configs/src/server_config/defaults.rs | 55 +-
core/configs/src/server_config/http.rs | 11 +
core/configs/src/server_config/validators.rs | 274 +-
core/configs/src/server_ng_config/defaults.rs | 94 +
core/configs/src/server_ng_config/displays.rs | 72 +
core/configs/src/server_ng_config/message_bus.rs | 257 ++
.../src/{server_config => server_ng_config}/mod.rs | 27 +-
core/configs/src/server_ng_config/server_ng.rs | 200 ++
core/configs/src/server_ng_config/validators.rs | 130 +
core/configs_derive/src/config_env.rs | 13 +-
core/connectors/runtime/Cargo.toml | 1 +
core/connectors/runtime/Dockerfile | 2 +-
.../example_config/connectors/delta_sink.toml} | 14 +-
core/connectors/sdk/Cargo.toml | 1 +
core/connectors/sdk/src/convert.rs | 114 +
.../sinks/{stdout_sink => delta_sink}/Cargo.toml | 10 +-
core/connectors/sinks/delta_sink/README.md | 92 +
core/connectors/sinks/delta_sink/config.toml | 62 +
core/connectors/sinks/delta_sink/src/coercions.rs | 680 ++++
core/connectors/sinks/delta_sink/src/lib.rs | 97 +
core/connectors/sinks/delta_sink/src/sink.rs | 181 ++
core/connectors/sinks/delta_sink/src/storage.rs | 301 ++
.../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/client_table.rs | 859 ++++++
core/consensus/src/impls.rs | 380 ++-
core/consensus/src/lib.rs | 5 +-
core/consensus/src/namespaced_pipeline.rs | 580 ----
core/consensus/src/observability.rs | 278 +-
core/consensus/src/plane_helpers.rs | 256 +-
core/harness_derive/Cargo.toml | 1 +
core/harness_derive/src/attrs.rs | 74 +-
core/harness_derive/src/codegen.rs | 205 +-
core/integration/Cargo.toml | 6 +-
.../integration/src/harness/config/jwks.rs | 13 +-
core/integration/src/harness/config/mod.rs | 2 +
core/integration/src/harness/handle/mod.rs | 2 +-
core/integration/src/harness/handle/server.rs | 9 +-
core/integration/src/harness/mod.rs | 4 +-
.../src/harness/orchestrator/builder.rs | 58 +-
.../src/harness/orchestrator/harness.rs | 234 +-
core/integration/src/harness/seeds.rs | 71 +-
core/integration/src/harness/shared.rs | 159 -
core/integration/src/lib.rs | 3 +-
core/integration/tests/config_provider/mod.rs | 469 ++-
core/integration/tests/connectors/api/endpoints.rs | 24 +-
.../{stdout/stdout_sink.rs => delta/delta_sink.rs} | 129 +-
.../tests/connectors/{api => delta}/mod.rs | 2 +-
.../tests/connectors/{http => delta}/sink.toml | 2 +-
.../connectors/elasticsearch/elasticsearch_sink.rs | 9 +-
.../elasticsearch/elasticsearch_source.rs | 9 +-
.../tests/connectors/fixtures/delta/fixture.rs | 391 +++
.../connectors/{http => fixtures/delta}/mod.rs | 4 +-
.../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 | 6 +-
.../tests/connectors/fixtures/postgres/sink.rs | 2 +-
.../connectors/fixtures/quickwit/container.rs | 8 +-
.../integration/tests/connectors/http/http_sink.rs | 26 +-
.../http_config_provider/direct_responses.rs | 30 +-
.../http_config_provider/wrapped_responses.rs | 30 +-
.../default_credentials_config}/config.toml | 6 +-
.../tests/connectors/iceberg/iceberg_sink.rs | 63 +-
.../sink_default_credentials.toml} | 2 +-
.../tests/connectors/influxdb/influxdb_sink.rs | 18 +-
.../connectors/influxdb/influxdb_sink_formats.rs | 36 +-
.../tests/connectors/influxdb/influxdb_source.rs | 12 +-
.../connectors/influxdb/influxdb_source_formats.rs | 27 +-
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/mongodb/mongodb_sink.rs | 31 +-
.../tests/connectors/postgres/postgres_sink.rs | 9 +-
.../tests/connectors/postgres/postgres_source.rs | 15 +-
.../tests/connectors/postgres/restart.rs | 6 +-
.../tests/connectors/quickwit/quickwit_sink.rs | 12 +-
.../tests/connectors/random/random_source.rs | 3 +-
.../tests/connectors/stdout/stdout_sink.rs | 9 +-
.../{connectors/api => server/a2a_jwt}/config.toml | 51 +-
core/integration/tests/server/a2a_jwt/jwt_tests.rs | 331 ++
.../{connectors/api => server/a2a_jwt}/mod.rs | 2 +-
.../server/a2a_jwt/wiremock/__files/jwks.json | 10 +
.../a2a_jwt/wiremock/mappings/jwks.json} | 4 +-
core/integration/tests/server/mod.rs | 1 +
.../server/scenarios/authentication_scenario.rs | 8 +-
...with_single_client_polling_messages_scenario.rs | 7 +-
core/iobuf/Cargo.toml | 26 -
core/journal/Cargo.toml | 2 +-
core/journal/src/lib.rs | 2 +-
.../{metadata_journal.rs => prepare_journal.rs} | 42 +-
core/message_bus/Cargo.toml | 8 +
core/message_bus/src/cache/connection.rs | 437 ++-
core/message_bus/src/cache/mod.rs | 3 +-
core/message_bus/src/client_listener.rs | 97 +
core/message_bus/src/config.rs | 93 +
core/message_bus/src/connector.rs | 184 ++
core/message_bus/src/error.rs | 69 +
core/message_bus/src/fd_transfer.rs | 192 ++
core/message_bus/src/framing.rs | 214 ++
core/message_bus/src/installer.rs | 542 ++++
core/message_bus/src/lib.rs | 678 +++-
.../src/lifecycle/connection_registry.rs | 1006 ++++++
.../src/lifecycle}/mod.rs | 14 +-
core/message_bus/src/lifecycle/shutdown.rs | 184 ++
core/message_bus/src/replica_io.rs | 154 +
core/message_bus/src/replica_listener.rs | 164 +
core/message_bus/src/socket_opts.rs | 76 +
.../tooltips => message_bus/src/transports}/mod.rs | 9 +-
core/message_bus/src/writer_task.rs | 117 +
core/message_bus/tests/backpressure.rs | 114 +
core/message_bus/tests/common/mod.rs | 88 +
core/message_bus/tests/connection_lost_notify.rs | 122 +
core/message_bus/tests/directional_connection.rs | 116 +
core/message_bus/tests/duplicate_client_id.rs | 200 ++
core/message_bus/tests/graceful_shutdown.rs | 140 +
core/message_bus/tests/head_of_line.rs | 177 ++
core/message_bus/tests/reconnect.rs | 80 +
core/message_bus/tests/reconnect_skip_connected.rs | 110 +
core/message_bus/tests/replica_roundtrip.rs | 127 +
core/message_bus/tests/shard_zero_gating.rs | 152 +
core/message_bus/tests/tcp_client_roundtrip.rs | 110 +
core/message_bus/tests/vectored_batch.rs | 107 +
core/metadata/Cargo.toml | 4 +-
core/metadata/src/impls/metadata.rs | 530 +++-
core/metadata/src/impls/recovery.rs | 12 +-
core/metadata/src/stm/mod.rs | 41 +
core/metadata/src/stm/mux.rs | 5 +
core/metadata/src/stm/snapshot.rs | 33 +-
core/metadata/src/stm/stream.rs | 238 +-
core/partitions/Cargo.toml | 2 +-
core/partitions/src/iggy_partition.rs | 1482 ++++++++-
core/partitions/src/iggy_partitions.rs | 1163 +------
core/partitions/src/journal.rs | 77 +-
core/partitions/src/lib.rs | 3 +-
core/partitions/src/messages_writer.rs | 2 +-
core/partitions/src/offset_storage.rs | 64 +
core/partitions/src/types.rs | 57 +-
core/sdk/src/client_provider.rs | 1 +
core/sdk/src/clients/client_builder.rs | 6 +
core/sdk/src/clients/consumer.rs | 3 +
core/sdk/src/http/http_client.rs | 4 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/session.rs | 252 ++
core/server-ng/Cargo.toml | 1 +
core/server-ng/Dockerfile | 2 +-
core/server-ng/config.toml | 73 +-
core/server-ng/src/lib.rs | 3 +
core/server-ng/src/login_register.rs | 467 +++
core/server-ng/src/session_manager.rs | 432 +++
core/server/Cargo.toml | 2 +
core/server/Dockerfile | 2 +-
core/server/config.toml | 48 +-
core/server/src/args.rs | 16 +
core/server/src/http/jwt/json_web_token.rs | 109 +-
core/server/src/http/jwt/jwks.rs | 316 ++
core/server/src/http/jwt/jwt_manager.rs | 200 +-
core/server/src/http/jwt/middleware.rs | 12 +-
core/server/src/http/jwt/mod.rs | 1 +
core/server/src/http/mapper.rs | 4 +-
core/server/src/main.rs | 2 +
core/server/src/shard/builder.rs | 10 +
core/server/src/shard/mod.rs | 4 +
core/server/src/shard/system/cluster.rs | 163 +-
core/server/src/shard/system/segments.rs | 2 +-
core/server/src/streaming/partitions/ops_tests.rs | 2 +-
core/server/src/streaming/partitions/storage.rs | 2 +-
core/shard/Cargo.toml | 2 +
core/shard/src/builder.rs | 216 ++
core/shard/src/config.rs | 60 +
core/shard/src/coordinator.rs | 561 ++++
core/shard/src/lib.rs | 1083 ++++++-
core/shard/src/router.rs | 269 +-
core/shard/src/shards_table.rs | 22 +-
core/simulator/Cargo.toml | 2 +-
core/simulator/src/bus.rs | 115 +-
core/simulator/src/client.rs | 75 +-
core/simulator/src/deps.rs | 2 +-
core/simulator/src/lib.rs | 285 +-
core/simulator/src/packet.rs | 6 +-
core/simulator/src/replica.rs | 42 +-
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 +
examples/rust/src/multi-tenant/consumer/main.rs | 4 +-
examples/rust/src/multi-tenant/producer/main.rs | 4 +-
examples/rust/src/sink-data-producer/main.rs | 3 +
foreign/csharp/Directory.Packages.props | 1 +
.../Fixtures/IggyClusterFixture.cs | 124 +-
.../Iggy_SDK.Tests.Integration.csproj | 1 +
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 32 +-
.../binary_response_deserializer.go | 28 +-
.../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 | 53 +-
foreign/go/go.sum | 157 +-
foreign/go/internal/command/user.go | 6 +-
foreign/go/internal/command/user_test.go | 209 ++
foreign/java/LICENSE | 28 +-
foreign/java/{buildSrc => bench}/build.gradle.kts | 21 +-
.../java/org/apache/iggy/bench/IggyBench.java} | 21 +-
.../tcp/async/TcpAsyncPinnedProducer.java | 51 +
.../apache/iggy/bench/cli/IggyBenchCommand.java | 162 +
.../iggy/bench/cli/PinnedProducerCommand.java | 111 +
.../iggy/bench/exception/BenchmarkException.java} | 19 +-
.../iggy/bench/models/cli/GlobalCliArgs.java | 85 +
.../bench/models/cli/PinnedProducerCliArgs.java | 43 +
.../models/provision/ProvisionedResources.java} | 4 +-
.../iggy/bench/provision/ResourceProvisioner.java | 100 +
foreign/java/gradle/libs.versions.toml | 2 +
foreign/java/settings.gradle.kts | 3 +
foreign/python/pyproject.toml | 8 +-
foreign/python/uv.lock | 37 +-
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 +-
rust-toolchain.toml | 2 +-
scripts/bump-version.sh | 8 +-
scripts/ci/markdownlint.sh | 7 +-
scripts/ci/setup-helm-tools.sh | 24 +-
scripts/ci/test-helm.sh | 46 +
scripts/dashboard/run_dev.sh | 13 +-
scripts/extract-version.sh | 116 +-
scripts/verify-crates-publish.sh | 295 ++
web/package-lock.json | 1330 +++++---
web/package.json | 45 +-
393 files changed, 35382 insertions(+), 9181 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
delete mode 100644 core/bench/dashboard/frontend/assets/iggy-dark.png
copy web/static/iggy-apache-lightbg.svg =>
core/bench/dashboard/frontend/assets/iggy-dark.svg (99%)
delete mode 100644 core/bench/dashboard/frontend/assets/iggy-light.png
copy assets/logo/SVG/iggy-apache-color-darkbg.svg =>
core/bench/dashboard/frontend/assets/iggy-light.svg (99%)
copy assets/logo/4x/[email protected] =>
core/bench/dashboard/frontend/assets/og-image.png (100%)
create mode 100644
core/bench/dashboard/frontend/src/components/chart/tail_chart.rs
create mode 100644
core/bench/dashboard/frontend/src/components/layout/benchmark_meta.rs
create mode 100644 core/bench/dashboard/frontend/src/components/layout/hero.rs
delete mode 100644 core/bench/dashboard/frontend/src/components/layout/logo.rs
create mode 100644
core/bench/dashboard/frontend/src/components/layout/sweep_view.rs
create mode 100644
core/bench/dashboard/frontend/src/components/layout/top_app_bar.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/layout/topbar.rs
create mode 100644 core/bench/dashboard/frontend/src/components/loader.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/benchmark_kind_selector.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/benchmark_search_box.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/benchmark_selector.rs
create mode 100644
core/bench/dashboard/frontend/src/components/selectors/benchmarks_list.rs
create mode 100644
core/bench/dashboard/frontend/src/components/selectors/dense_benchmark_row.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/gitref_selector.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/hardware_selector.rs
create mode 100644
core/bench/dashboard/frontend/src/components/selectors/param_filters_panel.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/recent_benchmarks_selector.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/selectors/view_mode_selector.rs
delete mode 100644
core/bench/dashboard/frontend/src/components/theme/theme_toggle.rs
create mode 100644 core/bench/dashboard/frontend/src/format.rs
create mode 100644 core/bench/dashboard/frontend/src/version.rs
rename core/{iobuf/src/lib.rs => binary_protocol/src/consensus/iobuf.rs} (86%)
copy core/binary_protocol/src/{responses/system/get_snapshot.rs =>
primitives/partition_assignment.rs} (51%)
create mode 100644
core/binary_protocol/src/requests/partitions/create_partitions_with_assignments.rs
create mode 100644
core/binary_protocol/src/requests/topics/create_topic_with_assignments.rs
create mode 100644 core/binary_protocol/src/requests/users/login_register.rs
create mode 100644
core/binary_protocol/src/requests/users/login_register_with_pat.rs
copy core/binary_protocol/src/responses/users/{login_user.rs =>
login_register.rs} (51%)
create mode 100644 core/configs/src/server_ng_config/defaults.rs
create mode 100644 core/configs/src/server_ng_config/displays.rs
create mode 100644 core/configs/src/server_ng_config/message_bus.rs
copy core/configs/src/{server_config => server_ng_config}/mod.rs (52%)
create mode 100644 core/configs/src/server_ng_config/server_ng.rs
create mode 100644 core/configs/src/server_ng_config/validators.rs
copy core/connectors/{sinks/stdout_sink/config.toml =>
runtime/example_config/connectors/delta_sink.toml} (79%)
copy core/connectors/sinks/{stdout_sink => delta_sink}/Cargo.toml (85%)
create mode 100644 core/connectors/sinks/delta_sink/README.md
create mode 100644 core/connectors/sinks/delta_sink/config.toml
create mode 100644 core/connectors/sinks/delta_sink/src/coercions.rs
create mode 100644 core/connectors/sinks/delta_sink/src/lib.rs
create mode 100644 core/connectors/sinks/delta_sink/src/sink.rs
create mode 100644 core/connectors/sinks/delta_sink/src/storage.rs
create mode 100644 core/consensus/src/client_table.rs
delete mode 100644 core/consensus/src/namespaced_pipeline.rs
copy foreign/java/buildSrc/build.gradle.kts =>
core/integration/src/harness/config/jwks.rs (80%)
delete mode 100644 core/integration/src/harness/shared.rs
copy core/integration/tests/connectors/{stdout/stdout_sink.rs =>
delta/delta_sink.rs} (69%)
copy core/integration/tests/connectors/{api => delta}/mod.rs (98%)
copy core/integration/tests/connectors/{http => delta}/sink.toml (94%)
create mode 100644 core/integration/tests/connectors/fixtures/delta/fixture.rs
copy core/integration/tests/connectors/{http => fixtures/delta}/mod.rs (92%)
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%)
copy core/integration/tests/{connectors/api => server/a2a_jwt}/config.toml
(50%)
create mode 100644 core/integration/tests/server/a2a_jwt/jwt_tests.rs
copy core/integration/tests/{connectors/api => server/a2a_jwt}/mod.rs (98%)
create mode 100644
core/integration/tests/server/a2a_jwt/wiremock/__files/jwks.json
copy
core/integration/tests/{connectors/http_config_provider/wiremock/mappings/direct/get-active-configs.json
=> server/a2a_jwt/wiremock/mappings/jwks.json} (64%)
delete mode 100644 core/iobuf/Cargo.toml
rename core/journal/src/{metadata_journal.rs => prepare_journal.rs} (95%)
create mode 100644 core/message_bus/src/client_listener.rs
create mode 100644 core/message_bus/src/config.rs
create mode 100644 core/message_bus/src/connector.rs
create mode 100644 core/message_bus/src/error.rs
create mode 100644 core/message_bus/src/fd_transfer.rs
create mode 100644 core/message_bus/src/framing.rs
create mode 100644 core/message_bus/src/installer.rs
create mode 100644 core/message_bus/src/lifecycle/connection_registry.rs
copy core/{server/src/shard/task_registry => message_bus/src/lifecycle}/mod.rs
(67%)
create mode 100644 core/message_bus/src/lifecycle/shutdown.rs
create mode 100644 core/message_bus/src/replica_io.rs
create mode 100644 core/message_bus/src/replica_listener.rs
create mode 100644 core/message_bus/src/socket_opts.rs
copy core/{bench/dashboard/frontend/src/components/tooltips =>
message_bus/src/transports}/mod.rs (77%)
create mode 100644 core/message_bus/src/writer_task.rs
create mode 100644 core/message_bus/tests/backpressure.rs
create mode 100644 core/message_bus/tests/common/mod.rs
create mode 100644 core/message_bus/tests/connection_lost_notify.rs
create mode 100644 core/message_bus/tests/directional_connection.rs
create mode 100644 core/message_bus/tests/duplicate_client_id.rs
create mode 100644 core/message_bus/tests/graceful_shutdown.rs
create mode 100644 core/message_bus/tests/head_of_line.rs
create mode 100644 core/message_bus/tests/reconnect.rs
create mode 100644 core/message_bus/tests/reconnect_skip_connected.rs
create mode 100644 core/message_bus/tests/replica_roundtrip.rs
create mode 100644 core/message_bus/tests/shard_zero_gating.rs
create mode 100644 core/message_bus/tests/tcp_client_roundtrip.rs
create mode 100644 core/message_bus/tests/vectored_batch.rs
create mode 100644 core/partitions/src/offset_storage.rs
create mode 100644 core/sdk/src/session.rs
create mode 100644 core/server-ng/src/login_register.rs
create mode 100644 core/server-ng/src/session_manager.rs
create mode 100644 core/server/src/http/jwt/jwks.rs
create mode 100644 core/shard/src/builder.rs
create mode 100644 core/shard/src/config.rs
create mode 100644 core/shard/src/coordinator.rs
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
copy foreign/java/{buildSrc => bench}/build.gradle.kts (58%)
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/message/PollingKind.java
=> bench/src/main/java/org/apache/iggy/bench/IggyBench.java} (71%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/benchmarks/tcp/async/TcpAsyncPinnedProducer.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/cli/IggyBenchCommand.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/cli/PinnedProducerCommand.java
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/message/PollingKind.java
=> bench/src/main/java/org/apache/iggy/bench/exception/BenchmarkException.java}
(75%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/cli/GlobalCliArgs.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/cli/PinnedProducerCliArgs.java
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/consumergroup/ConsumerGroupMember.java
=>
bench/src/main/java/org/apache/iggy/bench/models/provision/ProvisionedResources.java}
(85%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/provision/ResourceProvisioner.java
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
