mz_storage::source::postgres

Function ensure_replication_slot

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