Enum Control 

pub enum Control {
    Barrier(u64),
    Commit(u64),
    Stop,
}

What the coordinator tells a source.

Variants

Barrier(u64)

Take a barrier for epoch: record the position, forward the barrier.

Commit(u64)

Every task reported epoch: commit the position recorded at its barrier.

Stop

Finish after the current poll: Eos flows downstream in order.

Trait Implementations

impl Clone for Control

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Control

impl Debug for Control

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.