Struct Task 

pub struct Task {
    pub id: TaskId,
    pub name: String,
    pub task_type: TaskType,
    pub state: TaskState,
    pub priority: TaskPriority,
    pub retry: RetryPolicy,
    pub timeout: Duration,
    pub dependencies: Vec<TaskId>,
    pub metadata: HashMap<String, String>,
    pub retry_count: u32,
    pub conditions: Vec<String>,
}

Task definition.

Fields

id: TaskId

Unique task identifier.

name: String

Task name.

task_type: TaskType

Task type and configuration.

state: TaskState

Current state.

priority: TaskPriority

Task priority.

retry: RetryPolicy

Retry policy.

timeout: Duration

Execution timeout.

dependencies: Vec<TaskId>

Task dependencies.

metadata: HashMap<String, String>

Task metadata.

retry_count: u32

Number of retry attempts so far.

conditions: Vec<String>

Task conditions (must evaluate to true to run).

Implementations

impl Task

pub fn new(name: impl Into<String>, task_type: TaskType) -> Self

Create a new task.

pub fn add_dependency(&mut self, task_id: TaskId)

Add a dependency to this task.

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

Set task priority.

pub fn with_retry(self, retry: RetryPolicy) -> Self

Set retry policy.

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

Set timeout.

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add metadata.

pub fn with_condition(self, condition: impl Into<String>) -> Self

Add condition.

pub const fn can_execute(&self) -> bool

Check if task can be executed.

pub fn set_state(&mut self, state: TaskState) -> Result<()>

Update task state.

pub fn increment_retry(&mut self)

Increment retry count.

pub fn should_retry(&self) -> bool

Check if should retry.

pub fn retry_delay(&self) -> Duration

Get retry delay.

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.

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

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Task

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

where __S: Serializer,

Serialize this value into the given Serde serializer.