Enum AgentEvent 

#[non_exhaustive]
pub enum AgentEvent {
    AgentStart {
        prompts: Vec<Message>,
        session_id: Option<String>,
    },
    AgentEnd {
        messages: Vec<Message>,
        stop_reason: Option<String>,
        session_id: Option<String>,
    },
    TurnStart {
        turn_number: u32,
    },
    TurnEnd {
        turn_number: u32,
        assistant_message: Message,
        tool_results: Vec<ToolResultMessage>,
    },
    MessageStart {
        message: Message,
    },
    MessageUpdate {
        message: Message,
        delta: Option<String>,
    },
    MessageEnd {
        message: Message,
    },
    ToolExecutionStart {
        tool_call_id: String,
        tool_name: String,
        args: Value,
    },
    ToolExecutionUpdate {
        tool_call_id: String,
        tool_name: String,
        partial_result: String,
    },
    ToolExecutionEnd {
        tool_call_id: String,
        tool_name: String,
        result: ToolResult,
        is_error: bool,
    },
    Start {
        prompt: String,
    },
    Thinking,
    ThinkingDelta {
        text: String,
    },
    TextChunk {
        text: String,
    },
    ToolCall {
        tool_call: ToolCall,
    },
    ToolStart {
        tool_call_id: String,
        tool_name: String,
        arguments: Value,
    },
    ToolProgress {
        tool_call_id: String,
        message: String,
    },
    ToolComplete {
        result: ToolResult,
    },
    ToolError {
        tool_call_id: String,
        error: String,
    },
    Complete {
        content: String,
        stop_reason: String,
    },
    Error {
        message: String,
        session_id: Option<String>,
    },
    Iteration {
        number: usize,
    },
    Usage {
        input_tokens: usize,
        output_tokens: usize,
    },
    Compaction {
        event: CompactionEvent,
    },
    Retry {
        attempt: usize,
        max_retries: usize,
        retry_after_secs: u64,
        reason: String,
        session_id: Option<String>,
    },
    Fallback {
        from_model: String,
        to_model: String,
    },
    Cancelled,
    PartialResponse {
        content: String,
    },
    AutoRetryStart {
        attempt: usize,
        max_attempts: usize,
        delay_ms: u64,
        error_message: String,
    },
    AutoRetryEnd {
        success: bool,
        attempt: usize,
        final_error: Option<String>,
    },
    SteeringMessage {
        message: Message,
    },
    FollowUpMessage {
        message: Message,
    },
}

Events emitted during agent execution.

Events are tagged with type and serialized as camelCase for JSON consumers. This enum is #[non_exhaustive] — new variants may be added in future releases.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

AgentStart

Emitted when the agent begins processing a batch of prompts.

Fields

prompts: Vec<Message>

The initial prompt messages sent to the agent.

session_id: Option<String>

Optional session identifier for correlation.

AgentEnd

Emitted when the agent finishes all processing.

Fields

messages: Vec<Message>

Final conversation messages.

stop_reason: Option<String>

Why the agent stopped (e.g. "end_turn", "tool_use").

session_id: Option<String>

Optional session identifier for correlation.

TurnStart

Emitted at the start of each agent loop turn.

Fields

turn_number: u32

Zero-based turn index.

TurnEnd

Emitted when a turn completes, including the assistant reply and tool results.

Fields

turn_number: u32

Turn index that just completed.

assistant_message: Message

The assistant message produced this turn.

tool_results: Vec<ToolResultMessage>

Tool results collected during this turn.

MessageStart

A new message has been created in the conversation.

Fields

message: Message

The message that started.

MessageUpdate

A message has been updated with new content.

Fields

message: Message

The message in its current state.

delta: Option<String>

Incremental text delta since the last update, if available.

MessageEnd

A message has been finalized.

Fields

message: Message

The completed message.

ToolExecutionStart

A tool is about to be executed.

Fields

