faucet_source_postgres_cdc/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! PostgreSQL logical replication (CDC) source for `faucet-stream`.
4//!
5//! Subscribes to a Postgres logical replication slot using the `pgoutput`
6//! plugin and streams INSERT / UPDATE / DELETE / TRUNCATE events as JSON
7//! records. See the crate README for the output record schema and the
8//! Postgres setup requirements (`wal_level=logical`, replication-enabled
9//! role, publication).
10
11pub mod config;
12pub mod pgoutput;
13pub mod replication;
14pub mod state;
15pub mod stream;
16
17pub use config::{CdcTls, PostgresCdcSourceConfig, SlotType};
18pub use faucet_core::{FaucetError, Source};
19pub use state::Bookmark;
20pub use stream::PostgresCdcSource;