Struct ReplicationParams 

pub struct ReplicationParams<'a> {
    pub connection_url: &'a str,
    pub slot_name: &'a str,
    pub publication_name: &'a str,
    pub proto_version: u32,
    pub create_slot_if_missing: bool,
    pub start_lsn: Option<u64>,
    pub status_update_interval: Duration,
    pub tcp_keepalive: Duration,
    pub slot_type: SlotType,
    pub tls: &'a CdcTls,
}

All parameters required to establish a logical replication connection.

This struct is accepted by every function in this module.

Fields

connection_url: &'a str

postgres://user:pass@host:port/db style URL.

slot_name: &'a str

Name of the replication slot (must already exist, or create_slot_if_missing = true).

publication_name: &'a str

Publication name — must already exist on the server.

proto_version: u32

pgoutput protocol version. Only 1 is currently supported.

create_slot_if_missing: bool

Create the slot if it does not already exist.

start_lsn: Option<u64>

Optional LSN to resume from. None means “start from the slot’s confirmed_flush_lsn”.

status_update_interval: Duration

Protocol-level Standby Status Update cadence — must be shorter than the server’s wal_sender_timeout.

tcp_keepalive: Duration

TCP-level keepalive interval. Larger than status_update_interval in normal operation.

slot_type: SlotType

Whether a newly-created slot is permanent or temporary.

tls: &'a CdcTls

TLS settings for the replication connection.

Trait Implementations

impl<'a> Clone for ReplicationParams<'a>

fn clone(&self) -> ReplicationParams<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for ReplicationParams<'a>

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

Formats the value using the given formatter.