Struct opentelemetry_otlp::OtlpMetricPipeline
source · pub struct OtlpMetricPipeline<RT, EB> { /* 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, EB> OtlpMetricPipeline<RT, EB>where
RT: Runtime,
impl<RT, EB> OtlpMetricPipeline<RT, EB>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_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_delta_temporality(self) -> Self
pub fn with_delta_temporality(self) -> Self
Build with delta temporality selector.
This temporality selector is equivalent to OTLP Metrics Exporter’s
Delta
temporality preference (see its documentation).
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
source§impl<RT> OtlpMetricPipeline<RT, NoExporterConfig>where
RT: Runtime,
impl<RT> OtlpMetricPipeline<RT, NoExporterConfig>where
RT: Runtime,
sourcepub fn with_exporter<B: Into<MetricsExporterBuilder>>(
self,
pipeline: B
) -> OtlpMetricPipeline<RT, MetricsExporterBuilder>
pub fn with_exporter<B: Into<MetricsExporterBuilder>>( self, pipeline: B ) -> OtlpMetricPipeline<RT, MetricsExporterBuilder>
Build with the exporter
source§impl<RT> OtlpMetricPipeline<RT, MetricsExporterBuilder>where
RT: Runtime,
impl<RT> OtlpMetricPipeline<RT, MetricsExporterBuilder>where
RT: Runtime,
sourcepub fn build(self) -> Result<SdkMeterProvider>
pub fn build(self) -> Result<SdkMeterProvider>
Build MeterProvider
Trait Implementations§
Auto Trait Implementations§
impl<RT, EB> Freeze for OtlpMetricPipeline<RT, EB>
impl<RT, EB> !RefUnwindSafe for OtlpMetricPipeline<RT, EB>
impl<RT, EB> Send for OtlpMetricPipeline<RT, EB>
impl<RT, EB> Sync for OtlpMetricPipeline<RT, EB>
impl<RT, EB> Unpin for OtlpMetricPipeline<RT, EB>
impl<RT, EB> !UnwindSafe for OtlpMetricPipeline<RT, EB>
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