Skip to main content

ensure_replication_slot

mz_storage::source::postgres

Function ensure_replication_slot 

Source 
async fn ensure_replication_slot(
    client: &Client,
    slot: &str,
) -> Result<(), TransientError>