Struct opentelemetry_otlp::OtlpMetricPipeline
source · pub struct OtlpMetricPipeline<RT> { /* private fields */ }
Available on crate feature
metrics
only.Expand description
Pipeline to build OTLP metrics exporter
Note that currently the OTLP metrics exporter only supports tonic as it’s grpc layer and tokio as runtime.
Implementations§
source§impl<RT> OtlpMetricPipeline<RT>where
RT: Runtime,
impl<RT> OtlpMetricPipeline<RT>where RT: Runtime,
sourcepub fn with_resource(self, resource: Resource) -> Self
pub fn with_resource(self, resource: Resource) -> Self
Build with resource key value pairs.
sourcepub fn with_exporter<B: Into<MetricsExporterBuilder>>(self, pipeline: B) -> Self
pub fn with_exporter<B: Into<MetricsExporterBuilder>>(self, pipeline: B) -> Self
Build with the exporter
sourcepub fn with_timeout(self, timeout: Duration) -> Self
pub fn with_timeout(self, timeout: Duration) -> Self
Build with timeout
sourcepub fn with_period(self, period: Duration) -> Self
pub fn with_period(self, period: Duration) -> Self
Build with period, your metrics will be exported with this period
sourcepub fn with_temporality_selector<T: TemporalitySelector + 'static>(
self,
selector: T
) -> Self
pub fn with_temporality_selector<T: TemporalitySelector + 'static>( self, selector: T ) -> Self
Build with the given temporality selector
sourcepub fn with_aggregation_selector<T: AggregationSelector + 'static>(
self,
selector: T
) -> Self
pub fn with_aggregation_selector<T: AggregationSelector + 'static>( self, selector: T ) -> Self
Build with the given aggregation selector
sourcepub fn build(self) -> Result<MeterProvider>
pub fn build(self) -> Result<MeterProvider>
Build MeterProvider
Trait Implementations§
Auto Trait Implementations§
impl<RT> !RefUnwindSafe for OtlpMetricPipeline<RT>
impl<RT> Send for OtlpMetricPipeline<RT>where RT: Send,
impl<RT> !Sync for OtlpMetricPipeline<RT>
impl<RT> Unpin for OtlpMetricPipeline<RT>where RT: Unpin,
impl<RT> !UnwindSafe for OtlpMetricPipeline<RT>
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> 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