Expand description
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§
- Aggregated
Histogram - An aggregated histogram with fixed buckets, suitable for Prometheus exposition.
- Aggregated
Metrics Processor - Aggregated metrics processor.
- Aggregated
Metrics State - Aggregated metrics state.
- Filter
Handle - Handle to the metrics filter.
- Metrics
Flusher Worker - A worker that periodically flushes the internal metrics registry to broadcast subscribers.
- Metrics
Stream - Internal metrics stream
- Reflector
Reflectorcomposes 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.- Remapped
Metric - A metric that has been remapped by a
RemapperRule. - Remapper
Rule - A metric remapping rule.
- Telemetry
Processor - Processes an
AggregatedMetricsStateinto a Prometheus text exposition payload.
Enums§
- Aggregated
Metric Value - Aggregated metric value.
Traits§
- Processor
- Processes input data and modifies shared state based on the result.
Functions§
- 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.
Type Aliases§
- Shared
Events - A collection of events that can be cheaply cloned and shared between multiple consumers.