Struct LambdaSpanProcessor

pub struct LambdaSpanProcessor<E>
where
    E: SpanExporter + Debug,
{ /* private fields */ }

A span processor optimized for AWS Lambda functions.

This processor efficiently manages spans in a Lambda environment:

• Uses a fixed-size ring buffer to prevent memory growth
• Supports synchronous and asynchronous export modes
• Handles graceful shutdown for Lambda termination

Examples

use lambda_otel_lite::LambdaSpanProcessor;
use otlp_stdout_span_exporter::OtlpStdoutSpanExporter;

let processor = LambdaSpanProcessor::builder()
    .exporter(OtlpStdoutSpanExporter::default())
    .build();

With custom configuration:

use lambda_otel_lite::LambdaSpanProcessor;
use otlp_stdout_span_exporter::OtlpStdoutSpanExporter;

let processor = LambdaSpanProcessor::builder()
    .exporter(OtlpStdoutSpanExporter::default())
    .max_queue_size(1000)
    .max_batch_size(100)
    .build();

Implementations

impl<E> LambdaSpanProcessor<E>

where E: SpanExporter + Debug,

pub fn builder() -> LambdaSpanProcessorBuilder<E>

Creates a new LambdaSpanProcessor with the given exporter and configuration

Environment Variable Precedence

Configuration values follow this precedence order:

1. Environment variables (highest precedence)
2. Constructor parameters
3. Default values (lowest precedence)

The relevant environment variables are:

• LAMBDA_SPAN_PROCESSOR_BATCH_SIZE: Controls the maximum batch size
• LAMBDA_SPAN_PROCESSOR_QUEUE_SIZE: Controls the maximum queue size

Trait Implementations

impl<E> Debug for LambdaSpanProcessor<E>

where E: SpanExporter + Debug + Debug,

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

Formats the value using the given formatter.

impl<E> SpanProcessor for LambdaSpanProcessor<E>

where E: SpanExporter + Debug,

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(&self) -> 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.