Struct Task 

pub struct Task {
    pub id: String,
    pub name: String,
    pub payload: Vec<u8>,
    pub priority: TaskPriority,
    pub timeout: Option<Duration>,
    pub dependencies: Vec<String>,
    pub retry_count: usize,
    pub maxretries: usize,
    pub created_at: Instant,
    pub status: TaskStatus,
}

Task definition for orchestration

Fields

id: String

name: String

payload: Vec<u8>

priority: TaskPriority

timeout: Option<Duration>

dependencies: Vec<String>

retry_count: usize

maxretries: usize

created_at: Instant

status: TaskStatus

Implementations

impl Task

pub fn new(id: String, name: String, payload: Vec<u8>) -> Self

Create a new task

pub fn with_priority(self, priority: TaskPriority) -> Self

Set task priority

pub fn with_timeout(self, timeout: Duration) -> Self

Set task timeout

pub fn with_dependencies(self, dependencies: Vec<String>) -> Self

Add task dependencies

pub fn retries(self, maxretries: usize) -> Self

Set maximum retry count

pub fn can_retry(&self) -> bool

Check if task can be retried

pub fn increment_retry(&mut self)

Increment retry count

pub fn has_timed_out(&self) -> bool

Check if task has timed out

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.