Struct Task

pub struct Task {
    pub id: TaskId,
    pub task_type: String,
    pub priority: TaskPriority,
    pub payload: TaskPayload,
    pub required_capabilities: Vec<String>,
    pub timeout_ms: Option<u64>,
    pub retry_count: u32,
    pub max_retries: u32,
}

Task definition

Fields

id: TaskId

Unique identifier for this task

task_type: String

Type of task (e.g., “compute”, “io”, “network”)

priority: TaskPriority

Priority level for task scheduling

payload: TaskPayload

Task data payload

required_capabilities: Vec<String>

List of capabilities required by agents to execute this task

timeout_ms: Option<u64>

Optional timeout in milliseconds for task execution

retry_count: u32

Current number of retry attempts

max_retries: u32

Maximum number of retry attempts allowed

Implementations

impl Task

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

Create a new task

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

Set task priority

pub fn with_payload(self, payload: TaskPayload) -> Self

Set task payload

pub fn require_capability(self, capability: impl Into<String>) -> Self

Add required capability

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set timeout

pub fn can_retry(&self) -> bool

Check if task can be retried

pub fn increment_retry(&mut self)

Increment retry count

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

const 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.