Enum AgentEvent 

pub enum AgentEvent {
    RunStart {
        thread_id: String,
        run_id: String,
        parent_run_id: Option<String>,
    },
    RunFinish {
        thread_id: String,
        run_id: String,
        result: Option<Value>,
        termination: TerminationReason,
    },
    TextDelta {
        delta: String,
    },
    ReasoningDelta {
        delta: String,
    },
    ReasoningEncryptedValue {
        encrypted_value: String,
    },
    ToolCallStart {
        id: String,
        name: String,
    },
    ToolCallDelta {
        id: String,
        args_delta: String,
    },
    ToolCallReady {
        id: String,
        name: String,
        arguments: Value,
    },
    StepStart {
        message_id: String,
    },
    InferenceComplete {
        model: String,
        usage: Option<TokenUsage>,
        duration_ms: u64,
    },
    StateSnapshot {
        snapshot: Value,
    },
    StateDelta {
        delta: Vec<Value>,
    },
    MessagesSnapshot {
        messages: Vec<Value>,
    },
    ActivitySnapshot {
        message_id: String,
        activity_type: String,
        content: Value,
        replace: Option<bool>,
    },
    ActivityDelta {
        message_id: String,
        activity_type: String,
        patch: Vec<Value>,
    },
    ToolCallResumed {
        target_id: String,
        result: Value,
    },
    Error {
        message: String,
        code: Option<String>,
    },
    ToolCallDone {
        id: String,
        result: ToolResult,
        patch: Option<TrackedPatch>,
        message_id: String,
    },
    StepEnd,
}

Agent loop events for streaming execution.

Variants

RunStart

Run started.

Fields

thread_id: String

run_id: String

parent_run_id: Option<String>

RunFinish

Run finished.

Fields

thread_id: String

run_id: String

result: Option<Value>

termination: TerminationReason

TextDelta

LLM text delta.

Fields

delta: String

ReasoningDelta

LLM reasoning delta.

Fields

delta: String

ReasoningEncryptedValue

Opaque reasoning signature/token delta from provider.

Fields

encrypted_value: String

ToolCallStart

Tool call started.

Fields

id: String

name: String

ToolCallDelta

Tool call arguments delta.

Fields

id: String

args_delta: String

ToolCallReady

Tool call input is complete.

Fields

id: String

name: String

arguments: Value

StepStart

Step started.

Fields

message_id: String

InferenceComplete

LLM inference completed with token usage data.

Fields

model: String

usage: Option<TokenUsage>

duration_ms: u64

StateSnapshot

State snapshot.

Fields

snapshot: Value

StateDelta

State delta.

Fields

delta: Vec<Value>

MessagesSnapshot

Messages snapshot.

Fields

messages: Vec<Value>

ActivitySnapshot

Activity snapshot.

Fields

message_id: String

activity_type: String

content: Value

replace: Option<bool>

ActivityDelta

Activity delta.

Fields

message_id: String

activity_type: String

patch: Vec<Value>

ToolCallResumed

Suspension resolution received.

Fields

target_id: String

result: Value

Error

Error occurred.

Fields

message: String

code: Option<String>

ToolCallDone

Tool call completed.

Fields

id: String

result: ToolResult

patch: Option<TrackedPatch>

message_id: String

StepEnd

Step completed.

Implementations

impl AgentEvent

pub fn extract_response(result: &Option<Value>) -> String

Extract the response text from a RunFinish result value.

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.