Struct SnsEventExtractor 

pub struct SnsEventExtractor;

Extractor for SNS notification events.

SNS events may carry trace context in two locations within message_attributes:

1. W3C traceparent/tracestate - injected by OTel-instrumented producers
2. AWSTraceHeader - X-Ray format set by AWS

This extractor checks both, preferring W3C format when available.

Per OpenTelemetry semantic conventions for messaging systems, this extractor:

• Does NOT set a parent context (returns current context)
• Creates span links for each message’s trace context

This approach is appropriate because the async nature of message queues means span links are more semantically correct than parent-child relationships.

Example

use opentelemetry_lambda_tower::{OtelTracingLayer, SnsEventExtractor};

let layer = OtelTracingLayer::new(SnsEventExtractor::new());

Implementations

impl SnsEventExtractor

pub fn new() -> Self

Creates a new SNS event extractor.

Trait Implementations

impl Clone for SnsEventExtractor

fn clone(&self) -> SnsEventExtractor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SnsEventExtractor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SnsEventExtractor

fn default() -> SnsEventExtractor

Returns the “default value” for a type.

impl TraceContextExtractor<SnsEvent> for SnsEventExtractor

fn extract_context(&self, _event: &SnsEvent) -> Context

Extracts parent context for creating child spans.

fn extract_links(&self, event: &SnsEvent) -> Vec<Link>

Extracts span links for async message correlation.

fn trigger_type(&self) -> &'static str

Returns the FaaS trigger type for semantic conventions.

fn span_name(&self, event: &SnsEvent, lambda_ctx: &LambdaContext) -> String

Generates span name based on event and Lambda context.

fn record_attributes(&self, event: &SnsEvent, span: &Span)

Records event-specific attributes on the span.