Skip to main content

RuntimeMetrics

Struct RuntimeMetrics 

Source
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,
}
Expand description

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.

§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.

Implementations§

Source§

impl RuntimeMetrics

Source

pub fn new() -> Arc<Self>

Allocate a new RuntimeMetrics instance wrapped in an Arc.

Source

pub fn active_sessions(&self) -> usize

Return the number of agent sessions currently in progress.

Source

pub fn total_sessions(&self) -> u64

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

Source

pub fn total_steps(&self) -> u64

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

Source

pub fn total_tool_calls(&self) -> u64

Return the total number of tool calls dispatched.

Source

pub fn failed_tool_calls(&self) -> u64

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

Source

pub fn backpressure_shed_count(&self) -> u64

Return the total number of requests shed due to backpressure.

Source

pub fn memory_recall_count(&self) -> u64

Return the total number of memory recall operations performed.

Source

pub fn reset(&self)

Reset all counters to zero.

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

Source

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

Capture a snapshot of all counters as plain integers.

Returns (active_sessions, total_sessions, total_steps, total_tool_calls, failed_tool_calls, backpressure_shed_count, memory_recall_count).

Trait Implementations§

Source§

impl Debug for RuntimeMetrics

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for RuntimeMetrics

Source§

fn default() -> RuntimeMetrics

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more