Struct Task

pub struct Task<D> {
    pub task_id: Uuid,
    pub data: D,
    pub started: DateTime<Utc>,
    pub finished: Option<DateTime<Utc>>,
    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 data 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: Uuid

data: D

started: DateTime<Utc>

finished: Option<DateTime<Utc>>

retries: u32

error_msg: Option<String>

Implementations

impl<D> Task<D>

pub fn new(task_data: D) -> Self

Trait Implementations

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

fn clone(&self) -> Task<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D: Debug> 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>,

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,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.