Enum ObserverEvent 

pub enum ObserverEvent {
    AgentStart {
        provider: String,
        model: String,
    },
    LlmRequest {
        provider: String,
        model: String,
        messages_count: usize,
    },
    LlmResponse {
        provider: String,
        model: String,
        duration: Duration,
        success: bool,
        error_message: Option<String>,
        input_tokens: Option<u64>,
        output_tokens: Option<u64>,
    },
    AgentEnd {
        provider: String,
        model: String,
        duration: Duration,
        tokens_used: Option<u64>,
        cost_usd: Option<f64>,
    },
    ToolCallStart {
        tool: String,
    },
    ToolCall {
        tool: String,
        duration: Duration,
        success: bool,
    },
    TurnComplete,
    ChannelMessage {
        channel: String,
        direction: String,
    },
    HeartbeatTick,
    Error {
        component: String,
        message: String,
    },
}

Discrete events emitted by the agent runtime for observability.

Each variant represents a lifecycle event that observers can record, aggregate, or forward to external monitoring systems. Events carry just enough context for tracing and diagnostics without exposing sensitive prompt or response content.

Variants

AgentStart

The agent orchestration loop has started a new session.

Fields

provider: String

model: String

LlmRequest

A request is about to be sent to an LLM provider.

This is emitted immediately before a provider call so observers can print user-facing progress without leaking prompt contents.

Fields

provider: String

model: String

messages_count: usize

LlmResponse

Result of a single LLM provider call.

Fields

provider: String

model: String

duration: Duration

success: bool

error_message: Option<String>

input_tokens: Option<u64>

output_tokens: Option<u64>

AgentEnd

The agent session has finished.

Carries aggregate usage data (tokens, cost) when the provider reports it.

Fields

provider: String

model: String

duration: Duration

tokens_used: Option<u64>

cost_usd: Option<f64>

ToolCallStart

A tool call is about to be executed.

Fields

tool: String

ToolCall

A tool call has completed with a success/failure outcome.

Fields

tool: String

duration: Duration

success: bool

TurnComplete

The agent produced a final answer for the current user message.

ChannelMessage

A message was sent or received through a channel.

Fields

channel: String

Channel name (e.g., "telegram", "discord").

direction: String

"inbound" or "outbound".

HeartbeatTick

Periodic heartbeat tick from the runtime keep-alive loop.

Error

An error occurred in a named component.

Fields

component: String

Subsystem where the error originated (e.g., "provider", "gateway").

message: String

Human-readable error description. Must not contain secrets or tokens.

Trait Implementations

impl Clone for ObserverEvent

fn clone(&self) -> ObserverEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObserverEvent

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

Formats the value using the given formatter.