pub(super) async fn ensure_replication_prerequisites(
metadata_client: &Client,
replication_client: &Client,
connection: &PostgresSourceConnection,
config_set: &ConfigSet,
) -> Result<Result<(), DefiniteError>, TransientError>Expand description
Ensures the upstream still meets the conditions the replication stream depends on. Once violated, these conditions stay violated. It returns an outer transient error in case of connection issues and an inner definite error for the first violated condition.