Expand description
PGSync PostgreSQL adapter: replication protocol client, pgoutput decoder, source preflight, snapshot copier, and the PostgreSQL sink with transactional checkpoints.
Modulesยง
- client
- Ordinary (non-replication) connections through tokio-postgres.
- errors
- Mapping of PostgreSQL errors to PGSync error kinds.
- job
- Job orchestration: bootstrap (snapshot + handoff), run, status, cleanup, and the WAL safety monitor.
- replication
- Replication protocol: connection, pgoutput decoding, slot commands, and the event stream adapter.
- schema
- Schema bootstrap via
pg_dump --schema-only, and target column verification. - sink
- PostgreSQL sink: applies decoded changes inside target transactions and stores the job checkpoint in the same transaction.
- snapshot
- Streaming table copy under an exported snapshot.
- source
- Source inspection and preflight checks (ordinary SQL connection, read-only).
- tls
- rustls configuration shared by ordinary and replication connections.
- url
- Connection URL handling and TLS policy derivation.