Struct Registry

pub struct Registry { /* private fields */ }

Keeps track of all streaming collector instances

Implementations

impl Registry

pub fn get() -> &'static Self

Get the Registry singleton, and spawn the pruning task if it hasn’t already been launched.

pub fn register(collector: Arc<dyn StreamingCollector + Send + Sync>)

Register a new collector

pub fn stream_text(prefix: Option<String>) -> BoxStream<'static, String>

Produce a stream of String chunks that represent all known metrics in the Prometheus exposition format.

This will include the MetricFamily’s that have been registered with the prometheus crate and then supplement the output with our own set of registered streaming collectors.

The optional prefix parameter is used to “namespace” the returned metric names.

pub fn stream_json() -> BoxStream<'static, String>

Produce a stream of String chunks that represent all known metrics in the informal kumomta json format.

This will include the MetricFamily’s that have been registered with the prometheus crate and then supplement the output with our own set of registered streaming collectors.