Enum AgentEventType 

pub enum AgentEventType {
    DiagnosticLog {
        message: String,
    },
    RunStarted {},
    RunFinished {
        success: bool,
        total_steps: usize,
        failed_steps: usize,
        usage: Option<RunUsage>,
        context_budget: Option<ContextBudget>,
    },
    RunError {
        message: String,
        code: Option<String>,
        usage: Option<RunUsage>,
    },
    PlanStarted {
        initial_plan: bool,
    },
    PlanFinished {
        total_steps: usize,
    },
    PlanPruned {
        removed_steps: Vec<String>,
    },
    StepStarted {
        step_id: String,
        step_index: usize,
    },
    StepCompleted {
        step_id: String,
        success: bool,
        context_budget: Option<ContextBudget>,
        usage: Option<RunUsage>,
    },
    ReflectStarted {},
    ReflectFinished {
        should_retry: bool,
        reason: Option<String>,
    },
    ToolExecutionStart {
        step_id: String,
        tool_call_id: String,
        tool_call_name: String,
        input: Value,
    },
    ToolExecutionEnd {
        step_id: String,
        tool_call_id: String,
        tool_call_name: String,
        success: bool,
    },
    TextMessageStart {
        message_id: String,
        step_id: String,
        role: MessageRole,
        is_final: Option<bool>,
    },
    TextMessageContent {
        message_id: String,
        step_id: String,
        delta: String,
        stripped_content: Option<Vec<(usize, String)>>,
    },
    TextMessageEnd {
        message_id: String,
        step_id: String,
    },
    ToolCalls {
        step_id: String,
        parent_message_id: Option<String>,
        tool_calls: Vec<ToolCall>,
    },
    ToolResults {
        step_id: String,
        parent_message_id: Option<String>,
        results: Vec<ToolResponse>,
    },
    AgentHandover {
        from_agent: String,
        to_agent: String,
        reason: Option<String>,
    },
    LiveView {
        view_id: String,
        url: String,
        title: Option<String>,
        display_mode: Option<String>,
        width: Option<u32>,
        height: Option<u32>,
    },
    BrowserSessionStarted {
        session_id: String,
        viewer_url: Option<String>,
        stream_url: Option<String>,
    },
    InlineHookRequested {
        request: InlineHookRequest,
    },
    TodosUpdated {
        formatted_todos: String,
        action: String,
        todo_count: usize,
        changes: Vec<TodoChange>,
    },
    ContextCompaction {
        tier: CompactionTier,
        tokens_before: usize,
        tokens_after: usize,
        entries_affected: usize,
        context_limit: usize,
        usage_ratio: f64,
        summary: Option<String>,
        reinjected_skills: Vec<String>,
        context_budget: Option<ContextBudget>,
    },
    ContextBudgetUpdate {
        budget: ContextBudget,
        is_warning: bool,
        is_critical: bool,
    },
    ChannelReply {
        reply: ChannelReply,
    },
}

Variants

DiagnosticLog

Verbose diagnostic message streamed from server to client (only emitted when verbose=true).

Fields

message: String

RunStarted

RunFinished

Fields

success: bool

total_steps: usize

failed_steps: usize

usage: Option<RunUsage>

Token usage for this run

context_budget: Option<ContextBudget>

RunError

Fields

message: String

code: Option<String>

usage: Option<RunUsage>

Cumulative token usage at the point of failure

PlanStarted

Fields

initial_plan: bool

PlanFinished

Fields

total_steps: usize

PlanPruned

Fields

removed_steps: Vec<String>

StepStarted

Fields

step_id: String

step_index: usize

StepCompleted

Fields

step_id: String

success: bool

context_budget: Option<ContextBudget>

usage: Option<RunUsage>

Cumulative token usage for this run up to this step

ReflectStarted

ReflectFinished

Fields

should_retry: bool

reason: Option<String>

ToolExecutionStart

Fields

step_id: String

tool_call_id: String

tool_call_name: String

input: Value

ToolExecutionEnd

Fields

step_id: String

tool_call_id: String

tool_call_name: String

success: bool

TextMessageStart

Fields

message_id: String

step_id: String

role: MessageRole

is_final: Option<bool>

TextMessageContent

Fields

message_id: String

step_id: String

delta: String

stripped_content: Option<Vec<(usize, String)>>

TextMessageEnd

Fields

message_id: String

step_id: String

ToolCalls

Fields

step_id: String

parent_message_id: Option<String>

tool_calls: Vec<ToolCall>

ToolResults

Fields

step_id: String

parent_message_id: Option<String>

results: Vec<ToolResponse>

AgentHandover

Fields

from_agent: String

to_agent: String

reason: Option<String>

LiveView

A live, embeddable view produced by a tool (e.g. browsr viewer, Grafana dashboard, map widget). The channel renders it inline as an iframe (web) or as a clickable link (Telegram, WhatsApp, CLI).

Fields

view_id: String

Unique ID for this view — used for updates and teardown

url: String

URL to embed or link (must be https:// for iframe security)

title: Option<String>

Human-readable title for the view

display_mode: Option<String>

Display mode hint: “inline”, “fullscreen”, or “pip”

width: Option<u32>

Width hint in pixels

height: Option<u32>

Height hint in pixels

BrowserSessionStarted

Fields

session_id: String

viewer_url: Option<String>

stream_url: Option<String>

InlineHookRequested

Fields

request: InlineHookRequest

TodosUpdated

Fields

formatted_todos: String

action: String

todo_count: usize

changes: Vec<TodoChange>

Per-call diff: which items got added, had their status changed, or were removed. Empty when the renderer can’t or didn’t compute it (e.g. the very first write_todos call has no prior list to diff against — every item is Added). Renderers should prefer rendering this list when non-empty and fall back to formatted_todos.

ContextCompaction

Fields

tier: CompactionTier

tokens_before: usize

tokens_after: usize

entries_affected: usize

context_limit: usize

usage_ratio: f64

summary: Option<String>

reinjected_skills: Vec<String>

Skill IDs re-injected after compaction

context_budget: Option<ContextBudget>

ContextBudgetUpdate

Emitted each turn with the current context budget breakdown.

Fields

budget: ContextBudget

is_warning: bool

is_critical: bool

ChannelReply

A structured channel reply emitted by a workflow StepKind::Reply step. The gateway renders it per channel; non-channel consumers (CLI, web) render reply.text and ignore buttons they can’t show.

Fields

reply: ChannelReply

Trait Implementations

impl Clone for AgentEventType

fn clone(&self) -> AgentEventType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentEventType

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentEventType

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentEventType

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

where __S: Serializer,

Serialize this value into the given Serde serializer.