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:39:02 UTC
(iggy) 01/01: Merge branch 'master' into dependabot/npm_and_yarn/web/web-329c181da4
This is an automated email from the ASF dual-hosted git repository.
spetz pushed a commit to branch dependabot/npm_and_yarn/web/web-329c181da4
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit fd1fe675bae8a41635fad00dfeaefceeea429a40
Merge: 0b3eb68f8 54d8a49dd
Author: Piotr Gankiewicz <pi...@gmail.com>
AuthorDate: Tue Aug 4 06:38:57 2026 +0200
Merge branch 'master' into dependabot/npm_and_yarn/web/web-329c181da4
Cargo.lock | 90 ++
Cargo.toml | 6 +
core/connectors/README.md | 1 +
core/connectors/sinks/README.md | 1 +
.../connectors/sinks/meilisearch_sink}/Cargo.toml | 44 +-
core/connectors/sinks/meilisearch_sink/README.md | 105 ++
core/connectors/sinks/meilisearch_sink/config.toml | 43 +
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/meilisearch}/mod.rs | 8 +-
.../tests/connectors/fixtures/meilisearch/sink.rs | 90 ++
core/integration/tests/connectors/fixtures/mod.rs | 2 +
.../connectors/meilisearch/meilisearch_sink.rs | 81 ++
.../{cluster => connectors/meilisearch}/mod.rs | 4 +-
.../tests/connectors/meilisearch/sink.toml | 20 +
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/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 ++++-
46 files changed, 7091 insertions(+), 299 deletions(-)