Enum BusMessage 

pub enum BusMessage {
    AgentReady {
        agent_id: String,
        capabilities: Vec<String>,
    },
    AgentShutdown {
        agent_id: String,
    },
    AgentMessage {
        from: String,
        to: String,
        parts: Vec<Part>,
    },
    TaskUpdate {
        task_id: String,
        state: TaskState,
        message: Option<String>,
    },
    ArtifactUpdate {
        task_id: String,
        artifact: Artifact,
    },
    SharedResult {
        key: String,
        value: Value,
        tags: Vec<String>,
    },
    ToolRequest {
        request_id: String,
        agent_id: String,
        tool_name: String,
        arguments: Value,
    },
    ToolResponse {
        request_id: String,
        agent_id: String,
        tool_name: String,
        result: String,
        success: bool,
    },
    Heartbeat {
        agent_id: String,
        status: String,
    },
}

The set of messages the bus can carry.

Variants

AgentReady

An agent has come online and is ready to receive work

Fields

agent_id: String

capabilities: Vec<String>

AgentShutdown

An agent is shutting down

Fields

agent_id: String

AgentMessage

Free-form message from one agent to another (mirrors A2A Message)

Fields

from: String

to: String

parts: Vec<Part>

TaskUpdate

Task status changed

Fields

task_id: String

state: TaskState

message: Option<String>

ArtifactUpdate

A new artifact was produced for a task

Fields

task_id: String

artifact: Artifact

SharedResult

A sub-agent published a shared result (replaces raw ResultStore publish)

Fields

key: String

value: Value

tags: Vec<String>

ToolRequest

Tool execution request (for shared tool dispatch)

Fields

request_id: String

agent_id: String

tool_name: String

arguments: Value

ToolResponse

Tool execution response

Fields

request_id: String

agent_id: String

tool_name: String

result: String

success: bool

Heartbeat

Heartbeat (keep-alive / health signal)

Fields

agent_id: String

status: String

Trait Implementations

impl Clone for BusMessage

fn clone(&self) -> BusMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BusMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BusMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BusMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.