Crate phi_telemetry 

phi-telemetry — Observability layer for phi-agent.

Collects structured per-turn and per-session metrics via hooks registered on the agent runtime. Metrics are persisted as session_metrics.json alongside existing session data.

Architecture

agent-base (TurnContext + on_turn_end hook)
    ↑
phi-telemetry (collector + storage)  ← this crate
    ↑
phi-agent / phi-bard (consumers)

The observer runs in an independent tokio task, communicating with the agent runtime through an mpsc channel. A panic in the observer task never affects the agent.

Quick start

use phi_telemetry::{init_telemetry, save_metrics};

let handle = init_telemetry(&runtime, session_id, node_id, model);
// ... agent runs, metrics accumulate automatically ...
handle.shutdown();
let session = handle.session.blocking_read();
save_metrics(&session, &session_dir)?;

Re-exports

pub use collector::ObserverHandle;

pub use collector::init_telemetry;

pub use storage::list_all_metrics;

pub use storage::load_metrics;

pub use storage::save_metrics;

pub use storage::try_load_metrics;

pub use types::SessionMetrics;

pub use types::SessionOutcome;

pub use types::SessionSummary;

pub use types::TurnMetrics;

pub use types::TurnOutcome;

Modules

collector

Metrics collector — subscribes to turn-end hooks and accumulates session metrics.

storage

Metrics persistence — save, load, and list session metrics from disk.

types

Structured metrics types for Agent observability.