Struct LostWorkerReport 

pub struct LostWorkerReport {
    pub worker_id: WorkerId,
    pub tasks: Vec<InFlightActivity>,
    pub task_queue: Option<String>,
}

Tasks removed from tracking because a worker was declared lost.

Fields

worker_id: WorkerId

Lost worker removed from the connected-worker registry.

tasks: Vec<InFlightActivity>

In-flight activities swept off the tracker: surfaced to the engine as retryable failures on the fail_* paths, or parked for restart recovery (nothing recorded, nothing delivered) on the graceful-drain park_* paths (#207).

task_queue: Option<String>

Task queue the lost worker was serving, captured from the registry BEFORE deregistration (afterwards the handle is gone and the queue is unknowable). None when the worker was already absent from the registry.

This is what lets the deregistration log name the queue an operator has to act on, rather than an opaque worker id.

Trait Implementations

impl Clone for LostWorkerReport

fn clone(&self) -> LostWorkerReport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LostWorkerReport

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

Formats the value using the given formatter.

impl Eq for LostWorkerReport

impl PartialEq for LostWorkerReport

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LostWorkerReport