Struct JobContext 

pub struct JobContext { /* private fields */ }

What a job can reach while it runs.

Implementations

impl JobContext

pub fn new( container: Arc<Container>, id: impl Into<String>, queue: impl Into<String>, attempt: u32, max_attempts: u32, ) -> Self

Build a context.

pub fn container(&self) -> &Arc<Container>

The service container, for resolving whatever the job needs.

A job cannot capture its dependencies — it was serialised — so it resolves them here instead.

pub fn resolve<T: Send + Sync + 'static>(&self) -> Result<Arc<T>>

Resolve a service.

pub fn attempt(&self) -> u32

Which attempt this is, starting at 1.

pub fn max_attempts(&self) -> u32

How many attempts the job gets in total.

pub fn is_last_attempt(&self) -> bool

Whether this is the last attempt — a job that wants to record a permanent failure can check this before returning Err.

pub fn id(&self) -> &str

The queued job’s id.

pub fn queue(&self) -> &str

The queue it came from.

Trait Implementations

impl Debug for JobContext

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

Formats the value using the given formatter.