Struct Task 

pub struct Task<D: Clone> {
    pub task_id: TaskId,
    pub payload: D,
    pub status: TaskStatus,
    pub queued_at: SystemTime,
    pub started_at: Option<SystemTime>,
    pub finished_at: Option<SystemTime>,
    pub retries: u32,
    pub error_msg: Option<String>,
}

A Task struct represents a single unit of work that will be processed by a worker. It contains payload of type D, which is used by the worker during processing. The Task struct also includes fields for managing the task’s lifecycle, including the task’s UUID, the start and finish times, the number of retries, and any error messages.

Fields

task_id: TaskId

payload: D

status: TaskStatus

queued_at: SystemTime

started_at: Option<SystemTime>

finished_at: Option<SystemTime>

retries: u32

error_msg: Option<String>

Implementations

impl<D: Clone> Task<D>

pub fn new(payload: D) -> Self

pub fn set_in_progress(&mut self)

pub fn set_succeed(&mut self)

pub fn set_retry(&mut self, err_msg: &str)

pub fn set_dlq(&mut self, err_msg: &str)

pub fn set_status(&mut self, new_status: TaskStatus)

pub fn get_payload(&self) -> &D

Trait Implementations

impl<D: Clone + Clone> Clone for Task<D>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D: Debug + Clone> Debug for Task<D>

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

Formats the value using the given formatter.

impl<'de, D> Deserialize<'de> for Task<D>

where D: Deserialize<'de> + Clone,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<D> Serialize for Task<D>

where D: Serialize + Clone,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.