Skip to main content

build_start_replication_query

laminar_connectors::cdc::postgres::postgres_io

Function build_start_replication_query 

Source 
pub fn build_start_replication_query(
    slot_name: &str,
    start_lsn: Lsn,
    publication: &str,
) -> Result<String, ConnectorError>
Expand description

Builds the START_REPLICATION SQL command.

This returns the query string to be sent via the CopyBoth protocol. Currently used for documentation; will be used directly once CopyBoth support is available in tokio-postgres.

ยงErrors

Returns ConnectorError::ConfigurationError if slot_name or publication contain characters outside [a-zA-Z0-9_].