Struct OtelInternalExtension

pub struct OtelInternalExtension { /* private fields */ }

Extension that flushes OpenTelemetry spans after each Lambda invocation.

This extension is responsible for:

• Receiving completion signals from the handler
• Flushing spans at the appropriate time
• Managing the lifecycle of the tracer provider

The extension operates asynchronously to minimize impact on handler latency. It uses a channel-based communication pattern to coordinate with the handler.

Implementations

impl OtelInternalExtension

pub fn new( request_done_receiver: UnboundedReceiver<()>, tracer_provider: Arc<TracerProvider>, ) -> Self

Creates a new OtelInternalExtension.

Arguments

• request_done_receiver - Channel receiver for completion signals
• tracer_provider - TracerProvider for span management

pub async fn invoke(&self, event: LambdaEvent) -> Result<(), Error>

Handles extension events and flushes telemetry after each invocation.

This method:

1. Waits for an INVOKE event
2. Waits for the handler to signal completion
3. Flushes all pending spans

Arguments

• event - The Lambda extension event to handle

Returns

Returns Ok(()) if successful, or an Error if something went wrong