pub struct MetricsRegistry {
inner: Registry,
postprocessors: Arc<Mutex<Vec<Box<dyn FnMut(&mut Vec<MetricFamily>) + Send + Sync>>>>,
}
Available on crate feature
metrics
only.Expand description
The materialize metrics registry.
Fields§
§inner: Registry
§postprocessors: Arc<Mutex<Vec<Box<dyn FnMut(&mut Vec<MetricFamily>) + Send + Sync>>>>
Implementations§
Source§impl MetricsRegistry
impl MetricsRegistry
Sourcepub fn register<M>(&self, opts: MakeCollectorOpts) -> Mwhere
M: MakeCollector,
pub fn register<M>(&self, opts: MakeCollectorOpts) -> Mwhere
M: MakeCollector,
Register a metric defined with the metric
macro.
Sourcepub fn register_computed_gauge<F, P>(
&self,
opts: MakeCollectorOpts,
f: F,
) -> ComputedGenericGauge<P>
pub fn register_computed_gauge<F, P>( &self, opts: MakeCollectorOpts, f: F, ) -> ComputedGenericGauge<P>
Registers a gauge whose value is computed when observed.
Sourcepub fn register_collector<C: 'static + Collector>(&self, collector: C)
pub fn register_collector<C: 'static + Collector>(&self, collector: C)
Register a pre-defined prometheus collector.
Sourcepub fn register_postprocessor<F>(&self, f: F)
pub fn register_postprocessor<F>(&self, f: F)
Registers a metric postprocessor.
Postprocessors are invoked on every call to MetricsRegistry::gather
in the order that they are registered.
Sourcepub fn gather(&self) -> Vec<MetricFamily>
pub fn gather(&self) -> Vec<MetricFamily>
Gather all the metrics from the metrics registry for reporting.
This function invokes the postprocessors on all gathered metrics (see
MetricsRegistry::register_postprocessor
) in the order the
postprocessors were registered.
See also prometheus::Registry::gather
.
Trait Implementations§
Source§impl Clone for MetricsRegistry
impl Clone for MetricsRegistry
Source§fn clone(&self) -> MetricsRegistry
fn clone(&self) -> MetricsRegistry
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl Freeze for MetricsRegistry
impl !RefUnwindSafe for MetricsRegistry
impl Send for MetricsRegistry
impl Sync for MetricsRegistry
impl Unpin for MetricsRegistry
impl !UnwindSafe for MetricsRegistry
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request