Enum AgentEvent 

pub enum AgentEvent {
    RunStarted {
        session_id: SessionId,
    },
    TurnStarted {
        session_id: SessionId,
        turn_id: TurnId,
    },
    InputAccepted {
        session_id: SessionId,
        items: Vec<Item>,
    },
    ContentDelta(Delta),
    ToolCallRequested(ToolCallPart),
    ApprovalRequired(ApprovalRequest),
    AuthRequired(AuthRequest),
    ApprovalResolved {
        approved: bool,
    },
    AuthResolved {
        provided: bool,
    },
    CompactionStarted {
        session_id: SessionId,
        turn_id: Option<TurnId>,
        reason: CompactionReason,
    },
    CompactionFinished {
        session_id: SessionId,
        turn_id: Option<TurnId>,
        replaced_items: usize,
        transcript_len: usize,
        metadata: BTreeMap<String, Value>,
    },
    UsageUpdated(Usage),
    Warning {
        message: String,
    },
    RunFailed {
        message: String,
    },
    TurnFinished(TurnResult),
}

Lifecycle and streaming events emitted by the LoopDriver.

Observers (see LoopObserver) receive these events in the order they occur. They are useful for building UIs, logging, or telemetry.

Variants

RunStarted

The agent run has been initialised.

Fields

session_id: SessionId

TurnStarted

A new model turn is starting.

Fields

session_id: SessionId

turn_id: TurnId

InputAccepted

User input has been accepted into the pending queue.

Fields

session_id: SessionId

items: Vec<Item>

ContentDelta(Delta)

Incremental content delta from the model.

ToolCallRequested(ToolCallPart)

The model has requested a tool call.

ApprovalRequired(ApprovalRequest)

A tool call requires explicit user approval before execution.

AuthRequired(AuthRequest)

A tool call requires authentication before execution.

ApprovalResolved

An approval interrupt has been resolved.

Fields

approved: bool

AuthResolved

An authentication interrupt has been resolved.

Fields

provided: bool

CompactionStarted

Transcript compaction is about to begin.

Fields

session_id: SessionId

turn_id: Option<TurnId>

reason: CompactionReason

CompactionFinished

Transcript compaction has finished.

Fields

session_id: SessionId

turn_id: Option<TurnId>

replaced_items: usize

transcript_len: usize

metadata: BTreeMap<String, Value>

UsageUpdated(Usage)

Updated token usage statistics.

Warning

Non-fatal warning (e.g. a tool failure that was recovered from).

Fields

message: String

RunFailed

The agent run has failed with an unrecoverable error.

Fields

message: String

TurnFinished(TurnResult)

A turn has finished (successfully, via cancellation, etc.).

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<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentEvent

fn deserialize<__D>( __deserializer: __D, ) -> Result<AgentEvent, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AgentEvent

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AgentEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AgentEvent