Struct Task 

pub struct Task {
    pub id: TaskId,
    pub name: Option<String>,
    pub priority: TaskPriority,
    pub state: TaskState,
    pub action: RtObject,
    pub dependencies: Vec<TaskId>,
    pub dependents: Vec<TaskId>,
    pub created_at: u64,
    pub completed_at: Option<u64>,
}

A task represents a unit of work to be executed.

Fields

id: TaskId

Unique task identifier.

name: Option<String>

Human-readable name (for debugging).

priority: TaskPriority

Priority.

state: TaskState

Current state.

action: RtObject

The closure to execute (represented as an RtObject).

dependencies: Vec<TaskId>

Dependencies (tasks that must complete before this one).

dependents: Vec<TaskId>

Tasks that depend on this one (notified on completion).

created_at: u64

Creation timestamp (nanoseconds).

completed_at: Option<u64>

Completion timestamp (nanoseconds).

Implementations

impl Task

pub fn new(id: TaskId, action: RtObject) -> Self

Create a new task.

pub fn named(id: TaskId, name: String, action: RtObject) -> Self

Create a named task.

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

Set the priority.

pub fn depends_on(self, dep: TaskId) -> Self

Add a dependency.

pub fn dependencies_satisfied(&self, completed: &[TaskId]) -> bool

Check if all dependencies are satisfied.

pub fn complete(&mut self, result: RtObject)

Mark as completed.

pub fn fail(&mut self, error: String)

Mark as failed.

pub fn cancel(&mut self)

Mark as cancelled.

pub fn result(&self) -> Option<&RtObject>

Get the result if completed.

pub fn error(&self) -> Option<&str>

Get the error if failed.

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 Display for Task

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

Formats the value using the given formatter.