Struct opentelemetry_otlp::OtlpMetricPipeline
source · pub struct OtlpMetricPipeline<AS, TS, 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<AS, TS, RT> OtlpMetricPipeline<AS, TS, RT>where
AS: AggregatorSelector + Send + Sync + 'static,
TS: TemporalitySelector + Clone + Send + Sync + 'static,
RT: Runtime,
impl<AS, TS, RT> OtlpMetricPipeline<AS, TS, RT>where AS: AggregatorSelector + Send + Sync + 'static, TS: TemporalitySelector + Clone + Send + Sync + 'static, 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
Trait Implementations§
Auto Trait Implementations§
impl<AS, TS, RT> !RefUnwindSafe for OtlpMetricPipeline<AS, TS, RT>
impl<AS, TS, RT> Send for OtlpMetricPipeline<AS, TS, RT>where AS: Send, RT: Send, TS: Send,
impl<AS, TS, RT> !Sync for OtlpMetricPipeline<AS, TS, RT>
impl<AS, TS, RT> Unpin for OtlpMetricPipeline<AS, TS, RT>where AS: Unpin, RT: Unpin, TS: Unpin,
impl<AS, TS, RT> !UnwindSafe for OtlpMetricPipeline<AS, TS, RT>
Blanket Implementations§
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§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