Enum AgentEvent 

pub enum AgentEvent {
    RunStarted {
        thread_name: Option<String>,
        prompt_preview: String,
    },
    ModelCallStarted {
        thread_name: Option<String>,
        iteration: usize,
    },
    ToolCallStarted {
        thread_name: Option<String>,
        call_id: String,
        name: String,
        args_preview: String,
        args_detail: Option<String>,
    },
    ToolCallFinished {
        thread_name: Option<String>,
        call_id: String,
        name: String,
        content_preview: String,
        content: Option<String>,
        is_error: bool,
    },
    ThreadStarted {
        name: String,
        action: String,
        source_threads: Vec<String>,
    },
    ThreadSpawned {
        name: String,
        executable: String,
        cwd: String,
        sandboxed: bool,
    },
    ThreadLog {
        name: String,
        line: String,
    },
    TerminalSnapshot {
        thread_name: Option<String>,
        terminals: Vec<TerminalInfo>,
    },
    ThreadFinished {
        name: String,
        exit_code: i32,
        timed_out: bool,
        timeout_reason: Option<String>,
    },
    AssistantMessage {
        thread_name: Option<String>,
        content: String,
    },
    Error {
        thread_name: Option<String>,
        message: String,
    },
    RunFinished {
        thread_name: Option<String>,
    },
    ModelIterationUsage {
        thread_name: Option<String>,
        iteration: usize,
        prompt_tokens: Option<u32>,
        completion_tokens: Option<u32>,
        total_tokens: Option<u32>,
        cached_tokens: Option<u32>,
        cumulative_usage: Usage,
    },
    StreamTextDelta {
        thread_name: Option<String>,
        text: Option<String>,
    },
    StreamComplete {
        thread_name: Option<String>,
    },
    GoalContinuation {
        continuation_turn: usize,
    },
    GoalTurnAccounted {
        token_delta: i64,
        time_delta_seconds: i64,
    },
    GoalErrorTransition {
        new_status: String,
        error_message: String,
    },
    LeanResumeTriggered {
        thread_name: Option<String>,
        reason: String,
    },
}

Variants

RunStarted

Fields

thread_name: Option<String>

prompt_preview: String

ModelCallStarted

Fields

thread_name: Option<String>

iteration: usize

ToolCallStarted

Fields

thread_name: Option<String>

call_id: String

name: String

args_preview: String

args_detail: Option<String>

ToolCallFinished

Fields

thread_name: Option<String>

call_id: String

name: String

content_preview: String

content: Option<String>

is_error: bool

ThreadStarted

Fields

name: String

action: String

source_threads: Vec<String>

ThreadSpawned

Fields

name: String

executable: String

cwd: String

sandboxed: bool

ThreadLog

Fields

name: String

line: String

TerminalSnapshot

Fields

thread_name: Option<String>

terminals: Vec<TerminalInfo>

ThreadFinished

Fields

name: String

exit_code: i32

timed_out: bool

timeout_reason: Option<String>

AssistantMessage

Fields

thread_name: Option<String>

content: String

Error

Fields

thread_name: Option<String>

message: String

RunFinished

Fields

thread_name: Option<String>

ModelIterationUsage

Emitted after each model iteration with per-iteration and cumulative token usage. Allows the TUI to perform incremental goal-budget accounting and inject mid-turn steering messages when the budget is exceeded.

Fields

thread_name: Option<String>

iteration: usize

prompt_tokens: Option<u32>

completion_tokens: Option<u32>

total_tokens: Option<u32>

cached_tokens: Option<u32>

cumulative_usage: Usage

Cumulative usage across all iterations in this send() so far.

StreamTextDelta

Fields

thread_name: Option<String>

text: Option<String>

StreamComplete

Fields

thread_name: Option<String>

GoalContinuation

Emitted by the agent when it auto-continues for an active goal. The agent handles continuation internally (engine-level), and this event lets the TUI track each continuation turn for display.

Fields

continuation_turn: usize

Zero-indexed continuation turn number (0 = first continuation after the initial user-submitted turn).

GoalTurnAccounted

Emitted by the agent after each inner turn within a goal-driven send to report token/time usage for that turn, so the TUI can update its goal accounting.

Fields

token_delta: i64

time_delta_seconds: i64

GoalErrorTransition

Emitted when the agent encounters a turn error during goal continuation and transitions the goal to an error state.

Fields

new_status: String

error_message: String

LeanResumeTriggered

Fields

thread_name: Option<String>

reason: String

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 Eq for AgentEvent

impl PartialEq for AgentEvent

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

Equality operator ==.

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

Inequality operator !=.

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.

impl StructuralPartialEq for AgentEvent