Struct WorkerContext

pub struct WorkerContext {
    pub config: WorkerConfig,
    pub started_at: DateTime<Utc>,
    pub execution_metadata: HashMap<String, String>,
    pub attempt: u32,
    pub previous_exception: Option<String>,
}

Context information provided to workers during job execution

Fields

config: WorkerConfig

Worker configuration

started_at: DateTime<Utc>

When the job execution started

execution_metadata: HashMap<String, String>

Metadata for the current execution

attempt: u32

Attempt number (for retries)

previous_exception: Option<String>

Previous exception if this is a retry

Implementations

impl WorkerContext

pub fn new(config: WorkerConfig) -> Self

Create a new worker context

pub fn retry_from( config: WorkerConfig, attempt: u32, previous_exception: Option<String>, ) -> Self

Create a retry context from a previous attempt

pub fn add_metadata(&mut self, key: impl Into<String>, value: impl Into<String>)

Add execution metadata

pub fn duration(&self) -> Duration

Get execution duration so far

pub fn is_timed_out(&self) -> bool

Check if the job has timed out

pub fn is_retry(&self) -> bool

Check if this is a retry attempt

Trait Implementations

impl Clone for WorkerContext

fn clone(&self) -> WorkerContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerContext

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

Formats the value using the given formatter.