This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch dependabot/npm_and_yarn/web/web-329c181da4
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 0b3eb68f8 Merge branch 'master' into
dependabot/npm_and_yarn/web/web-329c181da4
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)
new fd1fe675b Merge branch 'master' into
dependabot/npm_and_yarn/web/web-329c181da4
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:
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/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, 7022 insertions(+), 289 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
