This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch partition_superblock
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1a2d35c63 address review comments
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 6b5957b55 Merge branch 'master' into partition_superblock
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
