Struct JobTracker 

pub struct JobTracker { /* private fields */ }

Stores and queries distributed jobs.

Implementations

impl JobTracker

pub fn new() -> Self

Create an empty tracker.

pub fn submit(&mut self, job: DistributedJob)

Add a job to the tracker.

pub fn get(&self, id: u64) -> Option<&DistributedJob>

Look up a job by ID (immutable).

pub fn get_mut(&mut self, id: u64) -> Option<&mut DistributedJob>

Look up a job by ID (mutable).

pub fn queued_jobs(&self) -> Vec<&DistributedJob>

Return all jobs currently in the Queued state.

pub fn running_jobs(&self) -> Vec<&DistributedJob>

Return all jobs currently in the Running state.

pub fn failed_jobs(&self) -> Vec<&DistributedJob>

Return all jobs currently in the Failed state.

pub fn completion_rate(&self) -> f64

Fraction of jobs that completed successfully.

Returns 0.0 when no jobs have been submitted.

pub fn total_jobs(&self) -> usize

Return the total number of tracked jobs.

Trait Implementations

impl Debug for JobTracker

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

Formats the value using the given formatter.

impl Default for JobTracker

fn default() -> JobTracker

Returns the “default value” for a type.