mz_storage::source::mysql

Function return_definite_error

Source
async fn return_definite_error(
    err: DefiniteError,
    outputs: &[usize],
    data_handle: &AsyncOutputHandle<GtidPartition, AccountedStackBuilder<CapacityContainerBuilder<StackWrapper<((usize, Result<SourceMessage, DataflowError>), GtidPartition, Diff)>>>, Tee<GtidPartition, StackWrapper<((usize, Result<SourceMessage, DataflowError>), GtidPartition, Diff)>>>,
    data_cap_set: &CapabilitySet<GtidPartition>,
    definite_error_handle: &AsyncOutputHandle<GtidPartition, CapacityContainerBuilder<Vec<ReplicationError>>, Tee<GtidPartition, Vec<ReplicationError>>>,
    definite_error_cap_set: &CapabilitySet<GtidPartition>,
)