Crate faucet_source_postgres_cdc 

PostgreSQL logical replication (CDC) source for faucet-stream.

Subscribes to a Postgres logical replication slot using the pgoutput plugin and streams INSERT / UPDATE / DELETE / TRUNCATE events as JSON records. See the crate README for the output record schema and the Postgres setup requirements (wal_level=logical, replication-enabled role, publication).

Re-exports

pub use config::CdcTls;

pub use config::PostgresCdcSourceConfig;

pub use config::SlotType;

pub use state::Bookmark;

pub use stream::PostgresCdcSource;

Modules

config

Configuration for PostgresCdcSource.

pgoutput

pgoutput logical decoding protocol — message types, wire decoder, relation registry, value decoder.

replication

Low-level replication-connection wrapper.

state

Bookmark <-> JSON serialization for replication slot LSN progress.

stream

PostgresCdcSource — public Source implementation.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Source

A source fetches records from an external system.