tool_call_id: String

Unique identifier for this tool call.

tool_name: String

Name of the tool being invoked.

args: Value

JSON arguments passed to the tool.

ToolExecutionUpdate

Partial progress from a running tool execution.

Fields

tool_call_id: String

Identifier of the tool call producing the update.

tool_name: String

Name of the tool.

partial_result: String

Partial result text so far.

ToolExecutionEnd

A tool execution has finished.

Fields

tool_call_id: String

Identifier of the completed tool call.

tool_name: String

Name of the tool.

result: ToolResult

The tool result payload.

is_error: bool

Whether the tool execution resulted in an error.

Start

Legacy: agent started processing a prompt.

Fields

prompt: String

The user prompt that triggered the run.

Thinking

Agent is waiting for the first response token.

ThinkingDelta

Incremental thinking / reasoning text from the model.

Fields

text: String

The reasoning text delta.

TextChunk

A chunk of generated text from the model.

Fields

text: String

The text delta to append.

ToolCall

The model requested a tool call.

Fields

tool_call: ToolCall

The tool call descriptor from the provider.

ToolStart

A tool execution has started.

Fields

tool_call_id: String

Identifier of the tool call.

tool_name: String

Name of the tool being invoked.

arguments: Value

JSON arguments for the tool call.

ToolProgress

Progress update from a running tool.

Fields

tool_call_id: String

Identifier of the tool call.

message: String

Human-readable progress message.

ToolComplete

A tool execution has completed.

Fields

result: ToolResult

The tool result payload.

ToolError

A tool execution failed.

Fields

tool_call_id: String

Identifier of the failed tool call.

error: String

Error description.

Complete

The agent produced a final response.

Fields

content: String

Full response text.

stop_reason: String

Stop reason string (e.g. "EndTurn").

Error

An error occurred during agent execution.

Fields

message: String

Human-readable error message.

session_id: Option<String>

Optional session identifier.

Iteration

Agent loop iteration counter update.

Fields

number: usize

Current iteration number.

Usage

Token usage report for a completed turn.

Fields

input_tokens: usize

Number of prompt / input tokens consumed.

output_tokens: usize

Number of completion / output tokens produced.

Compaction

Context compaction lifecycle event.

Fields

event: CompactionEvent

The underlying compaction event detail.

Retry

The agent is retrying after a transient error.

Fields

attempt: usize

Current retry attempt (1-based).

max_retries: usize

Maximum number of retries allowed.

retry_after_secs: u64

Seconds until the next attempt.

reason: String

Why the previous attempt failed.

session_id: Option<String>

Optional session identifier.

Fallback

The agent switched to a fallback model.

Fields

from_model: String

Model that was being used before the failure.

to_model: String

Fallback model that will be used instead.

Cancelled

The agent run was cancelled by the caller.

PartialResponse

A partial response delivered mid-stream (useful for UI rendering).

Fields

content: String

Accumulated response content so far.

AutoRetryStart

An automatic retry attempt is starting.

Fields

attempt: usize

Current retry attempt (1-based).

max_attempts: usize

Total retry attempts that will be made.

delay_ms: u64

Milliseconds before this attempt is sent.

error_message: String

The error that triggered the retry.

AutoRetryEnd

An automatic retry attempt has concluded.

Fields

success: bool

Whether the retry succeeded.

attempt: usize

Which attempt this was (1-based).

final_error: Option<String>

Final error if the retry failed, None on success.

SteeringMessage

A system-level steering message injected into the conversation.

Fields

message: Message

The steering message to add to the context.

FollowUpMessage

A follow-up message appended to continue the conversation.

Fields

message: Message

The follow-up message.

Implementations

impl AgentEvent

pub fn is_terminal(&self) -> bool

Returns true if this event represents the end of the agent lifecycle.

pub fn type_name(&self) -> &'static str

Returns the snake_case variant name of this event (useful for logging / serialization).

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.