Module metrics 

Internal metrics support.

Includes the MetricsStream broadcast of internally emitted metrics events and the Reflector-based AggregatedMetricsState view that downstream callers query for Prometheus exposition.

Structs

AggregatedHistogram

An aggregated histogram with fixed buckets, suitable for Prometheus exposition.

AggregatedMetricsProcessor

Aggregated metrics processor.

AggregatedMetricsState

Aggregated metrics state.

FilterHandle

Handle to the metrics filter.

MetricsFlusherWorker

A worker that periodically flushes the internal metrics registry to broadcast subscribers.

MetricsSnapshot

A batch of metric updates produced by a single flush.

MetricsStream

Internal metrics stream

Reflector

Reflector composes a source of data with a processor that’s used to transform the data, and then stores the results and allows for shared access by multiple callers.

ReflectorWorker

A worker that drives a Reflector’s data source.

RemappedMetric

A metric that has been remapped by a RemapperRule.

RemapperRule

A metric remapping rule.

TelemetryProcessor

Processes an AggregatedMetricsState into a Prometheus text exposition payload.

Enums

AggregatedMetricValue

Aggregated metric value.

Traits

Processor

Processes input data and modifies shared state based on the result.

Functions

delete_counter

Deletes an internal counter from the metrics registry.

get_shared_metrics_state

Gets the shared metrics state, which provides unified access to internal metrics in a simplified interface.

initialize_metrics

Initializes the metrics subsystem with the given metrics prefix and default filter level.

initialize_shared_metrics_state

Initializes the shared metrics state, returning the worker that drives it.

Type Aliases

SharedMetricsSnapshot

A MetricsSnapshot that can be cheaply cloned and shared between multiple consumers.

SharedMetricsWorker

The worker that drives the shared metrics reflector. See initialize_shared_metrics_state.