Struct MetricsQueryAccess 

pub struct MetricsQueryAccess { /* private fields */ }

The live in-process access backend. Cheap to construct (wraps the shared Arc).

Implementations

impl MetricsQueryAccess

pub fn new(query: Arc<MetricsQuery>) -> Self

Wrap the session’s live metrics query.

pub fn earliest_ms(&self) -> Option<i64>

SRD-90 §M5 — the oldest sample-time this in-memory tier can answer (Unix-ms), for the super::HybridStore coverage walk: the minimum captured_at across every component’s smallest-cadence retention ring, converted on the same clock as Self::select_range. None when nothing is retained yet (empty store / no cadence) — the hybrid then never short-circuits the colder tail.

Trait Implementations

impl HorizonAware for MetricsQueryAccess

fn earliest_ms(&self) -> Option<i64>

impl MetricAccess for MetricsQueryAccess

fn select_range( &self, matchers: &[Matcher], start_ms: i64, end_ms: i64, ) -> Result<Vector, QueryError>

Range selection: series matching every matcher, with every sample in [start_ms, end_ms] (ascending). Yields a range vector — the input a rollup (rate(m[w]), *_over_time) consumes. This is the one required method; select_instant derives from it.

fn select_instant( &self, matchers: &[Matcher], at_ms: i64, lookback_ms: Option<i64>, ) -> Result<Vector, QueryError>

Instant selection: series matching every matcher, each reduced to its latest sample within [at_ms - lookback, at_ms] (the PromQL stale-tolerance window; lookback_ms = None means a strict [at_ms, at_ms]). Yields an instant vector — one sample per series.