pub struct OtlpMetricPipeline<RT, EB> { /* private fields */ }
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