Add Linux user_events Receiver

rust/otap-dataflow/Cargo.toml

@@ -279,6 +279,9 @@ crypto-openssl = ["otap-df-otap/crypto-openssl"]
 contrib-exporters = ["otap-df-contrib-nodes/contrib-exporters"]
 geneva-exporter = ["otap-df-contrib-nodes/geneva-exporter"]
 azure-monitor-exporter = ["otap-df-contrib-nodes/azure-monitor-exporter"]
+# Contrib receivers (opt-in) - now in contrib-nodes
+contrib-receivers = ["otap-df-contrib-nodes/contrib-receivers"]
+userevents-receiver = ["otap-df-contrib-nodes/userevents-receiver"]
 # Contrib processors (opt-in) - now in contrib-nodes
 contrib-processors = ["otap-df-contrib-nodes/contrib-processors"]
 condense-attributes-processor = ["otap-df-contrib-nodes/condense-attributes-processor"]

rust/otap-dataflow/crates/contrib-nodes/Cargo.toml

@@ -14,30 +14,33 @@ workspace = true
 
 [dependencies]
 # Workspace crates (likely used by most/all features)
+otap-df-channel = { workspace = true }
 otap-df-config = { workspace = true }
 otap-df-engine = { workspace = true }
 otap-df-engine-macros = { workspace = true }
 otap-df-otap = { workspace = true }
 otap-df-pdata = { workspace = true }
 otap-df-pdata-views = { workspace = true }
 otap-df-telemetry = { workspace = true }
-otap-df-channel = { workspace = true }
 otap-df-telemetry-macros = { workspace = true }
 
 arrow.workspace = true
 async-trait.workspace = true
 futures.workspace = true
-tokio.workspace = true
-tracing.workspace = true
 bytes.workspace = true
 prost.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 thiserror.workspace = true
 linkme.workspace = true
+tokio.workspace = true
+tracing.workspace = true
+base64 = { workspace = true, optional = true }
 chrono = { workspace = true, optional = true }
-geneva-uploader = { workspace = true, optional = true }
 humantime-serde = { workspace = true, optional = true }
+tracepoint_decode = { version = "0.5.0", optional = true }
+itoa = { workspace = true, optional = true }
+geneva-uploader = { workspace = true, optional = true }
 opentelemetry-proto = { workspace = true, optional = true }
 data_engine_recordset = { workspace = true, optional = true }
 data_engine_recordset_otlp_bridge = { workspace = true, optional = true }
@@ -46,14 +49,28 @@ azure_core = { workspace = true, optional = true, features = ["reqwest"] }
 azure_identity = { workspace = true, optional = true }
 flate2 = { workspace = true, optional = true }
 http = { workspace = true, optional = true }
-itoa = { workspace = true, optional = true }
 rand = { workspace = true, optional = true }
 ryu = { workspace = true, optional = true }
 reqwest = { workspace = true, optional = true, features = ["rustls-no-provider"] }
 sysinfo = { workspace = true, optional = true }
 urlencoding = { workspace = true, optional = true }
 
+[target.'cfg(target_os = "linux")'.dependencies]
+# TODO: Remove this pinned git dependency once one-collect is upstream in the
+# normal dependency graph and no longer needs to be pulled directly here.
+one_collect = { git = "https://github.com/microsoft/one-collect.git", rev = "2d33e674348168f4a19bd3ab40d92f1c556407ec", features = ["scripting"], optional = true }
+
 [features]
+contrib-receivers = [
+    "userevents-receiver",
+]
+userevents-receiver = [
+    "dep:base64",
+    "dep:chrono",
+    "dep:humantime-serde",
+    "dep:one_collect",
+    "dep:tracepoint_decode",
+]
 contrib-exporters = [
     "geneva-exporter",
     "azure-monitor-exporter",
@@ -97,11 +114,16 @@ axum.workspace = true
 clap.workspace = true
 criterion = { workspace = true, features = ["html_reports"] }
 humantime.workspace = true
+core_affinity.workspace = true
+eventheader_dynamic = "0.5.0"
+otap-df-channel = { workspace = true }
 otap-df-engine = { workspace = true, features = ["test-utils"] }
 otap-df-otap = { workspace = true, features = ["test-utils"] }
+otap-df-pdata = { workspace = true, features = ["testing"] }
 pretty_assertions.workspace = true
 rand.workspace = true
 serde_yaml.workspace = true
+tracing-subscriber = { workspace = true, features = ["fmt", "std", "env-filter"] }
 wiremock.workspace = true
 
 [[bench]]

rust/otap-dataflow/crates/contrib-nodes/README.md

@@ -1,11 +1,15 @@
+<!-- markdownlint-disable MD013 -->
+
 # Contrib Nodes
 
-This crate contains optional (feature-gated) contrib processors and exporters.
+This crate contains contrib receivers, processors, and exporters.
 
 ## Folder Layout
 
 - `src/exporters/`
   - Contrib exporters
+- `src/receivers/`
+  - Contrib receivers
 - `src/processors/`
   - Contrib processors
 
@@ -14,6 +18,18 @@ This crate contains optional (feature-gated) contrib processors and exporters.
 Feature flags are grouped into aggregate categories and individual node flags.
 Aggregate flags enable all nodes in their category.
 
+### Receivers
+
+| Node | URN | Module |
+| ---- | --- | ------ |
+| userevents_receiver | `urn:otel:receiver:userevents` | `src/receivers/userevents_receiver/` |
+
+#### userevents_receiver
+
+- Reads Linux `user_events` tracepoints through per-CPU perf sessions
+- Supports single-tracepoint and multi-tracepoint configuration
+- Supports the `common_schema_otel_logs` decode format for supported log payloads
+
 ### Exporters
 
 - `contrib-exporters` (enables all contrib exporters)

rust/otap-dataflow/crates/contrib-nodes/src/lib.rs

@@ -6,5 +6,8 @@
 /// Exporter implementations for contrib nodes.
 pub mod exporters;
 
+/// Receiver implementations for contrib nodes.
+pub mod receivers;
+
 /// Processor implementations for contrib nodes.
 pub mod processors;

rust/otap-dataflow/crates/contrib-nodes/src/receivers/mod.rs

@@ -0,0 +1,6 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+/// Linux userevents receiver.
+#[cfg(feature = "userevents-receiver")]
+pub mod userevents_receiver;