feat(datadog-aws-lambda): add trigger extraction and inferred spans

instrumentation/Cargo.toml

@@ -22,6 +22,7 @@ publish = false
 
 [workspace.dependencies]
 datadog-aws-core = { path = "datadog-aws-core" }
+libdd-trace-inferrer = { git = "https://github.com/DataDog/libdatadog", branch = "david.ogbureke/libdd-trace-inferrer" }
 serde = "1.0.194"
 serde_json = "1.0.140"
 opentelemetry = { version = "0.31.0", features = ["trace", "metrics", "logs"], default-features = false }

instrumentation/datadog-aws-core/src/interceptor.rs

@@ -7,11 +7,10 @@
 //! [`Intercept`] trait. For each request it:
 //! 1. Creates a Datadog client span with base + service-specific tags
 //!    (`modify_before_serialization`).
-//! 2. Injects propagation headers into the outbound request payload via the
-//!    [`ServiceHandler`] implementation (`modify_before_serialization`).
+//! 2. Injects propagation headers into the outbound request payload via the [`ServiceHandler`]
+//!    implementation (`modify_before_serialization`).
 //! 3. Adds HTTP-level tags once the final request is known (`read_before_transmit`).
-//! 4. Records the response status and any error, then ends the span
-//!    (`read_after_execution`).
+//! 4. Records the response status and any error, then ends the span (`read_after_execution`).
 //!
 //! The [`SpanContext`] type ferries the active OTel [`Context`] through the
 //! SDK's [`ConfigBag`] between hooks.

instrumentation/datadog-aws-lambda/Cargo.toml

@@ -3,7 +3,7 @@
 
 [package]
 name = "datadog-aws-lambda"
-description = "Datadog distributed tracing for AWS Lambda."
+description = "Datadog distributed tracing for AWS Lambda. Provides inferred spans and trace context extraction for SQS, SNS, EventBridge, API Gateway (REST and HTTP APIs), and Lambda Function URLs."
 version.workspace = true
 edition.workspace = true
 rust-version = "1.85.0"
@@ -13,11 +13,13 @@ authors.workspace = true
 publish.workspace = true
 
 [dependencies]
+libdd-trace-inferrer = { workspace = true }
 datadog-opentelemetry = { version = "0.3", path = "../../datadog-opentelemetry", features = ["test-utils"] }
 lambda_runtime = "0.13"
 serde = { workspace = true }
 serde_json = { workspace = true, features = ["raw_value"] }
 opentelemetry = { workspace = true }
+opentelemetry-semantic-conventions = { workspace = true }
 opentelemetry_sdk = { workspace = true, features = ["trace", "metrics", "logs"] }
 tracing = { workspace = true }
 

instrumentation/datadog-aws-lambda/src/attribute_keys.rs

@@ -2,6 +2,8 @@
 // SPDX-License-Identifier: Apache-2.0
 
 pub(crate) const OPERATION_NAME: &str = "operation.name";
+// `operation_name` duplicates `operation.name` as a custom attribute
+pub(crate) const OPERATION_NAME_CUSTOM: &str = "operation_name";
 pub(crate) const RESOURCE_NAME: &str = "resource.name";
 pub(crate) const SPAN_TYPE: &str = "span.type";
 pub(crate) const ERROR: &str = "error";
@@ -11,8 +13,14 @@ pub(crate) const ERROR_MESSAGE: &str = "error.message";
 pub(crate) const LANGUAGE: &str = "language";
 pub(crate) const REQUEST_ID: &str = "request_id";
 pub(crate) const COLD_START: &str = "cold_start";
+pub(crate) const ASYNC_INVOCATION: &str = "async_invocation";
 pub(crate) const FUNCTION_ARN: &str = "function_arn";
 pub(crate) const FUNCTION_VERSION: &str = "function_version";
 pub(crate) const FUNCTION_NAME: &str = "functionname";
 pub(crate) const RESOURCE_NAMES: &str = "resource_names";
 pub(crate) const DD_ORIGIN: &str = "_dd.origin";
+pub(crate) const FUNCTION_TRIGGER_EVENT_SOURCE: &str = "function_trigger.event_source";
+pub(crate) const FUNCTION_TRIGGER_EVENT_SOURCE_ARN: &str = "function_trigger.event_source_arn";
+
+// OpenTelemetry semantic convention keys
+pub(crate) use opentelemetry_semantic_conventions::attribute::{PEER_SERVICE, SERVICE_NAME};