This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch vsr-dvc-headers
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d4b4d3046 fix(consensus): stop view change discarding committed ops
add fcef8c01c feat(server-ng): confirm committed sends with partition and
offset (#3781)
add 0a23e161b ci: skip unaffected language jobs in coverage baseline
(#3822)
new d93940ef3 Merge branch 'master' into vsr-dvc-headers
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 +
.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(-)
create mode 100644 core/binary_protocol/src/responses/messages/send_messages.rs
create mode 100644 core/integration/tests/sdk/send_confirmation.rs
create mode 100755 scripts/ci/coverage-baseline-affected.sh
