This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch fix-iov-max-len
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 931954c04 fix(server): chunk vectored writes to avoid exceeding
IOV_MAX limit
add 9319220e4 feat(connectors): extend Postgres sink & source connectors,
add integration tests (#2579)
add 915d64ae9 Merge branch 'master' into fix-iov-max-len
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 843 ++++++-------
Cargo.toml | 36 +-
DEPENDENCIES.md | 186 ++-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 4 +-
core/cli/Cargo.toml | 2 +-
core/common/src/configs/mod.rs | 113 +-
core/connectors/runtime/src/configs/connectors.rs | 10 +
.../src/configs/connectors/local_provider.rs | 75 +-
core/connectors/runtime/src/main.rs | 2 +
core/connectors/runtime/src/sink.rs | 36 +-
core/connectors/runtime/src/source.rs | 26 +-
core/connectors/sdk/Cargo.toml | 4 +-
core/connectors/sdk/src/lib.rs | 2 +
core/connectors/sinks/README.md | 2 +
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +
core/connectors/sinks/postgres_sink/README.md | 298 +++--
.../sinks/postgres_sink/config.toml} | 12 +-
core/connectors/sinks/postgres_sink/src/lib.rs | 741 +++++++++--
core/connectors/sources/README.md | 2 +
core/connectors/sources/postgres_source/Cargo.toml | 1 +
core/connectors/sources/postgres_source/README.md | 399 +++++-
.../sources/postgres_source/config.toml} | 27 +-
core/connectors/sources/postgres_source/src/lib.rs | 1299 +++++++++++++-------
core/integration/Cargo.toml | 8 +-
core/integration/tests/connectors/mod.rs | 158 ++-
core/integration/tests/connectors/postgres/mod.rs | 511 +++++++-
.../tests/connectors/postgres/postgres_sink.rs | 141 ++-
.../tests/connectors/postgres/postgres_source.rs | 209 ++++
.../connectors/postgres/{config.toml => sink.toml} | 2 +-
.../{random/config.toml => postgres/source.toml} | 2 +-
.../tests/connectors/random/random_source.rs | 5 +-
core/integration/tests/mcp/mod.rs | 1 +
core/server/Cargo.toml | 6 +-
34 files changed, 3679 insertions(+), 1488 deletions(-)
copy
core/{integration/tests/connectors/postgres/connectors_config/postgres.toml =>
connectors/sinks/postgres_sink/config.toml} (81%)
rename
core/{integration/tests/connectors/postgres/connectors_config/postgres.toml =>
connectors/sources/postgres_source/config.toml} (70%)
create mode 100644
core/integration/tests/connectors/postgres/postgres_source.rs
rename core/integration/tests/connectors/postgres/{config.toml => sink.toml}
(93%)
copy core/integration/tests/connectors/{random/config.toml =>
postgres/source.toml} (93%)
