This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch
dependabot/uv/foreign/python/python-dotenv-1.2.2
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a9a73f9c3 chore(deps): bump python-dotenv from 1.2.1 to 1.2.2 in
/foreign/python
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 909472066 Merge branch 'master' into
dependabot/uv/foreign/python/python-dotenv-1.2.2
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 | 218 +++--
Cargo.toml | 8 +-
DEPENDENCIES.md | 70 +-
Dockerfile | 2 +-
README.md | 53 +-
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/server/Dockerfile | 2 +-
core/bench/src/args/common.rs | 2 +-
core/bench/src/benchmarks/benchmark.rs | 2 +-
core/binary_protocol/src/consensus/iobuf.rs | 64 +-
core/binary_protocol/src/consensus/message.rs | 2 +-
core/binary_protocol/src/consensus/mod.rs | 4 +-
.../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/impls.rs | 22 +-
core/consensus/src/plane_helpers.rs | 139 +--
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 +-
...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 ++
.../layout => message_bus/src/transports}/mod.rs | 11 +-
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/src/impls/metadata.rs | 52 +-
core/partitions/src/iggy_partition.rs | 177 +++-
core/partitions/src/iggy_partitions.rs | 7 +-
core/partitions/src/journal.rs | 70 ++
core/partitions/src/types.rs | 2 +-
core/server-ng/Dockerfile | 2 +-
core/server-ng/config.toml | 33 +-
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 | 365 +++++--
core/shard/src/router.rs | 235 +++--
core/shard/src/shards_table.rs | 22 +-
core/simulator/src/bus.rs | 115 +--
core/simulator/src/lib.rs | 3 +-
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 +-
99 files changed, 8541 insertions(+), 1253 deletions(-)
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/layout =>
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/shard/src/builder.rs
create mode 100644 core/shard/src/config.rs
create mode 100644 core/shard/src/coordinator.rs
