pub struct PipelineBuilder<C> { /* private fields */ }
Expand description
Application Insights exporter pipeline builder
Implementations§
source§impl<C> PipelineBuilder<C>
impl<C> PipelineBuilder<C>
sourcepub fn with_client<NC>(self, client: NC) -> PipelineBuilder<NC>
pub fn with_client<NC>(self, client: NC) -> PipelineBuilder<NC>
Set HTTP client, which the exporter will use to send telemetry to Application Insights.
Use this to set an HTTP client which fits your async runtime.
sourcepub fn with_endpoint(
self,
endpoint: &str
) -> Result<Self, Box<dyn StdError + Send + Sync + 'static>>
👎Deprecated since 0.27.0: use new_pipeline_from_connection_string() or new_pipeline_from_env() instead
pub fn with_endpoint( self, endpoint: &str ) -> Result<Self, Box<dyn StdError + Send + Sync + 'static>>
Set endpoint used to ingest telemetry. This should consist of scheme and authrity. The
exporter will call /v2/track
on the specified endpoint.
Default: https://dc.services.visualstudio.com
Note: This example requires reqwest
and the opentelemetry-http/reqwest feature.
let tracer = opentelemetry_application_insights::new_pipeline("...".into())
.with_client(reqwest::blocking::Client::new())
.with_endpoint("https://westus2-0.in.applicationinsights.azure.com")?
.install_simple();
sourcepub fn with_sample_rate(self, sample_rate: f64) -> Self
pub fn with_sample_rate(self, sample_rate: f64) -> Self
Set sample rate, which is passed through to Application Insights. It should be a value between 0 and 1 and match the rate given to the sampler.
Default: 1.0
Note: This example requires reqwest
and the opentelemetry-http/reqwest feature.
let tracer = opentelemetry_application_insights::new_pipeline("...".into())
.with_client(reqwest::blocking::Client::new())
.with_sample_rate(0.3)
.install_simple();
sourcepub fn with_trace_config(self, config: Config) -> Self
pub fn with_trace_config(self, config: Config) -> Self
Assign the SDK config for the exporter pipeline.
If there is an existing sdk::Config
in the PipelineBuilder
the sdk::Resource
s
are merged and any other parameters are overwritten.
Note: This example requires reqwest
and the opentelemetry-http/reqwest feature.
let tracer = opentelemetry_application_insights::new_pipeline("...".into())
.with_client(reqwest::blocking::Client::new())
.with_trace_config(opentelemetry_sdk::trace::config().with_resource(
Resource::new(vec![
KeyValue::new("service.name", "my-application"),
]),
))
.install_simple();
sourcepub fn with_service_name<T: Into<Value>>(self, name: T) -> Self
pub fn with_service_name<T: Into<Value>>(self, name: T) -> Self
Assign the service name under which to group traces by adding a service.name
sdk::Resource
or overriding a previous setting of it.
If a sdk::Config
does not exist on the PipelineBuilder
one will be created.
This will be translated, along with the service namespace, to the Cloud Role Name.
let tracer = opentelemetry_application_insights::new_pipeline("...".into())
.with_client(reqwest::blocking::Client::new())
.with_service_name("my-application")
.install_simple();
sourcepub fn with_live_metrics(self, enable_live_metrics: bool) -> Self
Available on crate feature live-metrics
only.
pub fn with_live_metrics(self, enable_live_metrics: bool) -> Self
live-metrics
only.Enable live metrics.
source§impl<C> PipelineBuilder<C>where
C: HttpClient + 'static,
impl<C> PipelineBuilder<C>where
C: HttpClient + 'static,
sourcepub fn build_simple(self) -> TracerProvider
pub fn build_simple(self) -> TracerProvider
Build a configured TracerProvider
with a simple span processor.
sourcepub fn build_batch<R: RuntimeChannel>(self, runtime: R) -> TracerProvider
pub fn build_batch<R: RuntimeChannel>(self, runtime: R) -> TracerProvider
Build a configured TracerProvider
with a batch span processor using the specified
runtime.
sourcepub fn install_simple(self) -> Tracer
pub fn install_simple(self) -> Tracer
Install an Application Insights pipeline with the recommended defaults.
This registers a global TracerProvider
. See the build_simple
function if you don’t need
that.
sourcepub fn install_batch<R: RuntimeChannel>(self, runtime: R) -> Tracer
pub fn install_batch<R: RuntimeChannel>(self, runtime: R) -> Tracer
Install an Application Insights pipeline with the recommended defaults.
This registers a global TracerProvider
. See the build_simple
function if you don’t need
that.
Trait Implementations§
Auto Trait Implementations§
impl<C> !Freeze for PipelineBuilder<C>
impl<C> !RefUnwindSafe for PipelineBuilder<C>
impl<C> Send for PipelineBuilder<C>where
C: Send,
impl<C> Sync for PipelineBuilder<C>where
C: Sync,
impl<C> Unpin for PipelineBuilder<C>where
C: Unpin,
impl<C> !UnwindSafe for PipelineBuilder<C>
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
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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more