Struct OtelLambdaLayer

pub struct OtelLambdaLayer { /* private fields */ }

OpenTelemetry layer for AWS Lambda functions.

This layer provides automatic tracing instrumentation for AWS Lambda functions, creating spans for each invocation with appropriate FaaS semantic attributes.

Example

use lambda_runtime::{
    Error as LambdaRuntimeError, Error as LambdaError, LambdaEvent, Runtime,
    service_fn,
};
use telemetry_rust::{init_tracing, middleware::lambda::OtelLambdaLayer};

#[tracing::instrument(skip_all, err, fields(req_id = %event.context.request_id))]
pub async fn handle(event: LambdaEvent<()>) -> Result<String, LambdaError> {
    Ok(String::from("Hello!"))
}

#[tokio::main]
async fn main() -> Result<(), lambda_runtime::Error> {
    // Grab TracerProvider after telemetry initialisation
    let provider = init_tracing!(tracing::Level::WARN);

    // Create lambda telemetry layer
    let telemetry_layer = OtelLambdaLayer::new(provider);

    // Run lambda runtime with telemetry layer
    Runtime::new(service_fn(handle))
        .layer(telemetry_layer)
        .run()
        .await?;

    // Tracer provider will be automatically shutdown when the runtime is dropped

    Ok(())
}

Implementations

impl OtelLambdaLayer

pub fn new(provider: TracerProvider) -> Self

Creates a new OpenTelemetry layer for Lambda functions.

Arguments

• provider - The tracer provider to use for creating spans

Trait Implementations

impl<S> Layer<S> for OtelLambdaLayer

type Service = OtelLambdaService<S>

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.