Enum AgentMessage 

pub enum AgentMessage {
    StreamChunk {
        text: String,
    },
    StreamEnd {
        finish_reason: Option<String>,
    },
    ToolCallStart {
        id: String,
        name: String,
        server: Option<String>,
        input: Value,
    },
    ToolProgress {
        name: String,
        message: String,
        progress: Option<f64>,
    },
    ToolResult {
        id: String,
        name: String,
        output: Option<String>,
        error: Option<String>,
    },
    ConversationSync {
        session_id: String,
        model: String,
        messages: Vec<DisplayMessage>,
        status: String,
        is_busy: bool,
        tool_mode: ToolMode,
        mcp_servers: Vec<String>,
    },
    MessageAdded {
        message: DisplayMessage,
    },
    StatusUpdate {
        status: String,
    },
    TaskUpdate {
        task_tree: String,
        task_count: usize,
        completed_count: usize,
    },
    Error {
        message: String,
        fatal: bool,
    },
    Exiting {
        reason: String,
    },
    Ack {
        command: String,
    },
    SlashCommandResult {
        command: String,
        success: bool,
        output: Option<String>,
        action_taken: Option<String>,
        error: Option<String>,
        blocked: bool,
    },
    Toast {
        message: String,
        duration_ms: u64,
    },
    SealStatus {
        enabled: bool,
        entity_count: usize,
        last_resolution: Option<String>,
        quality_score: f32,
    },
    LockResult {
        success: bool,
        resource_type: ResourceLockType,
        scope: String,
        error: Option<String>,
        blocking_agent: Option<String>,
    },
    LockReleased {
        resource_type: ResourceLockType,
        scope: String,
    },
    LockStatus {
        locks: Vec<LockInfo>,
    },
    LockChanged {
        change: LockChangeType,
        lock: LockInfo,
    },
    AgentSpawned {
        new_session_id: String,
        parent_session_id: String,
        spawn_reason: String,
        model: String,
    },
    AgentList {
        agents: Vec<AgentMetadata>,
    },
    AgentExiting {
        session_id: String,
        reason: String,
        children_notified: Vec<String>,
    },
    ParentSignalReceived {
        signal: ParentSignalType,
        parent_session_id: String,
    },
    PlanModeEntered {
        plan_session_id: String,
        messages: Vec<DisplayMessage>,
        status: String,
    },
    PlanModeExited {
        summary: Option<String>,
    },
    PlanModeSync {
        plan_session_id: String,
        main_session_id: String,
        messages: Vec<DisplayMessage>,
        status: String,
        is_busy: bool,
    },
    PlanModeMessageAdded {
        message: DisplayMessage,
    },
    PlanModeStreamChunk {
        text: String,
    },
    PlanModeStreamEnd {
        finish_reason: Option<String>,
    },
}

Messages sent from Agent to Viewer (TUI)

Variants

StreamChunk

Streaming text chunk from AI response

Fields

text: String

The text delta

StreamEnd

Stream completed (full response received)

Fields

finish_reason: Option<String>

Optional finish reason

ToolCallStart

Tool call started

Fields

id: String

Tool use ID

name: String

Tool name

server: Option<String>

Server name (for MCP tools)

input: Value

Tool input parameters

ToolProgress

Tool execution progress update

Fields

name: String

Tool name

message: String

Progress message

progress: Option<f64>

Progress percentage (0.0-1.0) if known

ToolResult

Tool execution completed

Fields

id: String

Tool use ID

name: String

Tool name

output: Option<String>

Result output (if successful)

error: Option<String>

Error message (if failed)

ConversationSync

Full conversation state (sent on attach or sync request)

Fields

session_id: String

Session ID

model: String

Current model name

messages: Vec<DisplayMessage>

Full conversation history (for display)

status: String

Current status message

is_busy: bool

Whether an operation is in progress

tool_mode: ToolMode

Current tool mode

mcp_servers: Vec<String>

Connected MCP servers

MessageAdded

New message added to conversation

Fields

message: DisplayMessage

The message that was added

StatusUpdate

Status update (e.g., “Working…”, “Connected to MCP server X”)

Fields

status: String

New status message

TaskUpdate

Task list update

Fields

task_tree: String

Formatted task tree for display

task_count: usize

Total task count

completed_count: usize

Completed task count

Error

Error occurred

Fields

message: String

Error message

fatal: bool

Whether this is a fatal error (agent will exit)

Exiting

Agent is exiting

Fields

reason: String

Reason for exit

Ack

Acknowledgment of viewer command

Fields

command: String

Original command type that was acknowledged

SlashCommandResult

Result of a slash command execution (for remote control)

Fields

command: String

The command that was executed (without leading /)

success: bool

Whether the command executed successfully

output: Option<String>

Output/result of the command (for Message or Help results)

action_taken: Option<String>

Description of action taken (for Action results)

error: Option<String>

Error message if command failed

blocked: bool

Whether the command was blocked by security policy

Toast

Toast notification

Fields

message: String

Message to display

duration_ms: u64

Duration in milliseconds

SealStatus

SEAL status update

Fields

enabled: bool

Whether SEAL is enabled

entity_count: usize

Entity count

last_resolution: Option<String>

Last resolution (if any)

quality_score: f32

Quality score (0.0-1.0)

LockResult

Lock acquisition result

Fields

success: bool

Whether the lock was acquired

resource_type: ResourceLockType

Resource type

scope: String

Scope

error: Option<String>

Error message if failed

blocking_agent: Option<String>

Info about blocking lock if failed

LockReleased

Lock released confirmation

Fields

resource_type: ResourceLockType

Resource type

scope: String

Scope

LockStatus

Response to QueryLocks

Fields

locks: Vec<LockInfo>

All current locks

LockChanged

Lock state changed notification (for other viewers)

Fields

change: LockChangeType

The change type

lock: LockInfo

Lock info

AgentSpawned

A new child agent was spawned

Fields

new_session_id: String

Session ID of the new agent

parent_session_id: String

Session ID of the parent that spawned it

spawn_reason: String

Reason for spawning

model: String

Model used by the new agent

AgentList

Response to ListAgents request

Fields

agents: Vec<AgentMetadata>

All active agents with their metadata

AgentExiting

An agent is exiting (sent to TUI and potentially to children)

Fields

session_id: String

Session ID of the exiting agent

reason: String

Reason for exit

children_notified: Vec<String>

Child agents that were notified

ParentSignalReceived

Signal received from parent agent

Fields

signal: ParentSignalType

The signal type

parent_session_id: String

Parent’s session ID

PlanModeEntered

Plan mode entered successfully

Fields

plan_session_id: String

Plan session ID

messages: Vec<DisplayMessage>

Display messages from plan mode

status: String

Current status

PlanModeExited

Plan mode exited

Fields

summary: Option<String>

Optional summary of the planning session

PlanModeSync

Plan mode state sync (response to PlanModeSyncRequest)

Fields

plan_session_id: String

Plan session ID

main_session_id: String

Main session ID

messages: Vec<DisplayMessage>

Display messages from plan mode

status: String

Current status

is_busy: bool

Whether an operation is in progress

PlanModeMessageAdded

New message added to plan mode conversation

Fields

message: DisplayMessage

The message that was added

PlanModeStreamChunk

Streaming text chunk in plan mode

Fields

text: String

The text delta

PlanModeStreamEnd

Plan mode stream completed

Fields

finish_reason: Option<String>

Optional finish reason

Trait Implementations

impl Clone for AgentMessage

fn clone(&self) -> AgentMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.