Struct MetricsSnapshot 

pub struct MetricsSnapshot {
    pub requests_total: u64,
    pub errors_total: u64,
    pub cache_hits_total: u64,
    pub cache_misses_total: u64,
    pub pipelines_total: u64,
    pub pipeline_errors_total: u64,
    pub input_tokens_total: u64,
    pub output_tokens_total: u64,
    pub active_workers: i64,
    pub queue_depth: i64,
}

Point-in-time snapshot of all metric counters.

Returned by MetricsRegistry::snapshot.

Fields

requests_total: u64

Total scraping requests started

errors_total: u64

Total request failures

cache_hits_total: u64

Total cache hits

cache_misses_total: u64

Total cache misses

pipelines_total: u64

Total pipeline executions

pipeline_errors_total: u64

Total pipeline execution errors

input_tokens_total: u64

Total AI input/prompt tokens consumed

output_tokens_total: u64

Total AI output/completion tokens generated

active_workers: i64

Current active worker count

queue_depth: i64

Current worker queue depth

Implementations

impl MetricsSnapshot

pub fn cache_hit_rate(&self) -> f64

Cache hit rate in the range [0.0, 1.0]. Returns 0.0 when no cache accesses have been recorded.

Example

use stygian_graph::application::metrics::{MetricsRegistry, MetricEvent};

let r = MetricsRegistry::new();
r.record(MetricEvent::CacheAccess { hit: true });
r.record(MetricEvent::CacheAccess { hit: false });
let snap = r.snapshot();
assert!((snap.cache_hit_rate() - 0.5).abs() < f64::EPSILON);

pub fn error_rate(&self) -> f64

Error rate across all scraping requests in the range [0.0, 1.0].

Example

use stygian_graph::application::metrics::{MetricsRegistry, MetricEvent};

let r = MetricsRegistry::new();
r.record(MetricEvent::RequestStarted { service: "http".into() });
r.record(MetricEvent::RequestCompleted { service: "http".into(), duration_ms: 100, success: false });
let snap = r.snapshot();
assert!((snap.error_rate() - 1.0).abs() < f64::EPSILON);

Trait Implementations

impl Clone for MetricsSnapshot

fn clone(&self) -> MetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MetricsSnapshot

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MetricsSnapshot

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for MetricsSnapshot

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MetricsSnapshot

impl StructuralPartialEq for MetricsSnapshot