Function mz_storage::source::postgres::postgres_replication_loop_inner

source · 
async fn postgres_replication_loop_inner(
    task_info: &mut PostgresTaskInfo
) -> Result<(), ReplicationError>
Expand description

Core logic