Struct opentelemetry::metrics::Meter

pub struct Meter { /* fields omitted */ }

This is supported on crate feature metrics only.

Meter is the OpenTelemetry metric API, based on a sdk-defined MeterCore implementation and the Meter library name.

Instruments

Name	Instrument kind	Function(argument)	Default aggregation	Notes
Counter	Synchronous adding monotonic	Add(increment)	Sum	Per-request, part of a monotonic sum
UpDownCounter	Synchronous adding	Add(increment)	Sum	Per-request, part of a non-monotonic sum
ValueRecorder	Synchronous	Record(value)	TBD issue 636	Per-request, any grouping measurement
SumObserver	Asynchronous adding monotonic	Observe(sum)	Sum	Per-interval, reporting a monotonic sum
UpDownSumObserver	Asynchronous adding	Observe(sum)	Sum	Per-interval, reporting a non-monotonic sum
ValueObserver	Asynchronous	Observe(value)	LastValue	Per-interval, any grouping measurement

Implementations

impl Meter

pub fn new<T: Into<&'static str>>(
    instrumentation_name: T,
    instrumentation_version: Option<T>,
    core: Arc<dyn MeterCore + Send + Sync>
) -> Self

Create a new named meter from a sdk implemented core

pub fn u64_counter<T>(&self, name: T) -> CounterBuilder<'_, u64> where
    T: Into<String>, 

Creates a new integer CounterBuilder for u64 values with the given name.

pub fn f64_counter<T>(&self, name: T) -> CounterBuilder<'_, f64> where
    T: Into<String>, 

Creates a new floating point CounterBuilder for f64 values with the given name.

pub fn i64_up_down_counter<T>(&self, name: T) -> UpDownCounterBuilder<'_, i64> where
    T: Into<String>, 

Creates a new integer UpDownCounterBuilder for an i64 up down counter with the given name.

pub fn f64_up_down_counter<T>(&self, name: T) -> UpDownCounterBuilder<'_, f64> where
    T: Into<String>, 

Creates a new floating point UpDownCounterBuilder for an f64 up down counter with the given name.

pub fn i64_value_recorder<T>(&self, name: T) -> ValueRecorderBuilder<'_, i64> where
    T: Into<String>, 

Creates a new ValueRecorderBuilder for i64 values with the given name.

pub fn u64_value_recorder<T>(&self, name: T) -> ValueRecorderBuilder<'_, u64> where
    T: Into<String>, 

Creates a new ValueRecorderBuilder for u64 values with the given name.

pub fn f64_value_recorder<T>(&self, name: T) -> ValueRecorderBuilder<'_, f64> where
    T: Into<String>, 

Creates a new ValueRecorderBuilder for f64 values with the given name.

pub fn u64_sum_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> SumObserverBuilder<'_, u64> where
    T: Into<String>,
    F: Fn(ObserverResult<u64>) + Send + Sync + 'static, 

Creates a new integer SumObserverBuilder for u64 values with the given name and callback

pub fn f64_sum_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> SumObserverBuilder<'_, f64> where
    T: Into<String>,
    F: Fn(ObserverResult<f64>) + Send + Sync + 'static, 

Creates a new floating point SumObserverBuilder for f64 values with the given name and callback

pub fn i64_up_down_sum_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> UpDownSumObserverBuilder<'_, i64> where
    T: Into<String>,
    F: Fn(ObserverResult<i64>) + Send + Sync + 'static, 

Creates a new integer UpDownSumObserverBuilder for i64 values with the given name and callback.

pub fn f64_up_down_sum_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> UpDownSumObserverBuilder<'_, f64> where
    T: Into<String>,
    F: Fn(ObserverResult<f64>) + Send + Sync + 'static, 

Creates a new floating point UpDownSumObserverBuilder for f64 values with the given name and callback

pub fn u64_value_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> ValueObserverBuilder<'_, u64> where
    T: Into<String>,
    F: Fn(ObserverResult<u64>) + Send + Sync + 'static, 

Creates a new integer ValueObserverBuilder for u64 values with the given name and callback

pub fn i64_value_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> ValueObserverBuilder<'_, i64> where
    T: Into<String>,
    F: Fn(ObserverResult<i64>) + Send + Sync + 'static, 

Creates a new integer ValueObserverBuilder for i64 values with the given name and callback

pub fn f64_value_observer<T, F>(
    &self,
    name: T,
    callback: F
) -> ValueObserverBuilder<'_, f64> where
    T: Into<String>,
    F: Fn(ObserverResult<f64>) + Send + Sync + 'static, 

Creates a new floating point ValueObserverBuilder for f64 values with the given name and callback

pub fn build_batch_observer<B, F>(&self, builder: B) -> Result<()> where
    B: Fn(BatchObserver<'_>) -> Result<F>,
    F: Fn(BatchObserverResult) + Send + Sync + 'static, 

Creates a new BatchObserver that supports making batches of observations for multiple instruments or returns an error if instrument initialization fails.

Examples

use opentelemetry::{global, metrics::BatchObserverResult, KeyValue};

let meter = global::meter("test");

meter.build_batch_observer(|batch| {
  let instrument = batch.u64_value_observer("test_instrument").try_init()?;

  Ok(move |result: BatchObserverResult| {
    result.observe(&[KeyValue::new("my-key", "my-value")], &[instrument.observation(1)]);
  })
})?;

pub fn batch_observer<B, F>(&self, builder: B) where
    B: Fn(BatchObserver<'_>) -> F,
    F: Fn(BatchObserverResult) + Send + Sync + 'static, 

Creates a new BatchObserver that supports making batches of observations for multiple instruments.

Panics

Panics if instrument initialization or observer registration returns an error.

Examples

use opentelemetry::{global, metrics::BatchObserverResult, KeyValue};

let meter = global::meter("test");

meter.batch_observer(|batch| {
  let instrument = batch.u64_value_observer("test_instrument").init();

  move |result: BatchObserverResult| {
    result.observe(&[KeyValue::new("my-key", "my-value")], &[instrument.observation(1)]);
  }
});

pub fn record_batch<T: IntoIterator<Item = Measurement>>(
    &self,
    labels: &[KeyValue],
    measurements: T
)

Atomically record a batch of measurements.

pub fn record_batch_with_context<T: IntoIterator<Item = Measurement>>(
    &self,
    cx: &Context,
    labels: &[KeyValue],
    measurements: T
)

Atomically record a batch of measurements with a given context

Trait Implementations

impl Debug for Meter

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

Formats the value using the given formatter.