mz_storage::source::postgres::replication

Function spawn_schema_validator

Source 
fn spawn_schema_validator(
    client: Client,
    config: &RawSourceCreationConfig,
    publication: String,
    table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
) -> UnboundedReceiver<SchemaValidationError>