Enum Event 

pub enum Event {
    Snapshot {
        task: TaskId,
        epoch: u64,
        snap: OpSnapshot,
    },
    Ack {
        task: TaskId,
        epoch: u64,
    },
    Drained {
        task: TaskId,
        snap: OpSnapshot,
    },
    Finished {
        task: TaskId,
        cpu_ms: u64,
    },
    Failed {
        task: TaskId,
        error: String,
    },
}

What the coordinator hears from tasks.

Variants

Snapshot

A source or operator task snapshotted for epoch.

Fields

task: TaskId

epoch: u64

snap: OpSnapshot

Ack

A sink made everything before epoch’s barrier durable.

Fields

task: TaskId

epoch: u64

Drained

A source ran dry: its final position (see Source::position) — carried into every epoch completed after it, since a finished source takes no more barriers.

Fields

task: TaskId

snap: OpSnapshot

Finished

A task finished (its inputs hit Eos, the source ran dry, or the coordinator stopped it), having used cpu_ms of CPU on its thread — where the build’s cores went, by task.

Fields

task: TaskId

cpu_ms: u64

Failed

A source hit its strict data contract; it finishes right after.

Fields

task: TaskId

error: String

Trait Implementations

impl Debug for Event

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

Formats the value using the given formatter.