Struct HttpOtelService

pub struct HttpOtelService<S, F> { /* private fields */ }

The service implementation for the HttpOtelLayer.

This struct wraps the inner service and adds OpenTelemetry instrumentation including:

• HTTP request tracing
• Context propagation
• Cold start tracking
• Trace flushing

Trait Implementations

impl<S, F, T> Service<LambdaEvent<T>> for HttpOtelService<S, F>

where S: Service<LambdaEvent<T>, Response = Value, Error = Error> + Send + 'static, S::Future: Send + 'static, T: HttpEvent + Send + Sync + 'static, F: Fn() + Clone + Send,

Implementation of the Service trait for HttpOtelService to handle Lambda HTTP events.

This implementation wraps an inner service with OpenTelemetry instrumentation, creating spans for each request and propagating context through HTTP headers.

Type Parameters

• S - The inner service type that handles the Lambda event
• F - A function type used for flushing telemetry data
• T - The HTTP event type that implements HttpEvent

type Response = <S as Service<LambdaEvent<T>>>::Response

Responses given by the service.

type Error = <S as Service<LambdaEvent<T>>>::Error

Errors produced by the service.

type Future = HttpOtelFuture<Instrumented<<S as Service<LambdaEvent<T>>>::Future>, F>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, event: LambdaEvent<T>) -> Self::Future

Process the request and return the response asynchronously.