This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/pr-triage-bot
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 05e52793c feat(ci): label PR review state via slash commands and
lifecycle
add 239d7ee0b feat(cpp): add messaging FFI functions for C++ SDK (#3046)
add d5918aa79 feat(cluster): implement replica bootstrap (#3163)
add 9e6921596 fix(message_bus): expose background_tasks_len in release
builds (#3242)
add 921db5319 chore(deps): bump the minor-and-patch group with 10 updates
(#3237)
add 9fbb61da9 chore(deps): bump urllib3 from 2.6.3 to 2.7.0 in
/foreign/python (#3236)
add 1e44cc5b9 fix(common): errors with clippy pedantic (manual_assert)
(#3204)
add 9b9be1964 feat(configs): add address validation for `QUIC/HTTP`
builders (#3152)
add a4b6a8db5 feat(server,mcp): add systemd watchdog integration (#3233)
add 69177a1bf fix(ci): pin cargo-zigbuild to 0.22.1 and alpine to 3.23
(#3249)
add 0cd1bec3a refactor(connectors): isolate per-connector init failures in
runtime (#3244)
add 7c00c5d8a fix(connectors): log underlying errors instead of discarding
them in SDK poll/consume paths (#3200)
add 00df60b05 feat(consensus): cache reply payload and notify subscriber
on commit (#3223)
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 2a21f7f03 Merge branch 'master' into feat/pr-triage-bot
No new revisions were added by this update.
Summary of changes:
.../actions/utils/setup-rust-with-cache/action.yml | 11 +-
Cargo.lock | 157 +-
Cargo.toml | 33 +-
bdd/python/uv.lock | 2 +-
core/ai/mcp/Cargo.toml | 7 +-
core/ai/mcp/Dockerfile | 6 +-
core/ai/mcp/README.md | 11 +
core/ai/mcp/src/main.rs | 21 +
core/ai/mcp/src/systemd.rs | 57 +
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/binary_protocol/src/consensus/command.rs | 3 +-
core/binary_protocol/src/consensus/error.rs | 3 +
core/binary_protocol/src/consensus/header.rs | 246 ++-
core/binary_protocol/src/consensus/message.rs | 5 +
core/binary_protocol/src/consensus/mod.rs | 6 +-
core/binary_protocol/src/lib.rs | 9 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 4 +-
core/common/src/error/iggy_error.rs | 2 +
core/common/src/lib.rs | 1 +
core/common/src/sharding/mod.rs | 5 +-
core/common/src/sharding/namespace.rs | 99 ++
.../http_config/http_client_config_builder.rs | 43 +-
.../quic_config/quic_client_config_builder.rs | 43 +-
.../tcp_config/tcp_client_config_builder.rs | 2 +-
.../websocket_client_config_builder.rs | 36 +-
core/common/src/types/message/messages_batch.rs | 12 +-
.../common/src/types/message/messages_batch_mut.rs | 13 +-
.../common/src/types/message/messages_batch_set.rs | 12 +-
core/common/src/types/streaming_stats.rs | 28 +
core/common/src/utils/net.rs | 101 ++
core/common/src/utils/versioning.rs | 23 +-
core/configs/src/server_config/server.rs | 26 +-
core/configs/src/server_ng_config/defaults.rs | 3 +-
core/configs/src/server_ng_config/displays.rs | 24 +-
core/configs/src/server_ng_config/server_ng.rs | 29 +-
core/configs/src/server_ng_config/validators.rs | 26 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/Dockerfile | 6 +-
core/connectors/runtime/src/context.rs | 78 +-
core/connectors/runtime/src/main.rs | 42 +-
core/connectors/runtime/src/sink.rs | 199 ++-
core/connectors/runtime/src/source.rs | 219 ++-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/src/sink.rs | 89 +-
core/connectors/sdk/src/source.rs | 18 +-
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/consensus/Cargo.toml | 1 +
core/consensus/src/client_table.rs | 770 +++++-----
core/consensus/src/impls.rs | 595 +++++++-
core/consensus/src/lib.rs | 45 +-
core/consensus/src/metadata_helpers.rs | 729 +++++++++
core/consensus/src/oneshot.rs | 407 +++++
core/consensus/src/plane_helpers.rs | 191 +--
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/runtime/error_isolation.rs | 324 ++++
.../tests/connectors/{delta => runtime}/mod.rs | 2 +-
.../sink_invalid_config.toml} | 2 +-
.../sink_invalid_config/stdout_invalid.toml} | 14 +-
.../runtime/sink_invalid_config/stdout_valid.toml} | 12 +-
.../sink_missing_plugin.toml} | 2 +-
.../stdout_missing.toml} | 13 +-
.../sink_missing_plugin_config/stdout_valid.toml} | 12 +-
.../source_invalid_config.toml} | 2 +-
.../source_invalid_config/random_invalid.toml} | 20 +-
.../source_invalid_config/random_valid.toml} | 16 +-
.../source_invalid_state.toml} | 2 +-
.../random_invalid_state.toml} | 21 +-
.../source_invalid_state_config/random_valid.toml} | 16 +-
.../source_missing_plugin.toml} | 2 +-
.../random_missing.toml} | 18 +-
.../random_valid.toml} | 16 +-
core/message_bus/src/lib.rs | 9 +-
core/message_bus/src/replica/io.rs | 6 +-
core/metadata/src/impls/metadata.rs | 517 +++++--
core/metadata/src/impls/recovery.rs | 64 +-
core/metadata/src/lib.rs | 4 +-
core/metadata/src/stats/mod.rs | 381 -----
core/metadata/src/stm/mod.rs | 6 +
core/metadata/src/stm/mux.rs | 22 +
core/metadata/src/stm/stream.rs | 13 +-
core/partitions/src/iggy_index_writer.rs | 24 +-
core/partitions/src/iggy_partition.rs | 245 +--
core/partitions/src/lib.rs | 3 +
core/partitions/src/messages_writer.rs | 26 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/client_builder.rs | 4 +-
core/sdk/src/http/http_client.rs | 20 +-
core/sdk/src/quic/quic_client.rs | 15 +-
core/sdk/src/session.rs | 8 +-
core/server-ng/Cargo.toml | 20 +-
core/server-ng/Dockerfile | 6 +-
core/server-ng/LISTENER_SUPPORT_PLAN.md | 286 ++++
core/server-ng/config.toml | 11 +
.../src/args.rs} | 34 +-
core/server-ng/src/bootstrap.rs | 1573 ++++++++++++++++++++
core/server-ng/src/config_writer.rs | 111 ++
core/server-ng/src/lib.rs | 5 +
core/server-ng/src/login_register.rs | 564 ++++---
core/server-ng/src/main.rs | 55 +-
core/server-ng/src/server_error.rs | 105 ++
core/server/Cargo.toml | 4 +-
core/server/Dockerfile | 6 +-
core/server/README.md | 11 +
core/server/src/bootstrap.rs | 45 +-
core/server/src/http/http_server.rs | 4 +-
core/server/src/shard/mod.rs | 21 +-
core/server/src/shard/systemd.rs | 47 +
.../src/shard/tasks/oneshot/config_writer.rs | 3 +
core/server/src/shard/tasks/periodic/mod.rs | 4 +
.../tasks/periodic/systemd_watchdog.rs} | 40 +-
core/shard/src/router.rs | 45 +-
core/simulator/src/lib.rs | 173 ++-
core/simulator/src/ready_queue.rs | 1 -
examples/python/uv.lock | 2 +-
examples/rust/src/shared/codec.rs | 7 +-
foreign/cpp/Cargo.toml | 5 +-
foreign/cpp/build.rs | 1 +
foreign/cpp/src/client.rs | 234 ++-
foreign/cpp/src/identifier.rs | 4 +
foreign/cpp/src/lib.rs | 78 +
foreign/cpp/src/messages.rs | 85 ++
foreign/cpp/src/stream.rs | 14 +
foreign/cpp/tests/client/low_level_e2e.cpp | 1 +
foreign/cpp/tests/common/test_helpers.hpp | 17 +
foreign/cpp/tests/message/low_level_e2e.cpp | 1249 ++++++++++++++++
foreign/cpp/tests/message/unit_tests.cpp | 116 ++
foreign/cpp/tests/stream/low_level_e2e.cpp | 170 +++
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/go/contracts/version.go | 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 | 8 +-
scripts/bump-version.sh | 76 +-
web/package.json | 2 +-
153 files changed, 9447 insertions(+), 2216 deletions(-)
create mode 100644 core/ai/mcp/src/systemd.rs
create mode 100644 core/consensus/src/metadata_helpers.rs
create mode 100644 core/consensus/src/oneshot.rs
create mode 100644 core/integration/tests/connectors/runtime/error_isolation.rs
copy core/integration/tests/connectors/{delta => runtime}/mod.rs (97%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/sink_invalid_config.toml} (93%)
copy core/{connectors/sinks/stdout_sink/config.toml =>
integration/tests/connectors/runtime/sink_invalid_config/stdout_invalid.toml}
(70%)
copy core/{connectors/sinks/stdout_sink/config.toml =>
integration/tests/connectors/runtime/sink_invalid_config/stdout_valid.toml}
(75%)
copy core/integration/tests/connectors/{iceberg/sink_default_credentials.toml
=> runtime/sink_missing_plugin.toml} (92%)
copy core/{connectors/sinks/stdout_sink/config.toml =>
integration/tests/connectors/runtime/sink_missing_plugin_config/stdout_missing.toml}
(68%)
copy core/{connectors/sinks/stdout_sink/config.toml =>
integration/tests/connectors/runtime/sink_missing_plugin_config/stdout_valid.toml}
(74%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_invalid_config.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_config/random_invalid.toml}
(71%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_config/random_valid.toml}
(80%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_invalid_state.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_state_config/random_invalid_state.toml}
(63%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_state_config/random_valid.toml}
(81%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_missing_plugin.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_missing_plugin_config/random_missing.toml}
(72%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_missing_plugin_config/random_valid.toml}
(80%)
delete mode 100644 core/metadata/src/stats/mod.rs
create mode 100644 core/server-ng/LISTENER_SUPPORT_PLAN.md
copy core/{integration/src/harness/config/connectors_runtime.rs =>
server-ng/src/args.rs} (57%)
create mode 100644 core/server-ng/src/bootstrap.rs
create mode 100644 core/server-ng/src/config_writer.rs
create mode 100644 core/server-ng/src/server_error.rs
create mode 100644 core/server/src/shard/systemd.rs
copy core/server/src/{streaming/topics/helpers.rs =>
shard/tasks/periodic/systemd_watchdog.rs} (54%)
create mode 100644 foreign/cpp/src/messages.rs
create mode 100644 foreign/cpp/tests/message/low_level_e2e.cpp
create mode 100644 foreign/cpp/tests/message/unit_tests.cpp
