Struct RuntimeMetrics 

pub struct RuntimeMetrics {
    pub active_sessions: AtomicUsize,
    pub total_sessions: AtomicU64,
    pub total_steps: AtomicU64,
    pub total_tool_calls: AtomicU64,
    pub failed_tool_calls: AtomicU64,
    pub backpressure_shed_count: AtomicU64,
    pub memory_recall_count: AtomicU64,
    pub step_latency: LatencyHistogram,
    /* private fields */
}

Shared runtime metrics. Clone the Arc to share across threads.

Fields

active_sessions: AtomicUsize

Number of agent sessions currently in progress.

total_sessions: AtomicU64

Total number of sessions started since the runtime was created.

total_steps: AtomicU64

Total number of ReAct steps executed across all sessions.

total_tool_calls: AtomicU64

Total number of tool calls dispatched (across all tool names).

failed_tool_calls: AtomicU64

Total number of tool calls that returned an error observation.

backpressure_shed_count: AtomicU64

Total number of requests shed due to backpressure.

memory_recall_count: AtomicU64

Total number of memory recall operations.

step_latency: LatencyHistogram

Per-step latency histogram.

Implementations

impl RuntimeMetrics

pub fn new() -> Arc<Self>

Allocate a new RuntimeMetrics instance wrapped in an Arc.

pub fn active_sessions(&self) -> usize

Return the number of agent sessions currently in progress.

pub fn total_sessions(&self) -> u64

Return the total number of sessions started since the runtime was created.

pub fn total_steps(&self) -> u64

Return the total number of ReAct steps executed across all sessions.

pub fn total_tool_calls(&self) -> u64

Return the total number of tool calls dispatched.

pub fn failed_tool_calls(&self) -> u64

Return the total number of tool calls that returned an error observation.

pub fn backpressure_shed_count(&self) -> u64

Return the total number of requests shed due to backpressure.

pub fn memory_recall_count(&self) -> u64

Return the total number of memory recall operations performed.

pub fn record_tool_call(&self, tool_name: &str)

Increment the call counter for tool_name by 1.

Called automatically by the agent loop when with_metrics is configured.

pub fn record_tool_failure(&self, tool_name: &str)

Increment the failure counter for tool_name by 1.

Called automatically by the agent loop when a tool returns an error.

pub fn per_tool_calls_snapshot(&self) -> HashMap<String, u64>

Return a snapshot of per-tool call counts as a HashMap<tool_name, count>.

pub fn per_tool_failures_snapshot(&self) -> HashMap<String, u64>

Return a snapshot of per-tool failure counts as a HashMap<tool_name, count>.

pub fn record_agent_tool_call(&self, agent_id: &str, tool_name: &str)

Increment call counter for (agent_id, tool_name).

pub fn record_agent_tool_failure(&self, agent_id: &str, tool_name: &str)

Increment failure counter for (agent_id, tool_name).

pub fn per_agent_tool_calls_snapshot( &self, ) -> HashMap<String, HashMap<String, u64>>

Snapshot of per-agent, per-tool call counts.

pub fn per_agent_tool_failures_snapshot( &self, ) -> HashMap<String, HashMap<String, u64>>

Snapshot of per-agent, per-tool failure counts.

pub fn snapshot(&self) -> MetricsSnapshot

Capture a complete snapshot of all counters, including per-tool breakdowns.

This is the preferred alternative to to_snapshot — it returns a named MetricsSnapshot struct instead of an opaque tuple.

pub fn record_step_latency(&self, ms: u64)

Record a step latency sample.

pub fn reset(&self)

Reset all counters to zero.

Intended for testing. In production, counters are monotonically increasing.

pub fn to_snapshot(&self) -> (usize, u64, u64, u64, u64, u64, u64)

Capture a snapshot of global counters as plain integers.

Returns (active_sessions, total_sessions, total_steps, total_tool_calls, failed_tool_calls, backpressure_shed_count, memory_recall_count). For per-tool breakdowns use per_tool_calls_snapshot and per_tool_failures_snapshot.

Trait Implementations

impl Debug for RuntimeMetrics

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

Formats the value using the given formatter.

impl Default for RuntimeMetrics

fn default() -> Self

Returns the “default value” for a type.