Module sink 

PostgreSQL sink: applies decoded changes inside target transactions and stores the job checkpoint in the same transaction.

Structs

PgSink

RuntimeRow

One heartbeat of the running process, written outside any data transaction.

SinkLimits

Constants

SCHEMA_SQL

Functions

configure_session

Settings every pgsync session on the target needs: a fixed search path, durable commits, and no inherited timeouts. A statement_timeout or idle_in_transaction_session_timeout set on the target role or database would otherwise cancel long transactions or large copies on every attempt (SQLSTATE 57014 is retried, so the job would stall, not fail).

delete_job

Delete the job’s metadata rows (used by cleanup).

set_job_state

upsert_checkpoint

Insert or update the job row (autocommit).

upsert_runtime