Struct HttpOtelLayer

pub struct HttpOtelLayer<F> { /* private fields */ }

A Tower layer that adds OpenTelemetry tracing to AWS Lambda functions handling HTTP events.

This layer creates spans for incoming HTTP requests and ensures proper context propagation. It also manages span lifecycle to ensure all telemetry is properly flushed within the same Lambda invocation.

Examples

use lambda_runtime::{service_fn, Error, LambdaEvent};
use aws_lambda_events::event::apigw::ApiGatewayProxyRequest;
use lambda_runtime::tower::ServiceBuilder;
use opentelemetry::global;
use opentelemetry_sdk::trace::TracerProvider;
use lambda_otel_utils::http_otel_layer::HttpOtelLayer;

let tracer_provider = TracerProvider::builder().build();
let provider_clone = tracer_provider.clone();

let func = ServiceBuilder::new()
    .layer(HttpOtelLayer::new(move || {
        provider_clone.force_flush();
    }))
    .service(service_fn(handler));

Implementations

impl<F> HttpOtelLayer<F>

where F: Fn() + Clone,

pub fn new(flush_fn: F) -> Self

Trait Implementations

impl<F: Clone> Clone for HttpOtelLayer<F>

fn clone(&self) -> HttpOtelLayer<F>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S, F> Layer<S> for HttpOtelLayer<F>

where F: Fn() + Clone,

type Service = HttpOtelService<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.