Enum AgentSessionEvent 

pub enum AgentSessionEvent {
    AgentStart,
    AgentEnd {
        messages: Vec<AgentMessage>,
        will_retry: bool,
    },
    AgentSettled {
        aborted: bool,
    },
    TurnStart,
    TurnEnd {
        message: AgentMessage,
        tool_results: Vec<ToolResultMessage>,
    },
    MessageStart {
        message: AgentMessage,
    },
    MessageUpdate {
        message: AgentMessage,
        assistant_message_event: AssistantMessageEvent,
    },
    MessageEnd {
        message: AgentMessage,
    },
    ToolExecutionStart {
        tool_call_id: String,
        tool_name: String,
        args: JsonObject,
        parent_tool_call_id: Option<String>,
    },
    ToolExecutionUpdate {
        tool_call_id: String,
        tool_name: String,
        args: JsonObject,
        partial_result: AgentToolResult,
        parent_tool_call_id: Option<String>,
    },
    ToolExecutionEnd {
        tool_call_id: String,
        tool_name: String,
        result: AgentToolResult,
        is_error: bool,
        duration_ms: Option<u64>,
        parent_tool_call_id: Option<String>,
    },
    QueueUpdate {
        steering: Vec<String>,
        follow_up: Vec<String>,
    },
    CompactionStart {
        reason: CompactionReason,
    },
    CompactionEnd {
        reason: CompactionReason,
        result: Option<CompactionResult>,
        aborted: bool,
        will_retry: bool,
        error_message: Option<String>,
    },
    EntryAppended {
        entry: SessionEntry,
    },
    SessionInfoChanged {
        name: Option<String>,
    },
    ThinkingLevelChanged {
        level: ThinkingLevel,
    },
    AutoRetryStart {
        attempt: u32,
        max_attempts: u32,
        delay_ms: u64,
        error_message: String,
    },
    AutoRetryEnd {
        success: bool,
        attempt: u32,
        final_error: Option<String>,
    },
    SummarizationRetryScheduled {
        attempt: u32,
        max_attempts: u32,
        delay_ms: u64,
        error_message: String,
    },
    SummarizationRetryAttemptStart {
        source: SummarizationSource,
    },
    SummarizationRetryFinished,
    BashExecutionUpdate {
        id: Option<String>,
        delta: String,
    },
}

One event emitted by an agent session.

Variants

AgentStart

A run started.

AgentEnd

A run ended.

Fields

messages: Vec<AgentMessage>

Messages the run added.

will_retry: bool

An automatic retry follows.

AgentSettled

The session became idle after activity.

Fields

aborted: bool

The activity was aborted.

TurnStart

A turn started.

TurnEnd

A turn ended.

Fields

message: AgentMessage

Assistant message of the turn.

tool_results: Vec<ToolResultMessage>

Tool results (serialised with role).

MessageStart

A message started.

Fields

message: AgentMessage

The message.

MessageUpdate

The streaming message changed.

Fields

message: AgentMessage

Partial message.

assistant_message_event: AssistantMessageEvent

Provider event.

MessageEnd

A message is final.

Fields

message: AgentMessage

The message.

ToolExecutionStart

A tool call started.

Fields

tool_call_id: String

Tool-call id.

tool_name: String

Tool name.

args: JsonObject

Arguments.

parent_tool_call_id: Option<String>

Calling tool for nested calls.

ToolExecutionUpdate

A tool published a partial result.

Fields

tool_call_id: String

Tool-call id.

tool_name: String

Tool name.

args: JsonObject

Arguments.

partial_result: AgentToolResult

Partial result.

parent_tool_call_id: Option<String>

Calling tool for nested calls.

ToolExecutionEnd

A tool call settled.

Fields

tool_call_id: String

Tool-call id.

tool_name: String

Tool name.

result: AgentToolResult

Result.

is_error: bool

Error flag.

duration_ms: Option<u64>

Wall time.

parent_tool_call_id: Option<String>

Calling tool for nested calls.

QueueUpdate

Complete steering / follow-up queues.

Fields

steering: Vec<String>

Steering texts.

follow_up: Vec<String>

Follow-up texts.

CompactionStart

Compaction started.

Fields

reason: CompactionReason

Trigger.

CompactionEnd

Compaction finished.

Fields

reason: CompactionReason

Trigger.

result: Option<CompactionResult>

Result (absent on failure).

aborted: bool

Cancelled.

will_retry: bool

The interrupted turn is retried.

error_message: Option<String>

Failure text.

EntryAppended

An extension appended an entry.

Fields

entry: SessionEntry

The entry.

SessionInfoChanged

The session name changed (absent = cleared).

Fields

name: Option<String>

New name.

ThinkingLevelChanged

The thinking level changed.

Fields

level: ThinkingLevel

New level.

AutoRetryStart

An automatic retry is scheduled.

Fields

attempt: u32

Attempt number (1-based).

max_attempts: u32

Retry budget.

delay_ms: u64

Backoff delay.

error_message: String

Error that triggered the retry.

AutoRetryEnd

Automatic retries ended.

Fields

success: bool

A retry succeeded.

attempt: u32

Last attempt number.

final_error: Option<String>

Final error.

SummarizationRetryScheduled

A summarisation retry is scheduled.

Fields

attempt: u32

Attempt number.

max_attempts: u32

Retry budget.

delay_ms: u64

Backoff delay.

error_message: String

Error that triggered the retry.

SummarizationRetryAttemptStart

A summarisation retry attempt started.

Fields

source: SummarizationSource

What is being summarised.

SummarizationRetryFinished

Summarisation retries ended.

BashExecutionUpdate

Streaming output of a ! command.

Fields

id: Option<String>

Caller-supplied id.

delta: String

Appended output.

Implementations

impl AgentSessionEvent

pub fn from_agent(event: AgentEvent, will_retry: bool) -> Self

Maps a loop event to its session event (agent_end needs will_retry).

Trait Implementations

impl Clone for AgentSessionEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentSessionEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentSessionEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<AgentSessionEvent> for ClientEvent

fn from(event: AgentSessionEvent) -> Self

Converts to this type from the input type.

impl PartialEq for AgentSessionEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for AgentSessionEvent

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 AgentSessionEvent