Struct PostgresCdcConfig 

pub struct PostgresCdcConfig {

    pub host: String,
    pub port: u16,
    pub database: String,
    pub username: String,
    pub password: Option<String>,
    pub ssl_mode: SslMode,
    pub ca_cert_path: Option<String>,
    pub client_cert_path: Option<String>,
    pub client_key_path: Option<String>,
    pub sni_hostname: Option<String>,
    pub slot_name: String,
    pub publication: String,
    pub start_lsn: Option<Lsn>,
    pub output_plugin: String,
    pub snapshot_mode: SnapshotMode,
    pub poll_timeout: Duration,
    pub max_poll_records: usize,
    pub keepalive_interval: Duration,
    pub wal_sender_timeout: Duration,
    pub table_include: Vec<String>,
    pub table_exclude: Vec<String>,
}

Configuration for the PostgreSQL CDC source connector.

Fields

host: String

PostgreSQL host address.

port: u16

PostgreSQL port.

database: String

Database name.

username: String

Username for authentication.

password: Option<String>

Password for authentication.

ssl_mode: SslMode

SSL mode for the connection.

ca_cert_path: Option<String>

Path to CA certificate PEM file (for VerifyCa / VerifyFull).

client_cert_path: Option<String>

Path to client certificate PEM file (for mTLS).

client_key_path: Option<String>

Path to client private key PEM file (for mTLS).

sni_hostname: Option<String>

SNI hostname override (for proxy/load-balancer scenarios).

slot_name: String

Name of the logical replication slot.

publication: String

Name of the publication to subscribe to.

start_lsn: Option<Lsn>

LSN to start replication from (None = slot’s confirmed_flush_lsn).

output_plugin: String

Output plugin name (always pgoutput for logical replication).

snapshot_mode: SnapshotMode

How to handle the initial data snapshot.

poll_timeout: Duration

Timeout for each poll operation.

max_poll_records: usize

Maximum records to return per poll.

keepalive_interval: Duration

Interval for sending keepalive/status updates to PostgreSQL.

wal_sender_timeout: Duration

Maximum WAL sender timeout before the server drops the connection.

table_include: Vec<String>

Tables to include (empty = all tables in publication).

table_exclude: Vec<String>

Tables to exclude from replication.

Implementations

impl PostgresCdcConfig

pub fn new( host: &str, database: &str, slot_name: &str, publication: &str, ) -> Self

Creates a new config with required fields.

pub fn connection_string(&self) -> String

Builds a PostgreSQL connection string.

pub fn from_config(config: &ConnectorConfig) -> Result<Self, ConnectorError>

Parses configuration from a generic ConnectorConfig.

Errors

Returns ConnectorError if required keys are missing or values are invalid.

pub fn validate(&self) -> Result<(), ConnectorError>

Validates the configuration.

Errors

Returns ConnectorError::ConfigurationError for invalid settings.

pub fn should_include_table(&self, table: &str) -> bool

Returns whether a table should be included based on include/exclude lists.

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() -> Self

Returns the “default value” for a type.