This is an automated email from the ASF dual-hosted git repository. krishvishal pushed a commit to branch vsr-dvc-headers in repository https://gitbox.apache.org/repos/asf/iggy.git
commit d93940ef33dd2ed695c090768f94e0bd1393d87f Merge: d4b4d3046 0a23e161b Author: Krishna Vishal <[email protected]> AuthorDate: Thu Aug 6 02:36:28 2026 +0530 Merge branch 'master' into vsr-dvc-headers .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 + .github/workflows/coverage-baseline.yml | 69 ++++- Cargo.lock | 51 ++-- Cargo.toml | 8 +- 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/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 +- core/integration/tests/sdk/mod.rs | 1 + core/integration/tests/sdk/producer/background.rs | 6 +- core/integration/tests/sdk/send_confirmation.rs | 268 +++++++++++++++++++ .../server/scenarios/authentication_scenario.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 | 2 +- core/server-ng/src/dispatch.rs | 36 ++- core/server-ng/src/dispatch/authz.rs | 11 +- core/server-ng/src/http/error.rs | 17 +- core/server-ng/src/http/handlers.rs | 78 +++++- core/server-ng/src/http/reply.rs | 146 ++++++++++- core/server-ng/src/http/submit.rs | 11 +- 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/coverage-baseline-affected.sh | 96 +++++++ scripts/ci/license-headers.sh | 7 +- 92 files changed, 2384 insertions(+), 318 deletions(-)
