Struct LambdaSpanProcessor

pub struct LambdaSpanProcessor { /* private fields */ }

Lambda-optimized span processor implementation.

This processor is designed specifically for AWS Lambda functions, providing:

• Efficient span storage through a ring buffer
• Configurable processing modes for different use cases
• Thread-safe operations for concurrent span submission
• Automatic span sampling and filtering
• Batch export capabilities

Memory Usage

The processor uses a fixed amount of memory based on the configured queue size:

• Each span typically uses 100-500 bytes
• Default configuration (2048 spans) uses 0.5-1MB
• When buffer is full, new spans are dropped with warnings

Thread Safety

All operations are thread-safe through:

• Mutex protection for span buffer access
• Atomic operations for state management
• Safe sharing between threads with Arc

Example

use lambda_otel_lite::{LambdaSpanProcessor, ProcessorConfig};
use otlp_stdout_span_exporter::OtlpStdoutSpanExporter;

let processor = LambdaSpanProcessor::new(
    Box::new(OtlpStdoutSpanExporter::default()),
    ProcessorConfig::default(),
);

// Processor can be safely shared between threads
let processor = std::sync::Arc::new(processor);

Error Handling

The processor handles errors gracefully:

• Export failures are logged but don’t fail the function
• Dropped spans are counted and logged with warnings
• Buffer overflow warnings help with capacity planning

Implementations

impl LambdaSpanProcessor

pub fn new(exporter: Box<dyn SpanExporter>, config: ProcessorConfig) -> Self

Creates a new LambdaSpanProcessor with the given configuration

Trait Implementations

impl Debug for LambdaSpanProcessor

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

Formats the value using the given formatter.

impl SpanProcessor for LambdaSpanProcessor

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.

fn force_flush(&self) -> TraceResult<()>

Force the spans lying in the cache to be exported.

fn shutdown(&self) -> TraceResult<()>

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 log processor.