This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch ci/path-gate-coverage-baseline
in repository https://gitbox.apache.org/repos/asf/iggy.git
from e1bd5060d ci: skip unaffected language jobs in coverage baseline
add dc8493883 test(integration): remove suites duplicating existing
coverage (#3823)
add 0d76a691c feat(server-ng): add per-client-network advertised address
selectors (#3818)
add fcef8c01c feat(server-ng): confirm committed sends with partition and
offset (#3781)
add b1fe82a4c Merge branch 'master' into ci/path-gate-coverage-baseline
No new revisions were added by this update.
Summary of changes:
.github/actions/cpp-bazel/pre-merge/action.yml | 8 +-
.github/actions/php/pre-merge/action.yml | 1 +
.../actions/python-maturin/pre-merge/action.yml | 3 +
Cargo.lock | 53 +-
Cargo.toml | 9 +-
bdd/python/uv.lock | 2 +-
core/ai/mcp/src/service/mod.rs | 5 +-
core/bench/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/responses/messages/mod.rs | 2 +
.../src/responses/messages/send_messages.rs | 284 ++++++
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 5 +-
core/common/src/http/messages/send_messages.rs | 58 +-
core/common/src/lib.rs | 4 +
core/common/src/traits/binary_impls/messages.rs | 137 ++-
core/common/src/traits/binary_impls/mod.rs | 2 +
core/common/src/traits/message_client.rs | 15 +-
core/common/src/traits/mod.rs | 2 +
core/common/src/types/message/mod.rs | 4 +-
core/configs/Cargo.toml | 1 +
core/configs/src/server_ng_config/cluster.rs | 987 ++++++++++++++++++++-
core/configs/src/server_ng_config/defaults.rs | 1 +
core/configs/src/server_ng_config/validators.rs | 1 +
core/configs_derive/src/config_env.rs | 22 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 2 +-
core/connectors/sinks/doris_sink/Cargo.toml | 2 +-
.../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/meilisearch_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/s3_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_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 +-
.../tests/cluster/metadata_checkpoint_restart.rs | 138 ++-
core/integration/tests/sdk/mcp_parity.rs | 608 -------------
core/integration/tests/sdk/messages.rs | 172 ----
core/integration/tests/sdk/mod.rs | 5 +-
core/integration/tests/sdk/producer/background.rs | 6 +-
core/integration/tests/sdk/send_confirmation.rs | 268 ++++++
.../tests/server/cluster_metadata_vsr.rs | 229 ++++-
core/integration/tests/server/general.rs | 19 +-
core/integration/tests/server/http_client.rs | 19 +-
core/integration/tests/server/http_tls.rs | 112 ++-
.../server/metadata_checkpoint_recovery_vsr.rs | 138 ---
core/integration/tests/server/mod.rs | 4 -
.../server/scenarios/authentication_scenario.rs | 1 +
.../server/scenarios/create_message_payload.rs | 148 ---
core/integration/tests/server/scenarios/mod.rs | 1 -
core/partitions/src/iggy_partition.rs | 264 ++++--
core/sdk/Cargo.toml | 3 +-
.../src/client_wrappers/binary_message_client.rs | 3 +-
core/sdk/src/clients/binary_message.rs | 3 +-
core/sdk/src/clients/producer.rs | 167 +++-
core/sdk/src/clients/producer_dispatcher.rs | 7 +-
core/sdk/src/clients/producer_error_callback.rs | 11 +-
core/sdk/src/clients/producer_sharding.rs | 11 +-
core/sdk/src/http/messages.rs | 94 +-
core/sdk/src/prelude.rs | 9 +-
core/server-ng/Cargo.toml | 8 +-
core/server-ng/config.toml | 47 +
core/server-ng/src/bootstrap.rs | 9 +-
core/server-ng/src/cluster_meta.rs | 125 ++-
core/server-ng/src/dispatch.rs | 72 +-
core/server-ng/src/dispatch/authz.rs | 11 +-
core/server-ng/src/http.rs | 37 +-
core/server-ng/src/http/error.rs | 126 ++-
core/server-ng/src/http/extractor.rs | 22 +-
core/server-ng/src/http/handlers.rs | 85 +-
core/server-ng/src/http/reads.rs | 3 +-
core/server-ng/src/http/reply.rs | 146 ++-
core/server-ng/src/http/state.rs | 22 +-
core/server-ng/src/http/submit.rs | 11 +-
core/server-ng/src/http/tls.rs | 15 +-
core/server-ng/src/responses.rs | 12 +-
core/server-ng/src/session_manager.rs | 28 +
core/server-ng/tests/sdk_e2e.rs | 175 +---
examples/python/uv.lock | 2 +-
foreign/cpp/src/client.rs | 7 +-
foreign/cpp/src/lib.rs | 27 +-
foreign/cpp/src/type_conversion.rs | 30 +-
foreign/cpp/tests/e2e/message.cpp | 9 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 2 +-
foreign/node/src/client/client.utils.test.ts | 23 +-
foreign/node/src/client/client.utils.ts | 3 -
foreign/node/src/e2e/tcp.send-message.e2e.ts | 27 +-
foreign/node/src/index.ts | 2 +
.../src/wire/message/send-messages.command.test.ts | 110 ++-
.../node/src/wire/message/send-messages.command.ts | 81 +-
foreign/node/src/wire/vsr/register.ts | 4 +-
foreign/php/iggy-php.stubs.php | 59 +-
foreign/php/src/client.rs | 9 +-
foreign/php/src/lib.rs | 4 +-
foreign/php/src/message_iterator.rs | 3 +
foreign/php/src/send_message.rs | 87 +-
foreign/php/tests/IggySdkTest.php | 20 +
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 68 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 13 +-
foreign/python/src/lib.rs | 4 +-
foreign/python/src/send_message.rs | 98 +-
foreign/python/tests/test_message_operations.py | 40 +
foreign/python/uv.lock | 2 +-
scripts/ci/license-headers.sh | 7 +-
117 files changed, 4078 insertions(+), 1719 deletions(-)
create mode 100644 core/binary_protocol/src/responses/messages/send_messages.rs
delete mode 100644 core/integration/tests/sdk/mcp_parity.rs
delete mode 100644 core/integration/tests/sdk/messages.rs
create mode 100644 core/integration/tests/sdk/send_confirmation.rs
delete mode 100644
core/integration/tests/server/metadata_checkpoint_recovery_vsr.rs
delete mode 100644
core/integration/tests/server/scenarios/create_message_payload.rs
