Struct JobSummary 

pub struct JobSummary {

    pub id: String,
    pub kind: String,
    pub queue: String,
    pub state: String,
    pub schema_version: u32,
    pub priority: i32,
    pub attempt: u32,
    pub crash_attempt: u32,
    pub max_attempts: u32,
    pub partition_key: String,
    pub rate_class: String,
    pub sticky_worker: String,
    pub weight: u32,
    pub fingerprint: String,
    pub enqueued_at_ms: i64,
    pub scheduled_at_ms: i64,
    pub claimed_at_ms: Option<i64>,
    pub periodic_schedule_id: String,
    pub periodic_tick_ms: i64,
    pub finalized_at_ms: Option<i64>,
    pub payload: Option<Vec<u8>>,
    pub headers: BTreeMap<String, String>,
    pub errors_json: String,
    pub tags: Vec<String>,
}

Fields

id: String

kind: String

queue: String

state: String

schema_version: u32

priority: i32

attempt: u32

crash_attempt: u32

max_attempts: u32

partition_key: String

rate_class: String

sticky_worker: String

weight: u32

fingerprint: String

enqueued_at_ms: i64

scheduled_at_ms: i64

claimed_at_ms: Option<i64>

Store-stamped start of the active attempt. Absent once no lease is active.

periodic_schedule_id: String

periodic_tick_ms: i64

finalized_at_ms: Option<i64>

payload: Option<Vec<u8>>

Invariant 9: None unless the caller explicitly asked. Payloads carry PII and the console mounts at /admin.

headers: BTreeMap<String, String>

Opaque producer metadata. Kept out of list responses with the payload and returned only for an explicitly requested detail read.

errors_json: String

The per-attempt error history, as the JSON the store keeps (attempt-log contract timeline).

tags: Vec<String>

Implementations

impl JobSummary

pub fn is_orphaned(&self) -> bool

True once the store has reclaimed this job from an expired worker lease. This is durable provenance derived from crash_attempt, not a second state.

Trait Implementations

impl Clone for JobSummary

fn clone(&self) -> JobSummary

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobSummary

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

Formats the value using the given formatter.