Struct TaskContext 

pub struct TaskContext {
    pub task_id: TaskId,
    pub instance_id: InstanceId,
    pub scheduled_at: DateTime<Utc>,
    pub attempt: u32,
    /* private fields */
}

Execution context passed to task handlers.

Fields

task_id: TaskId

Task ID.

instance_id: InstanceId

Instance ID.

scheduled_at: DateTime<Utc>

Scheduled execution time.

attempt: u32

Current attempt number.

Implementations

impl TaskContext

pub fn new( task_id: TaskId, instance_id: InstanceId, scheduled_at: DateTime<Utc>, attempt: u32, payload: Bytes, ) -> Self

Create a new task context.

pub fn payload_bytes(&self) -> &Bytes

Get the raw payload bytes.

pub fn payload<T: DeserializeOwned>(&self) -> Result<T, Error>

Deserialize the payload.

Trait Implementations

impl Clone for TaskContext

fn clone(&self) -> TaskContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskContext

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

Formats the value using the given formatter.