Struct ExecutionContext 

pub struct ExecutionContext { /* private fields */ }

Execution context of a Task

Implementations

impl ExecutionContext

pub fn task_id(&self) -> Option<&TaskId>

Returns the task’s ID, if one has been allocated.

pub fn data(&self) -> &Extensions

Returns the extensions associated with the task.

pub fn attempt(&self) -> usize

Returns the number of attempts made to execute the task.

pub fn raw_attempt(&self) -> &Attempt

Get the atomic attempt

pub fn status(&self) -> Status

Returns the current status of the task.

pub fn raw_status(&self) -> &AtomicStatus

Get the atomic status

pub fn run_at(&self) -> Option<u64>

Returns the time at which the task is scheduled to run.

Returns None if no run time has been specified.

pub fn done_at(&self) -> Option<u64>

Returns the time at which the task was completed.

Returns None if the task has not been completed.

pub fn lock_at(&self) -> Option<u64>

Returns the time at which the task was locked.

Returns None if the task is not locked.

pub fn lock_by(&self) -> Option<&str>

Returns the identifier of the worker or process currently holding the lock on this task.

Returns None if the task is not currently locked.

pub fn idempotency_key(&self) -> Option<&str>

Returns the idempotency key associated with the task.

Returns None if no idempotency key has been specified.

pub fn metadata(&self) -> &MetadataStore

Returns the metadata associated with the task.

pub fn max_attempts(&self) -> Option<usize>

Returns the maximum number of attempts allowed for the task.

Returns None if no maximum has been specified.

pub fn priority(&self) -> Option<usize>

Returns the priority of the task.

Returns None if no priority has been specified.

pub fn queue(&self) -> Option<&Queue>

Returns the queue to which the task belongs.

Returns None if the task is not associated with a queue.

pub fn runs(&self) -> &[Run]

Returns the runs recorded for this task.

Trait Implementations

impl Clone for ExecutionContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionContext

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

Formats the value using the given formatter.

impl Default for ExecutionContext

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExecutionContext

Available on crate feature serde only.

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionContext

Available on crate feature serde only.

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.