Struct MetricsStore 

pub struct MetricsStore { /* private fields */ }

Top-level per-service metrics store, keyed by service type (ResourceType as i32).

Implementations

impl MetricsStore

pub fn new() -> Self

pub async fn push_sample(&self, service_type: i32, sample: MetricSample)

Push a 1-minute sample for service_type into tier 0 and cascade rollups into tier 1 / tier 2 as needed.

pub async fn query(&self, service_type: i32, tier: u8) -> Vec<MetricSample>

Query samples at the given tier for a service.

Returns an empty vec if no data exists for service_type or tier is out of range.

pub fn start_sampler( self, counters: Arc<HashMap<i32, Arc<ServiceCounters>>>, interval: Duration, )

Spawn a background sampler task that periodically snapshots each service’s counters and pushes the samples into the store.

The task runs every interval (typically 60 s) until the runtime shuts down.

Trait Implementations

impl Clone for MetricsStore

fn clone(&self) -> MetricsStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsStore

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

Formats the value using the given formatter.

impl Default for MetricsStore

fn default() -> Self

Returns the “default value” for a type.