mz_storage::source::sql_server::replication

Function handle_data_event

Source 
async fn handle_data_event(
    changes: Vec<Operation>,
    partition_indexes: &[u64],
    decoder_map: &BTreeMap<u64, Arc<SqlServerRowDecoder>>,
    commit_lsn: Lsn,
    rewinds: &BTreeMap<u64, (Lsn, Lsn)>,
    data_output: &AsyncOutputHandle<Lsn, AccountedStackBuilder<CapacityContainerBuilder<TimelyStack<((u64, Result<SourceMessage, DataflowError>), Lsn, Diff)>>>, Tee<Lsn, TimelyStack<((u64, Result<SourceMessage, DataflowError>), Lsn, Diff)>>>,
    data_cap_set: &CapabilitySet<Lsn>,
) -> Result<(), TransientError>