Struct dataflow::arrangement::manager::TraceBundle

pub struct TraceBundle {
    oks: TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>,
    errs: TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>,
    to_drop: Option<Rc<dyn Any>>,
}

Bundles together traces for the successful computations (oks), the failed computations (errs), additional tokens that should share the lifetime of the bundled traces (to_drop), and a permutation describing how to reconstruct the original row (permutation).

Fields

oks: TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>

errs: TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>

to_drop: Option<Rc<dyn Any>>

Implementations

impl TraceBundle

pub fn new(
    oks: TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>,
    errs: TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>
) -> TraceBundle

Constructs a new trace bundle out of an oks trace and errs trace.

pub fn with_drop<T>(self, to_drop: T) -> TraceBundle where
    T: 'static, 

Adds tokens to be dropped when the trace bundle is dropped.

pub fn oks_mut(
    &mut self
) -> &mut TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>

Returns a mutable reference to the oks trace.

pub fn errs_mut(
    &mut self
) -> &mut TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>

Returns a mutable reference to the errs trace.

pub fn to_drop(&self) -> &Option<Rc<dyn Any>>

Returns a reference to the to_drop tokens.

Trait Implementations

impl Clone for TraceBundle

fn clone(&self) -> TraceBundle

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.