Struct opentelemetry::sdk::trace::BatchSpanProcessor

pub struct BatchSpanProcessor { /* fields omitted */ }

A SpanProcessor that asynchronously buffers finished spans and reports them at a preconfigured interval.

Implementations

impl BatchSpanProcessor

pub fn builder<E, S, SH, SO, I, IO>(
    exporter: E,
    spawn: S,
    interval: I
) -> BatchSpanProcessorBuilder<E, S, I> where
    E: SpanExporter,
    S: Fn(BoxFuture<'static, ()>) -> SH,
    SH: Future<Output = SO> + Send + Sync + 'static,
    I: Fn(Duration) -> IO, 

Create a new batch processor builder

pub fn from_env<E, S, SH, SO, I, IO>(
    exporter: E,
    spawn: S,
    interval: I
) -> BatchSpanProcessorBuilder<E, S, I> where
    E: SpanExporter,
    S: Fn(BoxFuture<'static, ()>) -> SH,
    SH: Future<Output = SO> + Send + Sync + 'static,
    I: Fn(Duration) -> IO, 

Create a new batch processor builder and set the config value based on environment variables.

If the value in environment variables is illegal, will fall back to use default value.

Note that export batch size should be less than or equals to max queue size. If export batch size is larger than max queue size, we will lower to be the same as max queue size

Trait Implementations

impl Debug for BatchSpanProcessor

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

Formats the value using the given formatter.

impl SpanProcessor for BatchSpanProcessor

fn on_start(&self, _span: &SpanData)

on_start method is invoked when a Span is started.

fn on_end(&self, span: SpanData)

on_end method is invoked when a Span is ended.

fn shutdown(&mut self)

Shutdown is invoked when SDK shuts down. Use this call to cleanup any processor data. No calls to on_start and on_end method is invoked after shutdown call is made.