mz_storage::source::postgres::replication

Function ensure_publication_exists

Source 
async fn ensure_publication_exists(
    client: &Client,
    publication: &str,
) -> Result<Result<(), DefiniteError>, TransientError>
Expand description

Ensures the publication exists on the server. It returns an outer transient error in case of connection issues and an inner definite error if the publication is dropped.