Enum AgentEvent 

#[non_exhaustive]
pub enum AgentEvent {
    AgentStart,
    AgentEnd {
        messages: Vec<AgentMessage>,
    },
    TurnStart,
    TurnEnd {
        message: AgentMessage,
        tool_results: Vec<ToolResultMessage>,
    },
    MessageStart {
        message: AgentMessage,
    },
    MessageUpdate {
        message: AgentMessage,
        assistant_event: Box<AssistantStreamEvent>,
    },
    MessageEnd {
        message: AgentMessage,
    },
    ToolExecutionStart {
        tool_call_id: String,
        tool_name: String,
        args: Value,
    },
    ToolExecutionUpdate {
        tool_call_id: String,
        tool_name: String,
        args: Value,
        partial_result: Value,
    },
    ToolExecutionEnd {
        tool_call_id: String,
        tool_name: String,
        result: Value,
        details: Option<Value>,
        is_error: bool,
    },
    QueueUpdate {
        steering: Vec<String>,
        follow_up: Vec<String>,
    },
    AutoRetryStart {
        attempt: u32,
        max_attempts: u32,
        delay_ms: u64,
        error_message: String,
    },
    AutoRetryEnd {
        success: bool,
        attempt: u32,
        final_error: Option<String>,
    },
    CompactionStart {
        reason: CompactionReason,
    },
    CompactionEnd {
        reason: CompactionReason,
        result: Option<CompactionResult>,
        aborted: bool,
        error_message: Option<String>,
    },
    SessionPersistError {
        message: String,
    },
}

Events emitted during the agent loop lifecycle.

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

The agent loop has started.

AgentEnd

The agent loop has ended. No more loop events will be emitted.

Fields

messages: Vec<AgentMessage>

TurnStart

A new turn (provider request/response cycle) has started.

TurnEnd

A turn has ended with the assistant message and any tool results.

Fields

message: AgentMessage

tool_results: Vec<ToolResultMessage>

MessageStart

An assistant message has started streaming.

Fields

message: AgentMessage

MessageUpdate

An assistant message has been updated with a stream event.

Fields

message: AgentMessage

assistant_event: Box<AssistantStreamEvent>

MessageEnd

An assistant message has finished streaming.

Fields

message: AgentMessage

ToolExecutionStart

Tool execution is about to begin.

Fields

tool_call_id: String

tool_name: String

args: Value

ToolExecutionUpdate

Tool execution has produced a progress update.

Fields

tool_call_id: String

tool_name: String

args: Value

partial_result: Value

ToolExecutionEnd

Tool execution has completed.

Fields

tool_call_id: String

tool_name: String

result: Value

details: Option<Value>

is_error: bool

QueueUpdate

Queue messages were delivered to the conversation.

Fields

steering: Vec<String>

follow_up: Vec<String>

AutoRetryStart

A retryable provider error occurred; a retry attempt is starting.

Fields

attempt: u32

max_attempts: u32

delay_ms: u64

error_message: String

AutoRetryEnd

A retry attempt concluded (either successfully or after exhausting attempts).

Fields

success: bool

attempt: u32

final_error: Option<String>

CompactionStart

Compaction has started. Emitted by the harness outside the agent loop.

Fields

reason: CompactionReason

CompactionEnd

Compaction has finished. Emitted by the harness outside the agent loop.

Fields

reason: CompactionReason

result: Option<CompactionResult>

aborted: bool

error_message: Option<String>

SessionPersistError

Session persistence failed (disk full, permissions, etc.).

Fields

message: 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 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.