Struct LiveJobOutcome 

pub struct LiveJobOutcome {
    pub local_job_id: String,
    pub remote_job_id: Option<RemoteBuildId>,
    pub selected_worker: Option<String>,
    pub slots: u32,
    pub kind: JobKind,
    pub disposition: LiveDisposition,
    pub queued: bool,
    pub queue_wait_ms: u64,
    pub runtime_ms: u64,
    pub queue_depth: Option<u32>,
}

One observed REAL canary outcome from a live --load self-test run.

The consumer populates one of these per concurrent canary build it launched, recording how the build actually resolved (which worker the daemon selected, the remote build id it was assigned, whether it queued/fell back/was refused/cancelled, and the measured timings).

Fields

local_job_id: String

Local wrapper id (rchw-…) the hook minted for this job.

remote_job_id: Option<RemoteBuildId>

Remote build id the daemon assigned once admitted; None if the job never reached a worker.

selected_worker: Option<String>

The worker the scheduler selected; None for fallback/refusal/cancel.

slots: u32

Slots the job requested (for slot-utilization accounting).

kind: JobKind

Command kind (only affects the redacted command fingerprint).

disposition: LiveDisposition

How the job actually resolved.

queued: bool

Whether the job spent time in the queue before resolving (drives an intermediate queued event carrying attach/cancel guidance).

queue_wait_ms: u64

Measured queue wait, milliseconds.

runtime_ms: u64

Measured remote/local runtime, milliseconds.

queue_depth: Option<u32>

Queue depth observed when the job resolved, if known.

Implementations

impl LiveJobOutcome

pub fn remote( local_job_id: impl Into<String>, worker: impl Into<String>, remote_id: RemoteBuildId, slots: u32, runtime_ms: u64, ) -> Self

A remote-success outcome: admitted to worker with remote_id, ran for runtime_ms.

pub fn local_fallback( local_job_id: impl Into<String>, slots: u32, runtime_ms: u64, ) -> Self

A local-fallback outcome: no remote capacity, ran locally for runtime_ms.

pub fn with_kind(self, kind: JobKind) -> Self

Override the command kind.

pub fn queued_for(self, wait_ms: u64, depth: Option<u32>) -> Self

Mark the job as having queued, with the measured wait and depth.

pub fn with_disposition(self, disposition: LiveDisposition) -> Self

Override the disposition (for fallback/refusal/cancel outcomes).

Trait Implementations

impl Clone for LiveJobOutcome

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LiveJobOutcome

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

Formats the value using the given formatter.

impl PartialEq for LiveJobOutcome

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for LiveJobOutcome