Function mz_storage::source::postgres::replication::ensure_replication_timeline_id

async fn ensure_replication_timeline_id(
    replication_client: &Client,
    expected_timeline_id: &u64,
) -> Result<Result<(), DefiniteError>, TransientError>

Ensure the active replication timeline_id matches the one we expect such that we can safely resume replication. It returns an outer transient error in case of connection issues and an inner definite error if the timeline id does not match.