feat(bottlecap): add runtime tag

bottlecap/src/lifecycle/invocation/processor.rs

@@ -19,8 +19,12 @@ use crate::{
         span_inferrer::SpanInferrer, tag_span_from_value,
     },
     metrics::enhanced::lambda::{EnhancedMetricData, Lambda as EnhancedMetrics},
-    proc::{self, CPUData, NetworkData},
-    tags::provider,
+    proc::{
+        self,
+        constants::{ETC_PATH, PROC_PATH},
+        CPUData, NetworkData,
+    },
+    tags::{lambda::tags::resolve_runtime_from_proc, provider},
     telemetry::events::{ReportMetrics, Status},
     traces::{
         context::SpanContext,
@@ -63,6 +67,7 @@ pub struct Processor {
     aws_config: AwsConfig,
     // Flag to determine if a tracer was detected
     tracer_detected: bool,
+    runtime: Option<String>,
     config: Arc<config::Config>,
 }
 
@@ -91,6 +96,7 @@ impl Processor {
             enhanced_metrics: EnhancedMetrics::new(metrics_aggregator, Arc::clone(&config)),
             aws_config: aws_config.clone(),
             tracer_detected: false,
+            runtime: None,
             config: Arc::clone(&config),
         }
     }
@@ -166,6 +172,11 @@ impl Processor {
             } else {
                 cold_start = true;
             }
+
+            // Resolve runtime only once
+            let runtime = resolve_runtime_from_proc(PROC_PATH, ETC_PATH);
+            self.enhanced_metrics.set_runtime_tag(&runtime);
+            self.runtime = Some(runtime);
         }
 
         if proactive_initialization {
@@ -174,6 +185,13 @@ impl Processor {
                 proactive_initialization.to_string(),
             );
         }
+
+        if let Some(runtime) = &self.runtime {
+            self.span
+                .meta
+                .insert(String::from("runtime"), runtime.to_string());
+        }
+
         self.span
             .meta
             .insert(String::from("cold_start"), cold_start.to_string());

bottlecap/src/metrics/enhanced/lambda.rs

@@ -35,7 +35,7 @@ impl Lambda {
         }
     }
 
-    /// Set the dynamic value tags that are not available at compile time
+    /// Set the init tags in `dynamic_value_tags`
     pub fn set_init_tags(&mut self, proactive_initialization: bool, cold_start: bool) {
         self.dynamic_value_tags.remove("cold_start");
         self.dynamic_value_tags.remove("proactive_initialization");
@@ -52,6 +52,12 @@ impl Lambda {
         }
     }
 
+    /// Sets the runtime tag in `dynamic_value_tags`
+    pub fn set_runtime_tag(&mut self, runtime: &str) {
+        self.dynamic_value_tags
+            .insert(String::from("runtime"), runtime.to_string());
+    }
+
     fn get_dynamic_value_tags(&self) -> Option<SortedTags> {
         let vec_tags: Vec<String> = self
             .dynamic_value_tags

bottlecap/src/proc/constants.rs

@@ -2,6 +2,7 @@ pub const PROC_NET_DEV_PATH: &str = "/proc/net/dev";
 pub const PROC_STAT_PATH: &str = "/proc/stat";
 pub const PROC_UPTIME_PATH: &str = "/proc/uptime";
 pub const PROC_PATH: &str = "/proc";
+pub const ETC_PATH: &str = "/etc";
 
 pub const LAMDBA_NETWORK_INTERFACE: &str = "vinternal_1";
 pub const LAMBDA_FILE_DESCRIPTORS_DEFAULT_LIMIT: f64 = 1024.0;

bottlecap/src/tags/lambda/tags.rs

@@ -144,8 +144,7 @@ fn tags_from_env(
     tags_map
 }
 
-#[allow(dead_code)] // keeping this logic for when async runtime resolution will be supported
-fn resolve_runtime_from_proc(proc_path: &str, fallback_provided_al_path: &str) -> String {
+pub fn resolve_runtime_from_proc(proc_path: &str, fallback_provided_al_path: &str) -> String {
     let start = Instant::now();
     match fs::read_dir(proc_path) {
         Ok(proc_dir) => {