Struct TracingLayer 

pub struct TracingLayer<F: Fn() + Clone, I: Instrumentor> { /* private fields */ }

Tower Layer that wraps the Lambda runtime service with per-invocation OTel spans.

TracingLayer intercepts each LambdaInvocation and:

1. Parses the _X_AMZN_TRACE_ID header and propagates the X-Ray trace context into the new span.
2. Creates a SERVER-kind span named after the Lambda function with the faas.trigger, faas.invocation_id, faas.coldstart, cloud.account.id, and cloud.resource_id attributes.
3. Wraps the invocation future in a FlushedFuture that calls the flush callback when the future drops, ensuring the exporter is flushed even when the invocation is cancelled.

Use DefaultTracingLayer to avoid specifying the I type parameter explicitly.

Examples

use awssdk_instrumentation::lambda::layer::DefaultTracingLayer;
use awssdk_instrumentation::lambda::OTelFaasTrigger;

let layer = DefaultTracingLayer::new(|| { /* flush */ })
    .with_trigger(OTelFaasTrigger::Datasource);

Implementations

impl<F: Fn() + Clone, I: Instrumentor> TracingLayer<F, I>

pub fn new(flush_fn: F) -> Self

Creates a new TracingLayer with the given flush callback.

The flush_fn is called synchronously in the Drop impl of FlushedFuture after each invocation completes or is cancelled. Use it to call tracer_provider.force_flush().

The faas.trigger attribute defaults to OTelFaasTrigger::Datasource. Call with_trigger to override it.

Examples

use awssdk_instrumentation::lambda::layer::DefaultTracingLayer;

let layer = DefaultTracingLayer::new(|| { /* flush */ });

pub fn with_trigger(self, trigger: OTelFaasTrigger) -> Self

Sets the faas.trigger OTel attribute for every invocation span.

Examples

use awssdk_instrumentation::lambda::layer::DefaultTracingLayer;
use awssdk_instrumentation::lambda::OTelFaasTrigger;

let layer = DefaultTracingLayer::new(|| { /* flush */ })
    .with_trigger(OTelFaasTrigger::Http);

Trait Implementations

impl<S, F: Fn() + Clone, I: Instrumentor> Layer<S> for TracingLayer<F, I>

Wraps the Lambda runtime service S with per-invocation OTel instrumentation.

type Service = TracingService<I, S, F>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.