Skip to main content

start_replication

faucet_stream::source::postgres_cdc::replication

Function start_replication 

Source 
pub async fn start_replication(
    _client: &Client,
    params: &ReplicationParams<'_>,
) -> Result<Duplex, FaucetError>
Available on crate features source-postgres-cdc and source-rest only.
Expand description

Open a logical replication stream and return a Duplex handle.

Internally this calls pgwire_replication::ReplicationClient::connect which handles TCP, TLS negotiation, auth, and START_REPLICATION in one shot.