Enum AgentEvent 

pub enum AgentEvent {
    PipelineStarted {
        request_id: String,
        timestamp_ms: u64,
    },
    Progress {
        request_id: String,
        stage: ProgressStage,
        percent: Option<u8>,
        message: String,
    },
    TokenStream {
        request_id: String,
        content: String,
        is_thinking: bool,
    },
    ToolStarted {
        request_id: String,
        tool_id: String,
        tool_name: String,
    },
    ToolProgress {
        request_id: String,
        tool_id: String,
        percent: Option<u8>,
        message: String,
    },
    ToolCompleted {
        request_id: String,
        tool_id: String,
        success: bool,
        duration_ms: u64,
        output_preview: String,
    },
    ContextCompacted {
        request_id: String,
        messages_before: usize,
        messages_after: usize,
        tokens_saved: usize,
    },
    RetryAttempt {
        request_id: String,
        attempt: u32,
        max_attempts: u32,
        delay_ms: u64,
        reason: String,
    },
    PipelineCompleted {
        request_id: String,
        duration_ms: u64,
        tokens_used: Option<u64>,
    },
    PipelineFailed {
        request_id: String,
        error: String,
        recoverable: bool,
    },
    PipelineCancelled {
        request_id: String,
    },
    PipelinePaused {
        request_id: String,
    },
}

Event types for the agent pipeline

Variants

PipelineStarted

Pipeline has started processing a request

Fields

request_id: String

timestamp_ms: u64

Progress

Progress update for long-running operations

Fields

request_id: String

stage: ProgressStage

percent: Option<u8>

message: String

TokenStream

Token streaming event

Fields

request_id: String

content: String

is_thinking: bool

ToolStarted

Tool execution started

Fields

request_id: String

tool_id: String

tool_name: String

ToolProgress

Tool execution progress

Fields

request_id: String

tool_id: String

percent: Option<u8>

message: String

ToolCompleted

Tool execution completed

Fields

request_id: String

tool_id: String

success: bool

duration_ms: u64

output_preview: String

ContextCompacted

Context was compacted

Fields

request_id: String

messages_before: usize

messages_after: usize

tokens_saved: usize

RetryAttempt

Retry attempt

Fields

request_id: String

attempt: u32

max_attempts: u32

delay_ms: u64

reason: String

PipelineCompleted

Pipeline completed successfully

Fields

request_id: String

duration_ms: u64

tokens_used: Option<u64>

PipelineFailed

Pipeline failed with error

Fields

request_id: String

error: String

recoverable: bool

PipelineCancelled

Pipeline was cancelled

Fields

request_id: String

PipelinePaused

Pipeline was paused (cancelled with resume intent).

Fields

request_id: 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<(), 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 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.