Struct EpochTracker 

pub struct EpochTracker { /* private fields */ }

The coordinator’s book: which tasks reported which epoch, which tasks finished. Epochs complete in order. An epoch completes when every expected task has reported it (or finished before it) — for a single-process run that is every task 0..n; for one worker of a multi- process run it is only the tasks placed on this worker (the leader aggregates across workers).

Implementations

impl EpochTracker

pub fn new(n_tasks: usize) -> Self

A tracker for a contiguous task set 0..n_tasks (the single-process run).

pub fn new_for(expected: Vec<TaskId>) -> Self

A tracker for an explicit set of task ids (one worker’s own tasks).

pub fn on_event(&mut self, e: &Event) -> Vec<Completed>

Book one event; returns the epochs it completed, in order.

pub fn all_finished(&self) -> bool

pub fn finished(&self) -> usize

pub fn cpu_ms(&self) -> &HashMap<TaskId, u64>

The CPU each finished task used on its thread, in milliseconds.

Trait Implementations

impl Debug for EpochTracker

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

Formats the value using the given formatter.