Enum TelemetryEvent 

pub enum TelemetryEvent {
    RunStarted {
        run_id: String,
        agent_name: String,
        model: Option<String>,
        parent_run_id: Option<String>,
        recovered: bool,
        at_ms: i64,
    },
    StageEntered {
        run_id: String,
        stage_index: usize,
        stage_name: String,
        at_ms: i64,
    },
    StageExited {
        run_id: String,
        stage_index: usize,
        stage_name: String,
        prompt_tokens: usize,
        completion_tokens: usize,
        at_ms: i64,
    },
    InferenceCompleted {
        run_id: String,
        stage_name: String,
        provider: String,
        model: String,
        latency_ms: u64,
        prompt_tokens: usize,
        completion_tokens: usize,
        cached_tokens: usize,
        success: bool,
    },
    ToolCallCompleted {
        run_id: String,
        stage_name: String,
        tool_name: String,
        batch_latency_ms: u64,
        success: bool,
    },
    CompactionCompleted {
        run_id: String,
        stage_name: String,
        success: bool,
    },
    RunCompleted {
        run_id: String,
        status: String,
        prompt_tokens: usize,
        completion_tokens: usize,
        tool_calls: usize,
        at_ms: i64,
    },
    Log {
        run_id: String,
        stage_index: usize,
        kind: LogKind,
        line: String,
    },
}

One observable moment in an agent run’s life.

Timestamps are milliseconds since the Unix epoch (at_ms) so a sink can reconstruct span boundaries without sub-second drift; durations are measured wall-clock milliseconds at the point the work actually ran.

Variants

RunStarted

An agent run became visible to the observer.

Fields

run_id: String

agent_name: String

model: Option<String>

The run-level model hint from spawn metadata, if one was recorded.

parent_run_id: Option<String>

Present when this run is a sub-agent of another run.

recovered: bool

True when the run was reloaded from disk rather than freshly spawned - its earlier life was traced (if at all) by a previous daemon process, so this trace starts mid-run.

at_ms: i64

StageEntered

The run entered a stage (including the first).

Fields

run_id: String

stage_index: usize

stage_name: String

at_ms: i64

StageExited

The run left a stage; token counts are the stage’s own totals.

Fields

run_id: String

stage_index: usize

stage_name: String

prompt_tokens: usize

completion_tokens: usize

at_ms: i64

InferenceCompleted

One inference call finished (successfully or not).

Fields

run_id: String

stage_name: String

provider: String

model: String

latency_ms: u64

Wall-clock time of the provider call, including retries.

prompt_tokens: usize

completion_tokens: usize

cached_tokens: usize

success: bool

ToolCallCompleted

One tool call finished.

Fields

run_id: String

stage_name: String

tool_name: String

batch_latency_ms: u64

Wall-clock time of the batch the call ran in. Tool calls execute in batches and the executor reports one duration per batch, so every call in a batch carries the same figure.

success: bool

Derived from the [error] result-text convention every executor uses; a heuristic, not a structured status.

CompactionCompleted

A context compaction finished.

Fields

run_id: String

stage_name: String

success: bool

RunCompleted

The run reached a terminal status; totals are run-wide.

Fields

run_id: String

status: String

The terminal status label: complete, error, or cancelled.

prompt_tokens: usize

completion_tokens: usize

tool_calls: usize

at_ms: i64

Log

One per-run log line, as also written to the stage’s log files.

Fields

run_id: String

stage_index: usize

kind: LogKind

line: String

Implementations

impl TelemetryEvent

pub fn kind(&self) -> &'static str

A stable short name for this event’s variant.

Exists so a test can assert_eq!(event.kind(), "run_started") rather than assert!(matches!(event, ...)) - the matches! non-matching arm is a region only a failing assertion ever reaches, which reads as uncovered under the workspace’s 100% gate. Useful in its own right for structured logging, where the kind is the field worth indexing on.

pub fn run_id(&self) -> &str

The run this event belongs to.

Trait Implementations

impl Clone for TelemetryEvent

fn clone(&self) -> TelemetryEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryEvent

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

Formats the value using the given formatter.

impl PartialEq for TelemetryEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TelemetryEvent