Struct SdkMeterProvider

pub struct SdkMeterProvider { /* private fields */ }

Handles the creation and coordination of Meters.

All Meters created by a MeterProvider will be associated with the same Resource, have the same views applied to them, and have their produced metric telemetry passed to the configured [MetricReader]s. This is a clonable handle to the MeterProvider implementation itself, and cloning it will create a new reference, not a new instance of a MeterProvider. Dropping the last reference to it will trigger shutdown of the provider. Shutdown can also be triggered manually by calling the shutdown method. Meter: opentelemetry::metrics::Meter

Implementations

impl SdkMeterProvider

pub fn builder() -> MeterProviderBuilder

Return default MeterProviderBuilder

pub fn force_flush(&self) -> Result<(), OTelSdkError>

Flushes all pending telemetry.

There is no guaranteed that all telemetry be flushed or all resources have been released on error.

Examples

use opentelemetry::{global, Context};
use opentelemetry_sdk::metrics::SdkMeterProvider;

fn init_metrics() -> SdkMeterProvider {
    // Setup metric pipelines with readers + views, default has no
    // readers so nothing is exported.
    let provider = SdkMeterProvider::default();

    // Set provider to be used as global meter provider
    let _ = global::set_meter_provider(provider.clone());

    provider
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let provider = init_metrics();

    // create instruments + record measurements

    // force all instruments to flush
    provider.force_flush()?;

    // record more measurements..

    // shutdown ensures any cleanup required by the provider is done,
    // and also invokes shutdown on the readers.
    provider.shutdown()?;

    Ok(())
}

pub fn shutdown_with_timeout( &self, _timeout: Duration, ) -> Result<(), OTelSdkError>

Shuts down the meter provider flushing all pending telemetry and releasing any held computational resources.

This call is idempotent. The first call will perform all flush and releasing operations. Subsequent calls will perform no action and will return an error stating this.

Measurements made by instruments from meters this MeterProvider created will not be exported after Shutdown is called.

There is no guaranteed that all telemetry be flushed or all resources have been released on error.

pub fn shutdown(&self) -> Result<(), OTelSdkError>

shutdown with default timeout

Trait Implementations

impl Clone for SdkMeterProvider

fn clone(&self) -> SdkMeterProvider

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SdkMeterProvider

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

Formats the value using the given formatter.

impl Default for SdkMeterProvider

fn default() -> SdkMeterProvider

Returns the “default value” for a type.

impl MeterProvider for SdkMeterProvider

fn meter(&self, name: &'static str) -> Meter

Returns a new Meter with the provided name and default configuration.

fn meter_with_scope(&self, scope: InstrumentationScope) -> Meter

Returns a new Meter with the given instrumentation scope.