Struct dataflow::arrangement::manager::TraceBundle [−][src]
pub struct TraceBundle {
oks: TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>,
errs: TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>,
to_drop: Option<Rc<dyn Any>>,
}
Expand description
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
pub fn new(
oks: TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>,
errs: TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>
) -> 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.
Adds tokens to be dropped when the trace bundle is dropped.
Returns a mutable reference to the oks
trace.
pub fn errs_mut(
&mut self
) -> &mut TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>
pub fn errs_mut(
&mut self
) -> &mut TraceAgent<OrdKeySpine<DataflowError, Timestamp, Diff, usize>>
Returns a mutable reference to the errs
trace.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for TraceBundle
impl !Send for TraceBundle
impl !Sync for TraceBundle
impl Unpin for TraceBundle
impl !UnwindSafe for TraceBundle
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more