Function mz_storage::source::postgres::ensure_replication_slot

source · 
async fn ensure_replication_slot(
    client: &Client,
    slot: &str
) -> Result<(), TransientError>
Expand description

Ensures the replication slot of this connection is created.