Enum JobEvent 

pub enum JobEvent<T> {
    Started {
        args: T,
        job: JobRow,
    },
    WaitingForCallback {
        args: T,
        job: JobRow,
    },
    Completed {
        args: T,
        job: JobRow,
        duration: Duration,
    },
    Retried {
        args: T,
        job: JobRow,
        error: String,
        attempt: i16,
        next_run_at: DateTime<Utc>,
    },
    Exhausted {
        args: T,
        job: JobRow,
        error: String,
        attempt: i16,
    },
    Cancelled {
        args: T,
        job: JobRow,
        reason: String,
    },
    Rescued {
        args: T,
        job: JobRow,
        reason: RescueReason,
    },
}

Typed lifecycle event for a specific job argument type.

Variants

Started

Job execution started after the claim committed.

Fields

args: T

job: JobRow

WaitingForCallback

Job parked waiting for an external callback. job.callback_id and job.callback_timeout_at identify the pending callback.

Fields

args: T

job: JobRow

Completed

Job completed successfully.

For a callback-driven completion duration is Duration::ZERO, since no handler ran during the parked phase.

Fields

args: T

job: JobRow

duration: Duration

Retried

Job failed but will be retried later.

Fields

args: T

job: JobRow

error: String

attempt: i16

next_run_at: DateTime<Utc>

Exhausted

Job exhausted its retry budget and moved to failed.

Fields

args: T

job: JobRow

error: String

attempt: i16

Cancelled

Job was cancelled by the handler.

Fields

args: T

job: JobRow

reason: String

Rescued

Job was rescued by maintenance — either its callback wait expired, its heartbeat went stale (presumed crashed worker), or its deadline was exceeded. reason identifies the rescue path. The post-rescue job.state is retryable when retries remain or failed when the attempt that was rescued exhausted its retry budget.

Fields

args: T

job: JobRow

reason: RescueReason

Implementations

impl<T> JobEvent<T>

pub fn job(&self) -> &JobRow

The job snapshot associated with this event.

Trait Implementations

impl<T: Clone> Clone for JobEvent<T>

fn clone(&self) -> JobEvent<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for JobEvent<T>

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

Formats the value using the given formatter.