This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch dependabot/uv/bdd/python/mako-1.3.11
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1eefbed31 chore(deps): bump mako from 1.3.10 to 1.3.11 in /bdd/python
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 f81e4ebe4 Merge branch 'master' into
dependabot/uv/bdd/python/mako-1.3.11
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 2 +-
.github/actions/node-npm/pre-merge/action.yml | 7 +-
.github/actions/utils/server-start/action.yml | 10 +-
Cargo.lock | 354 ++-
Cargo.toml | 24 +-
DEPENDENCIES.md | 85 +-
Dockerfile | 2 +-
README.md | 53 +-
assets/benchmarking_platform.png | Bin 326093 -> 1165558
bytes
bdd/docker-compose.yml | 70 +-
bdd/java/Dockerfile | 2 +-
bdd/python/Dockerfile | 2 +-
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Dockerfile | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
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/Dockerfile | 2 +-
core/bench/report/src/plotting/chart.rs | 23 +-
core/bench/src/args/common.rs | 2 +-
core/bench/src/benchmarks/benchmark.rs | 2 +-
core/binary_protocol/Cargo.toml | 1 +
core/binary_protocol/src/codes.rs | 4 +
core/binary_protocol/src/consensus/header.rs | 98 +-
core/binary_protocol/src/consensus/iobuf.rs | 64 +-
core/binary_protocol/src/consensus/message.rs | 2 +-
core/binary_protocol/src/consensus/mod.rs | 4 +-
core/binary_protocol/src/consensus/operation.rs | 79 +-
core/binary_protocol/src/dispatch.rs | 110 +-
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 +
.../common/src/types/message/messages_batch_mut.rs | 4 +-
.../configs/src/configs_impl/typed_env_provider.rs | 13 +-
core/configs/src/server_config/cluster.rs | 29 +-
core/configs/src/server_config/defaults.rs | 54 +-
core/configs/src/server_config/validators.rs | 274 +-
core/configs_derive/src/config_env.rs | 13 +-
core/connectors/runtime/Dockerfile | 2 +-
core/consensus/src/client_table.rs | 496 ++-
core/consensus/src/impls.rs | 22 +-
core/consensus/src/observability.rs | 3 +
core/consensus/src/plane_helpers.rs | 192 +-
core/integration/src/harness/handle/server.rs | 7 +
.../src/harness/orchestrator/builder.rs | 43 +-
core/integration/tests/config_provider/mod.rs | 469 ++-
.../tests/connectors/fixtures/postgres/sink.rs | 2 +-
.../server/scenarios/authentication_scenario.rs | 8 +-
...with_single_client_polling_messages_scenario.rs | 7 +-
core/message_bus/Cargo.toml | 7 +
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 | 2 +-
core/metadata/src/impls/metadata.rs | 439 ++-
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/src/iggy_partition.rs | 237 +-
core/partitions/src/iggy_partitions.rs | 7 +-
core/partitions/src/journal.rs | 70 +
core/partitions/src/types.rs | 2 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/session.rs | 252 ++
core/server-ng/Dockerfile | 2 +-
core/server-ng/config.toml | 33 +-
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/Dockerfile | 2 +-
core/server/config.toml | 42 +-
core/server/src/args.rs | 16 +
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 | 1 +
core/shard/src/builder.rs | 216 ++
core/shard/src/config.rs | 60 +
core/shard/src/coordinator.rs | 561 ++++
core/shard/src/lib.rs | 382 ++-
core/shard/src/router.rs | 240 +-
core/shard/src/shards_table.rs | 22 +-
core/simulator/src/bus.rs | 115 +-
core/simulator/src/client.rs | 60 +-
core/simulator/src/lib.rs | 89 +-
core/simulator/src/replica.rs | 1 +
examples/rust/src/multi-tenant/consumer/main.rs | 4 +-
examples/rust/src/multi-tenant/producer/main.rs | 4 +-
foreign/csharp/Directory.Packages.props | 1 +
.../Fixtures/IggyClusterFixture.cs | 124 +-
.../Iggy_SDK.Tests.Integration.csproj | 1 +
rust-toolchain.toml | 2 +-
scripts/dashboard/run_dev.sh | 13 +-
184 files changed, 20021 insertions(+), 4484 deletions(-)
delete mode 100644 core/bench/dashboard/frontend/assets/iggy-dark.png
copy assets/logo/SVG/iggy-apache-color-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
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/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/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/shard/src/builder.rs
create mode 100644 core/shard/src/config.rs
create mode 100644 core/shard/src/coordinator.rs
