Struct MetricsStore 

pub struct MetricsStore { /* private fields */ }

Thread-safe, in-memory store for per-route request metrics.

Create a single instance at server startup and share it (via Arc) with all request-handling filters. Call MetricsStore::record after each upstream request completes, and MetricsStore::snapshot to produce a serializable view for the GET /v1/metrics endpoint.

Persistence

Metrics are currently held in memory only and are lost on process restart. This is intentional for the initial release — the consuming plugin layer (OpenClaw) can handle its own persistence if needed. A future release may back this store with a database or Redis cache.

Implementations

impl MetricsStore

pub fn new() -> Self

Creates a new, empty metrics store. The uptime clock starts now.

pub fn record(&self, event: RequestMetrics)

Records a completed request into the store.

This method acquires a write-lock for a very short duration (counter increments + a Vec::push) so contention should be negligible.

pub fn record_success( &self, route: String, endpoint: String, start: Instant, input_tokens: Option<u32>, output_tokens: Option<u32>, )

Records a successful generate (non-streaming) request.

This is a convenience wrapper used by provider handlers to reduce duplicated recording logic across OpenAI, Anthropic and Google filters.

pub fn record_outcome( &self, route: String, endpoint: String, start: Instant, is_error: bool, )

Records a failed or stream-only request.

is_error should be true for upstream failures and false for streaming requests where token counts are unavailable.

pub fn snapshot(&self) -> MetricsSnapshot

Produces a serialisable snapshot of all collected metrics.

The read-lock is held only long enough to clone raw counters and latency vectors. Expensive work (sorting for percentiles, computing averages) is performed after the lock is released so that concurrent record() calls are not blocked by a /v1/metrics request.

Trait Implementations

impl Default for MetricsStore

fn default() -> Self

Returns the “default value” for a type.