Struct PostgresCdcConfig 

pub struct PostgresCdcConfig {
    pub url: String,
    pub publication: String,
    pub slot_name: String,
    pub create_slot: bool,
    pub create_publication: bool,
    pub publication_tables: Vec<String>,
    pub temporary_slot: bool,
    pub cursor_id: Option<String>,
    pub checkpoint_store: Option<String>,
    pub status_interval_ms: u64,
    pub tls: TlsConfig,
}

Postgres logical-replication CDC source (pgoutput). Source-only.

Fields

url: String

Connection URL, e.g. postgres://user:pass@host:5432/dbname.

publication: String

Publication name (must already exist; defines which tables are captured).

slot_name: String

Replication slot name; created if missing when create_slot is true.

create_slot: bool

Create the replication slot if it does not exist.

create_publication: bool

Create the publication if missing (default false; leave off if it pre-exists). Needs table ownership for publication_tables, or superuser when none are set (FOR ALL TABLES).

publication_tables: Vec<String>

Tables to include when managing the publication (create_publication); may be schema.table. Missing ones are added to an existing publication (never removed). Empty = FOR ALL TABLES (needs superuser).

temporary_slot: bool

Use a temporary slot (dropped on disconnect). Not restart-safe; default is a permanent slot.

cursor_id: Option<String>

Checkpoint key for persisting the confirmed LSN across restarts (optional; the slot is authoritative).

checkpoint_store: Option<String>

Checkpoint store spec (e.g. file:///path, s3://bucket/prefix); defaults to the source database.

status_interval_ms: u64

Standby-status-update interval in ms; must be shorter than the server’s wal_sender_timeout.

tls: TlsConfig

TLS configuration for the replication connection.

Trait Implementations

impl Clone for PostgresCdcConfig

fn clone(&self) -> PostgresCdcConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PostgresCdcConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PostgresCdcConfig

fn default() -> PostgresCdcConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PostgresCdcConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl SecretExtractor for PostgresCdcConfig

fn extract_secrets( &mut self, prefix: &str, secrets: &mut HashMap<String, String>, )

Extracts secrets into the provided map using the given prefix, and clears them from self.

impl Serialize for PostgresCdcConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.