Struct TaskModel 

pub struct TaskModel {

    pub id: String,
    pub task_type: String,
    pub priority: TaskPriority,
    pub status: TaskStatus,
    pub assigned_to: Option<String>,
    pub payload: Value,
    pub result: Option<Value>,
    pub error: Option<String>,
    pub retry_count: u32,
    pub max_retries: u32,
    pub dependencies: Vec<String>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
}

Task model representing work items in the swarm

Fields

id: String

task_type: String

priority: TaskPriority

status: TaskStatus

assigned_to: Option<String>

payload: Value

result: Option<Value>

error: Option<String>

retry_count: u32

max_retries: u32

dependencies: Vec<String>

created_at: DateTime<Utc>

updated_at: DateTime<Utc>

started_at: Option<DateTime<Utc>>

completed_at: Option<DateTime<Utc>>

Implementations

impl TaskModel

pub fn new(task_type: String, payload: Value, priority: TaskPriority) -> Self

pub fn assign_to(&mut self, agent_id: &str)

pub fn start(&mut self)

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

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

Trait Implementations

impl Clone for TaskModel

fn clone(&self) -> TaskModel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskModel

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskModel

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TaskModel

fn eq(&self, other: &TaskModel) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TaskModel

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TaskModel