Enum JobEvent 

pub enum JobEvent<T> {
    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,
    },
}

Typed lifecycle event for a specific job argument type.

Variants

Completed

Job completed successfully.

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

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.