faucet-source-postgres-cdc 1.0.0

PostgreSQL logical replication (CDC) source for the faucet-stream ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

#![cfg_attr(docsrs, feature(doc_cfg))]

//! 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).

pub mod config;
pub mod pgoutput;
pub mod replication;
pub mod state;
pub mod stream;

pub use config::{CdcTls, PostgresCdcSourceConfig, SlotType};
pub use faucet_core::{FaucetError, Source};
pub use state::Bookmark;
pub use stream::PostgresCdcSource;