Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Event emitter with optional buffering for rate limiting

Implementations

impl EventEmitter

pub fn new(tx: Sender<AgentEvent>) -> Self

Create a new event emitter with default configuration

pub fn with_config(tx: Sender<AgentEvent>, config: EventBufferConfig) -> Self

Create a new event emitter with custom configuration

pub async fn emit(&self, event: AgentEvent) -> Result<(), SendError<AgentEvent>>

Emit an event immediately (bypasses buffering)

pub async fn emit_progress( &mut self, request_id: String, stage: ProgressStage, percent: Option<u8>, message: String, )

Emit a progress event with rate limiting

pub async fn buffer_token( &mut self, request_id: &str, content: &str, is_thinking: bool, )

Buffer token content and emit when threshold is reached

pub async fn flush_tokens(&mut self, request_id: &str, is_thinking: bool)

Flush any buffered tokens

pub async fn pipeline_started(&self, request_id: &str)

Emit pipeline started event

pub async fn pipeline_completed( &self, request_id: &str, duration_ms: u64, tokens_used: Option<u64>, )

Emit pipeline completed event

pub async fn pipeline_failed( &self, request_id: &str, error: &str, recoverable: bool, )

Emit pipeline failed event

pub async fn tool_started( &self, request_id: &str, tool_id: &str, tool_name: &str, )

Emit tool started event

pub async fn tool_completed( &self, request_id: &str, tool_id: &str, success: bool, duration_ms: u64, output_preview: &str, )

Emit tool completed event