This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch server_perf_cut_extra_work
in repository https://gitbox.apache.org/repos/asf/iggy.git
from fac23670e Merge branch 'master' into server_perf_cut_extra_work
add b68a506be fix(connectors): validate sink writes and startup readiness
(#4154)
add 142606d2d Merge branch 'master' into server_perf_cut_extra_work
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 2 +
.../example_config/connectors/quickwit_sink.toml | 2 +-
core/connectors/sinks/clickhouse_sink/README.md | 48 ++---
core/connectors/sinks/clickhouse_sink/config.toml | 13 +-
.../connectors/sinks/clickhouse_sink/src/binary.rs | 124 ++++++++++-
core/connectors/sinks/delta_sink/README.md | 17 +-
core/connectors/sinks/delta_sink/config.toml | 2 +-
core/connectors/sinks/doris_sink/README.md | 26 +--
core/connectors/sinks/doris_sink/config.toml | 1 -
core/connectors/sinks/doris_sink/src/lib.rs | 5 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 3 +
core/connectors/sinks/elasticsearch_sink/README.md | 4 +-
.../connectors/sinks/elasticsearch_sink/src/lib.rs | 239 +++++++++++++++++++--
core/connectors/sinks/iceberg_sink/README.md | 69 ++++--
core/connectors/sinks/influxdb_sink/README.md | 89 +++++---
core/connectors/sinks/influxdb_sink/src/lib.rs | 58 +++--
.../connectors/sinks/influxdb_sink/src/protocol.rs | 30 +--
core/connectors/sinks/meilisearch_sink/README.md | 58 +++--
core/connectors/sinks/mongodb_sink/README.md | 74 ++++---
core/connectors/sinks/mongodb_sink/src/lib.rs | 9 -
core/connectors/sinks/postgres_sink/README.md | 107 +++++++--
core/connectors/sinks/postgres_sink/src/lib.rs | 31 ++-
core/connectors/sinks/quickwit_sink/README.md | 25 ++-
core/connectors/sinks/quickwit_sink/config.toml | 2 +-
core/connectors/sinks/quickwit_sink/src/lib.rs | 200 ++++++++++++++---
core/connectors/sinks/s3_sink/Cargo.toml | 1 +
core/connectors/sinks/s3_sink/README.md | 67 +++---
core/connectors/sinks/s3_sink/src/client.rs | 42 +++-
core/connectors/sinks/s3_sink/src/sink.rs | 116 +++++++++-
core/connectors/sinks/surrealdb_sink/README.md | 103 +++++++--
core/connectors/sinks/surrealdb_sink/config.toml | 1 -
core/connectors/sinks/surrealdb_sink/src/lib.rs | 9 +-
.../connectors/elasticsearch/elasticsearch_sink.rs | 79 +++++++
core/integration/tests/connectors/fixtures/mod.rs | 4 +-
.../tests/connectors/fixtures/mongodb/sink.rs | 2 -
.../tests/connectors/fixtures/surrealdb/mod.rs | 4 +-
.../tests/connectors/fixtures/surrealdb/sink.rs | 52 ++++-
.../tests/connectors/influxdb/influxdb_sink.rs | 6 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 4 +-
.../tests/connectors/surrealdb/surrealdb_sink.rs | 33 ++-
40 files changed, 1415 insertions(+), 346 deletions(-)
