Struct JobCtx 

pub struct JobCtx {
    pub id: String,
    pub queue: String,
    pub job_type: String,
    pub priority: Priority,
    pub attempt: u32,
    pub max_attempts: u32,
    pub enqueued_at: SystemTime,
    pub scheduled_at: Option<SystemTime>,
    pub custom: HashMap<String, Primitive>,
    pub trace_context: Option<TraceContext>,
    pub lease_expires_at: SystemTime,
    /* private fields */
}

Everything about a reserved job except its payload: identity, delivery metadata, and the handle needed to manage its lease.

A handler receives this as Arc<JobCtx> alongside the payload. It also carries an internal lease handle, which is why extend can be called directly on it.

Fields

id: String

Server-assigned job id (a UUID).

queue: String

The queue this job was reserved from. Useful when a worker reserves from several queues and needs to tell which one each job came from.

job_type: String

The job type, used to route to a handler.

priority: Priority

The job’s effective priority.

attempt: u32

Which delivery attempt this is, starting at 1 and incremented on each redelivery.

max_attempts: u32

The maximum attempts before the job is dead-lettered.

enqueued_at: SystemTime

When the producer enqueued the job.

scheduled_at: Option<SystemTime>

When the producer scheduled the job to run, if it was delayed; None for a job that was available immediately.

custom: HashMap<String, Primitive>

Custom metadata the producer attached.

trace_context: Option<TraceContext>

The producer’s trace context, if any and if it was well-formed.

lease_expires_at: SystemTime

When the current lease expires. The job must be acked, nacked, or extended before this, or it will be redelivered.

Implementations

impl JobCtx

pub async fn extend( &self, extension: Duration, ) -> Result<SystemTime, LeaseError>

Extends this job’s lease by extension, measured from now, and returns the new expiry.

Use this from inside a handler that needs more time than the original lease allowed. A Worker configured with with_auto_extend does this for you.

Trait Implementations

impl Clone for JobCtx

fn clone(&self) -> JobCtx

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobCtx

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

Formats the value using the given formatter.

impl Display for JobCtx

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

Formats the value using the given formatter.