You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by pi...@apache.org on 2026/08/04 04:55:38 UTC
(iggy) branch dependabot/nuget/foreign/csharp/csharp-00d090c756 updated (839eb538e -> b3e9fca6f)
This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch dependabot/nuget/foreign/csharp/csharp-00d090c756
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 839eb538e Merge branch 'master' into dependabot/nuget/foreign/csharp/csharp-00d090c756
add a684e550f feat(python): add user header and origin timestamp support (#3613)
add 3ca8695d3 feat(connectors): add Meilisearch sink connector (#3497)
add 54d8a49dd feat(server-ng): close the partition materialisation race at the owner (#3786)
add 198364f22 chore(deps): Bump the web group across 1 directory with 16 updates (#3807)
add 4199fed86 chore(deps): Bump fast-uri from 3.1.4 to 3.1.5 in /foreign/node (#3812)
add b3e9fca6f Merge branch 'master' into dependabot/nuget/foreign/csharp/csharp-00d090c756
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 90 ++
Cargo.toml | 6 +
core/connectors/README.md | 1 +
core/connectors/sinks/README.md | 1 +
.../Cargo.toml | 14 +-
core/connectors/sinks/meilisearch_sink/README.md | 105 ++
.../config.toml | 18 +-
core/connectors/sinks/meilisearch_sink/src/lib.rs | 1412 ++++++++++++++++++
core/integration/tests/cluster/mod.rs | 1 +
.../cluster/multi_shard_partition_convergence.rs | 223 +++
.../connectors/fixtures/meilisearch/container.rs | 180 +++
.../fixtures/{quickwit => meilisearch}/mod.rs | 4 +-
.../tests/connectors/fixtures/meilisearch/sink.rs | 90 ++
core/integration/tests/connectors/fixtures/mod.rs | 2 +
.../connectors/meilisearch/meilisearch_sink.rs | 81 ++
.../tests/connectors/{delta => meilisearch}/mod.rs | 2 +-
.../connectors/{delta => meilisearch}/sink.toml | 2 +-
core/integration/tests/connectors/mod.rs | 1 +
core/metadata/src/stm/stream.rs | 16 +-
core/sdk/src/prelude.rs | 6 +-
core/server-ng/Cargo.toml | 7 +
core/server-ng/src/dispatch.rs | 68 +-
core/server-ng/src/partition_reconciler.rs | 1531 +++++++++++++++++++-
core/shard/src/lib.rs | 835 ++++++++++-
core/shard/src/metrics.rs | 139 +-
core/shard/src/router.rs | 40 +-
core/simulator/src/lib.rs | 17 +
examples/python/README.md | 23 +
examples/python/basic/producer.py | 50 +-
examples/python/getting-started/producer.py | 50 +-
examples/python/message-headers/common.py | 240 +++
.../message-headers/plain-headers/consumer.py | 77 +
.../message-headers/plain-headers/producer.py | 59 +
.../message-headers/typed-headers/consumer.py | 77 +
.../message-headers/typed-headers/producer.py | 64 +
examples/python/pyproject.toml | 5 +
foreign/node/package-lock.json | 6 +-
foreign/python/Cargo.toml | 1 +
foreign/python/Dockerfile.test | 2 +-
foreign/python/apache_iggy.pyi | 397 ++++-
foreign/python/docker-compose.test.yml | 11 +-
foreign/python/src/lib.rs | 5 +
foreign/python/src/receive_message.rs | 26 +
foreign/python/src/send_message.rs | 41 +-
foreign/python/src/user_headers.rs | 791 ++++++++++
foreign/python/tests/test_consumer_group.py | 98 ++
foreign/python/tests/test_message_operations.py | 402 ++++-
web/package-lock.json | 613 ++++----
web/package.json | 30 +-
49 files changed, 7348 insertions(+), 612 deletions(-)
copy core/connectors/sinks/{surrealdb_sink => meilisearch_sink}/Cargo.toml (84%)
create mode 100644 core/connectors/sinks/meilisearch_sink/README.md
copy core/connectors/sinks/{elasticsearch_sink => meilisearch_sink}/config.toml (77%)
create mode 100644 core/connectors/sinks/meilisearch_sink/src/lib.rs
create mode 100644 core/integration/tests/cluster/multi_shard_partition_convergence.rs
create mode 100644 core/integration/tests/connectors/fixtures/meilisearch/container.rs
copy core/integration/tests/connectors/fixtures/{quickwit => meilisearch}/mod.rs (89%)
create mode 100644 core/integration/tests/connectors/fixtures/meilisearch/sink.rs
create mode 100644 core/integration/tests/connectors/meilisearch/meilisearch_sink.rs
copy core/integration/tests/connectors/{delta => meilisearch}/mod.rs (97%)
copy core/integration/tests/connectors/{delta => meilisearch}/sink.toml (94%)
create mode 100644 examples/python/message-headers/common.py
create mode 100644 examples/python/message-headers/plain-headers/consumer.py
create mode 100644 examples/python/message-headers/plain-headers/producer.py
create mode 100644 examples/python/message-headers/typed-headers/consumer.py
create mode 100644 examples/python/message-headers/typed-headers/producer.py
create mode 100644 foreign/python/src/user_headers.rs