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 a7b8288a7 fix(sdk): preserve group membership during primary polling
add 153088b3e fix(connectors): defer postgres source progress until ack
(#3957)
add e0a8196ef feat(python): expose update_user options (#4173)
add fac23670e Merge branch 'master' into server_perf_cut_extra_work
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-source/SKILL.md | 55 +-
.claude/skills/connector-source/TEMPLATE.md | 49 +-
Cargo.lock | 5 +
Cargo.toml | 5 +-
core/connectors/README.md | 2 +-
core/connectors/runtime/README.md | 2 +
core/connectors/runtime/src/manager/source.rs | 35 +
core/connectors/runtime/src/source.rs | 122 +-
core/connectors/runtime/src/stream.rs | 47 +-
core/connectors/sdk/src/source.rs | 174 +-
core/connectors/sources/README.md | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 3 +
core/connectors/sources/postgres_source/README.md | 101 +-
core/connectors/sources/postgres_source/src/lib.rs | 1927 +++++++++++++++++---
.../src/harness/handle/connectors_runtime.rs | 16 +-
core/integration/src/harness/seeds.rs | 8 +-
core/integration/tests/connectors/fixtures/mod.rs | 6 +-
.../tests/connectors/fixtures/postgres/cdc.rs | 41 +
.../tests/connectors/fixtures/postgres/mod.rs | 8 +-
.../tests/connectors/fixtures/postgres/source.rs | 313 +++-
core/integration/tests/connectors/postgres/mod.rs | 58 +-
.../tests/connectors/postgres/postgres_source.rs | 410 ++++-
.../connectors/postgres/postgres_source_cdc.rs | 342 +++-
.../tests/connectors/postgres/restart.rs | 3 +-
foreign/python/apache_iggy.pyi | 4 +
foreign/python/src/client.rs | 20 +-
foreign/python/tests/test_user.py | 36 +
27 files changed, 3429 insertions(+), 365 deletions(-)