Struct dataflow::render::SourceBoundary [−][src]
pub struct SourceBoundary {
pub ok: ActivatedEventPusher<Rc<EventLink<Timestamp, (Row, Timestamp, Diff)>>>,
pub err: ActivatedEventPusher<Rc<EventLink<Timestamp, (DataflowError, Timestamp, Diff)>>>,
pub token: Rc<dyn Any>,
}
Expand description
Information about each source that must be communicated between storage and compute layers.
Fields
ok: ActivatedEventPusher<Rc<EventLink<Timestamp, (Row, Timestamp, Diff)>>>
Captured row
updates representing a differential collection.
err: ActivatedEventPusher<Rc<EventLink<Timestamp, (DataflowError, Timestamp, Diff)>>>
Captured error updates representing a differential collection.
token: Rc<dyn Any>
A token that should be dropped to terminate the source.
Auto Trait Implementations
impl !RefUnwindSafe for SourceBoundary
impl !Send for SourceBoundary
impl !Sync for SourceBoundary
impl Unpin for SourceBoundary
impl !UnwindSafe for SourceBoundary
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