Enum SwarmMessage 

pub enum SwarmMessage {
    ExecuteTask {
        task_id: String,
        instruction: String,
    },
    Progress {
        task_id: String,
        progress: f32,
        message: String,
    },
    TaskCompleted {
        task_id: String,
        result: String,
    },
    TaskFailed {
        task_id: String,
        error: String,
    },
    ToolRequest {
        tool_id: String,
        arguments: Value,
    },
    ToolResponse {
        tool_id: String,
        result: ToolResult,
    },
}

Message types for swarm coordination

Variants

ExecuteTask

Execute a task

Fields

task_id: String

instruction: String

Progress

Report progress

Fields

task_id: String

progress: f32

message: String

TaskCompleted

Task completed

Fields

task_id: String

result: String

TaskFailed

Task failed

Fields

task_id: String

error: String

ToolRequest

Request tool execution

Fields

tool_id: String

arguments: Value

ToolResponse

Tool response

Fields

tool_id: String

result: ToolResult

Trait Implementations

impl Clone for SwarmMessage

fn clone(&self) -> SwarmMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SwarmMessage

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

Formats the value using the given formatter.

impl Handler<SwarmMessage> for Agent

Handler implementation for SwarmMessage - enables message processing

type Response = SwarmMessage

The response type for this handler

fn handle<'life0, 'async_trait>( &'life0 mut self, message: SwarmMessage, ) -> Pin<Box<dyn Future<Output = Result<Self::Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a message and return a response