Enum AgentEvent 

pub enum AgentEvent {
    Start {
        thread_id: ThreadId,
        turn: usize,
    },
    Thinking {
        message_id: String,
        text: String,
    },
    ThinkingDelta {
        message_id: String,
        delta: String,
    },
    TextDelta {
        message_id: String,
        delta: String,
    },
    Text {
        message_id: String,
        text: String,
    },
    ToolCallStart {
        id: String,
        name: String,
        display_name: String,
        input: Value,
        tier: ToolTier,
    },
    ToolCallEnd {
        id: String,
        name: String,
        display_name: String,
        result: ToolResult,
    },
    ToolProgress {
        id: String,
        name: String,
        display_name: String,
        stage: String,
        message: String,
        data: Option<Value>,
    },
    ToolRequiresConfirmation {
        id: String,
        name: String,
        input: Value,
        description: String,
    },
    TurnComplete {
        turn: usize,
        usage: TokenUsage,
    },
    Done {
        thread_id: ThreadId,
        total_turns: usize,
        total_usage: TokenUsage,
        duration: Duration,
    },
    Error {
        message: String,
        recoverable: bool,
    },
    Refusal {
        message_id: String,
        text: Option<String>,
    },
    ContextCompacted {
        original_count: usize,
        new_count: usize,
        original_tokens: usize,
        new_tokens: usize,
    },
    SubagentProgress {
        subagent_id: String,
        subagent_name: String,
        tool_name: String,
        tool_context: String,
        completed: bool,
        success: bool,
        tool_count: u32,
        total_tokens: u64,
    },
}

Events emitted by the agent loop during execution. These are streamed to the client for real-time UI updates.

Variants

Start

Agent loop has started

Fields

thread_id: ThreadId

turn: usize

Thinking

Agent is “thinking” - complete thinking text after stream ends

Fields

message_id: String

text: String

ThinkingDelta

A thinking delta for streaming thinking content

Fields

message_id: String

delta: String

TextDelta

A text delta for streaming responses

Fields

message_id: String

delta: String

Text

Complete text block from the agent

Fields

message_id: String

text: String

ToolCallStart

Agent is about to call a tool

Fields

id: String

name: String

display_name: String

input: Value

tier: ToolTier

ToolCallEnd

Tool execution completed

Fields

id: String

name: String

display_name: String

result: ToolResult

ToolProgress

Progress update from an async tool operation

Fields

id: String

Tool call ID

name: String

Tool name

display_name: String

Human-readable display name

stage: String

Progress stage

message: String

Human-readable progress message

data: Option<Value>

Optional tool-specific data

ToolRequiresConfirmation

Tool requires confirmation before execution. The application determines the confirmation type (normal, PIN, biometric).

Fields

id: String

name: String

input: Value

description: String

TurnComplete

Agent turn completed (one LLM round-trip)

Fields

turn: usize

usage: TokenUsage

Done

Agent loop completed successfully

Fields

thread_id: ThreadId

total_turns: usize

total_usage: TokenUsage

duration: Duration

Error

An error occurred during execution

Fields

message: String

recoverable: bool

Refusal

The model refused the request (safety/policy).

Fields

message_id: String

text: Option<String>

ContextCompacted

Context was compacted to reduce size

Fields

original_count: usize

Number of messages before compaction

new_count: usize

Number of messages after compaction

original_tokens: usize

Estimated tokens before compaction

new_tokens: usize

Estimated tokens after compaction

SubagentProgress

Progress update from a running subagent

Fields

subagent_id: String

ID of the parent tool call that spawned this subagent

subagent_name: String

Name of the subagent (e.g., “explore”, “plan”)

tool_name: String

Tool name that just started or completed

tool_context: String

Brief context for the tool (e.g., file path, pattern)

completed: bool

Whether the tool completed (false = started, true = ended)

success: bool

Whether the tool succeeded (only meaningful if completed)

tool_count: u32

Current total tool count for this subagent

total_tokens: u64

Current total tokens used by this subagent

Implementations

impl AgentEvent

pub const fn start(thread_id: ThreadId, turn: usize) -> Self

pub fn thinking(message_id: impl Into<String>, text: impl Into<String>) -> Self

pub fn thinking_delta( message_id: impl Into<String>, delta: impl Into<String>, ) -> Self

pub fn text_delta( message_id: impl Into<String>, delta: impl Into<String>, ) -> Self

pub fn text(message_id: impl Into<String>, text: impl Into<String>) -> Self

pub fn tool_call_start( id: impl Into<String>, name: impl Into<String>, display_name: impl Into<String>, input: Value, tier: ToolTier, ) -> Self

pub fn tool_call_end( id: impl Into<String>, name: impl Into<String>, display_name: impl Into<String>, result: ToolResult, ) -> Self

pub fn tool_progress( id: impl Into<String>, name: impl Into<String>, display_name: impl Into<String>, stage: impl Into<String>, message: impl Into<String>, data: Option<Value>, ) -> Self

pub const fn done( thread_id: ThreadId, total_turns: usize, total_usage: TokenUsage, duration: Duration, ) -> Self

pub fn error(message: impl Into<String>, recoverable: bool) -> Self

pub fn refusal(message_id: impl Into<String>, text: Option<String>) -> Self

pub const fn context_compacted( original_count: usize, new_count: usize, original_tokens: usize, new_tokens: usize, ) -> Self

Trait Implementations

impl Clone for AgentEvent

fn clone(&self) -> AgentEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.