Struct DocketTask 

pub struct DocketTask {
    pub id: TaskId,
    pub task_type: String,
    pub params: Value,
    pub priority: i32,
    pub retry_count: u32,
    pub max_retries: u32,
    pub created_at: String,
    pub claimed_at: Option<String>,
    pub status: TaskStatus,
    pub error: Option<String>,
    pub result: Option<Value>,
}

A queued task in the Docket system.

Fields

id: TaskId

Unique task identifier.

task_type: String

Task type (determines which handler processes it).

params: Value

Task parameters.

priority: i32

Task priority (higher = processed first).

retry_count: u32

Number of retry attempts so far.

max_retries: u32

Maximum retries allowed.

created_at: String

When the task was created.

claimed_at: Option<String>

When the task was claimed by a worker.

status: TaskStatus

Current task status.

error: Option<String>

Error message if failed.

result: Option<Value>

Task result if completed.

Implementations

impl DocketTask

pub fn to_task_info(&self) -> TaskInfo

Converts to TaskInfo for protocol responses.

pub fn to_task_result(&self) -> Option<TaskResult>

Converts to TaskResult for protocol responses.

Trait Implementations

impl Clone for DocketTask

fn clone(&self) -> DocketTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DocketTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DocketTask

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DocketTask

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

where __S: Serializer,

Serialize this value into the given Serde serializer.