Struct LiveMetricsSpanProcessor

pub struct LiveMetricsSpanProcessor<R: RuntimeChannel> { /* private fields */ }

Application Insights live metrics span processor

Enables live metrics collection: https://learn.microsoft.com/en-us/azure/azure-monitor/app/live-stream.

#[tokio::main]
async fn main() {
    let exporter = opentelemetry_application_insights::Exporter::new_from_connection_string(
        "connection_string",
        reqwest::Client::new(),
    )
    .expect("valid connection string");
    let tracer_provider = opentelemetry_sdk::trace::SdkTracerProvider::builder()
       .with_span_processor(opentelemetry_sdk::trace::span_processor_with_async_runtime::BatchSpanProcessor::builder(exporter.clone(), opentelemetry_sdk::runtime::Tokio).build())
       .with_span_processor(opentelemetry_application_insights::LiveMetricsSpanProcessor::new(exporter, opentelemetry_sdk::runtime::Tokio))
       .build();
    opentelemetry::global::set_tracer_provider(tracer_provider.clone());

    // ... send traces ...

    tracer_provider.shutdown().unwrap();
}

Implementations

impl<R: RuntimeChannel> LiveMetricsSpanProcessor<R>

pub fn new<C: HttpClient + 'static>( exporter: Exporter<C>, runtime: R, ) -> LiveMetricsSpanProcessor<R>

Create new live metrics span processor.

Trait Implementations

impl<R: RuntimeChannel> Debug for LiveMetricsSpanProcessor<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<R: RuntimeChannel> Drop for LiveMetricsSpanProcessor<R>

fn drop(&mut self)

Executes the destructor for this type.

impl<R: RuntimeChannel> SpanProcessor for LiveMetricsSpanProcessor<R>

fn on_start(&self, _span: &mut Span, _cx: &Context)

on_start is called when a Span is started. This method is called synchronously on the thread that started the span, therefore it should not block or throw exceptions.

fn on_end(&self, span: SpanData)

on_end is called after a Span is ended (i.e., the end timestamp is already set). This method is called synchronously within the Span::end API, therefore it should not block or throw an exception. TODO - This method should take reference to SpanData

fn force_flush(&self) -> OTelSdkResult

Force the spans lying in the cache to be exported.

fn shutdown_with_timeout(&self, _timeout: Duration) -> OTelSdkResult

Shuts down the processor. Called when SDK is shut down. This is an opportunity for processors to do any cleanup required.

fn set_resource(&mut self, resource: &Resource)

Set the resource for the span processor.

fn shutdown(&self) -> Result<(), OTelSdkError>

shutdown the processor with a default timeout.