Struct OtlpActionTraceSink

pub struct OtlpActionTraceSink { /* private fields */ }

A bridge from action-trace to batched opentelemetry trace services.

Implementations

impl OtlpActionTraceSink

pub fn new( otlp_endpoint: &str, interceptors: Option<Box<dyn RequestInterceptor>>, batch_size: usize, insecure: bool, attributes: OtlpAttributes, ) -> Result<Self, Box<dyn Error>>

pub fn drain_batch(&self)

pub fn send(&self, span: impl Into<Span>)

Spans are batched up and sent to your downstream.

See send_many() instead if you have a collection of spans to send.

sink.send(span);

pub fn send_many(&self, batch: impl IntoIterator<Item = impl Into<Span>>)

Spans are batched up and sent to your downstream.

Use this over send() when you have already collected spans to avoid needless extra synchronization cost.

let batch = vec![span1, span2];   // Collect a batch somehow
sink.send_many(batch);            // Send them all at once

Trait Implementations

impl TraceSink for OtlpActionTraceSink

fn sink_trace(&self, trace: &mut ActionSpan)