Add cloud_run_job to MonitoredResource (open-telemetry#101)

Co-authored-by: Lalit Kumar Bhasin <lalit_fin@yahoo.com>
cijothomas · Aug 29, 2024 · 8b10ca3 · 8b10ca3
1 parent e6feb3c
commit 8b10ca3
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 0 deletions.
diff --git a/opentelemetry-stackdriver/CHANGELOG.md b/opentelemetry-stackdriver/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog
 
+## vNext
+
+### Added
+
+- Added support for `MonitoredResource::CloudRunJob` [#100](https://github.com/open-telemetry/opentelemetry-rust-contrib/issues/100)
+
 ## v0.21.0
 
 ### Changed

diff --git a/opentelemetry-stackdriver/src/lib.rs b/opentelemetry-stackdriver/src/lib.rs
@@ -553,6 +553,24 @@ impl From<LogContext> for InternalLogContext {
     fn from(cx: LogContext) -> Self {
         let mut labels = HashMap::default();
         let resource = match cx.resource {
+            MonitoredResource::CloudRunJob {
+                project_id,
+                job_name,
+                location,
+            } => {
+                labels.insert("project_id".to_string(), project_id);
+                if let Some(job_name) = job_name {
+                    labels.insert("job_name".to_string(), job_name);
+                }
+                if let Some(location) = location {
+                    labels.insert("location".to_string(), location);
+                }
+
+                proto::api::MonitoredResource {
+                    r#type: "cloud_run_job".to_owned(),
+                    labels,
+                }
+            }
             MonitoredResource::CloudRunRevision {
                 project_id,
                 service_name,
@@ -665,6 +683,11 @@ pub enum MonitoredResource {
         job: Option<String>,
         task_id: Option<String>,
     },
+    CloudRunJob {
+        project_id: String,
+        job_name: Option<String>,
+        location: Option<String>,
+    },
     CloudRunRevision {
         project_id: String,
         service_name: Option<String>,