Struct DistributedJob 

pub struct DistributedJob {
    pub id: u64,
    pub name: String,
    pub state: JobState,
    pub created_at: u64,
    pub updated_at: u64,
    pub priority: i32,
    /* private fields */
}

A single distributed encoding job with progress and ETA tracking.

Fields

id: u64

name: String

state: JobState

created_at: u64

updated_at: u64

priority: i32

Implementations

impl DistributedJob

pub fn new(id: u64, name: &str, priority: i32, now: u64) -> Self

Create a new job in the Queued state.

pub fn assign(&mut self, worker_id: u64, now: u64)

Transition to Assigned.

pub fn update_progress(&mut self, pct: f32, now: u64)

Transition to Running with the given progress percentage.

Stores a progress sample for ETA computation and sets started_at_ms on the first call.

pub fn progress_pct(&self) -> f32

Current progress as a percentage (0.0–100.0).

Returns 0.0 for jobs not yet in the Running state.

pub fn eta_ms(&self) -> Option<u64>

Estimated time to completion in milliseconds.

Uses the most recent two progress samples to compute the current encoding rate, then extrapolates to 100 %. Returns None when there are fewer than two samples, the progress is already at 100 %, or the elapsed time is zero.

pub fn complete(&mut self, output: &str, now: u64)

Transition to Completed.

pub fn fail(&mut self, error: &str, now: u64)

Transition to Failed.

pub fn cancel(&mut self, now: u64)

Transition to Cancelled.

Trait Implementations

impl Clone for DistributedJob

fn clone(&self) -> DistributedJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DistributedJob

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

Formats the value using the given formatter.