feat: Cloud Run Jobs support

Author: kberezin-nshl

google-cloud-logging/src/main/java/com/google/cloud/logging/MetadataLoader.java

@@ -40,6 +40,7 @@ public final class MetadataLoader {
           .put(Label.FunctionName, this::getFunctionName)
           .put(Label.InstanceId, this::getInstanceId)
           .put(Label.InstanceName, this::getInstanceName)
+          .put(Label.JobName, this::getCloudRunJobName)
           .put(Label.CloudRunLocation, this::getCloudRunLocation)
           .put(Label.GKELocation, this::getGKELocation)
           .put(Label.ModuleId, this::getModuleId)
@@ -182,6 +183,10 @@ private String getRegion() {
     return null;
   }
 
+  private String getCloudRunJobName() {
+    return getter.getEnv("CLOUD_RUN_JOB");
+  }
+
   private String getRevisionName() {
     return getter.getEnv("K_REVISION");
   }

google-cloud-logging/src/main/java/com/google/cloud/logging/MonitoredResourceUtil.java

@@ -42,6 +42,7 @@ protected enum Label {
     FunctionName("function_name"),
     InstanceId("instance_id"),
     InstanceName("instance_name"),
+    JobName("job_name"),
     CloudRunLocation("location"),
     GKELocation("location"),
     ModuleId("module_id"),
@@ -67,6 +68,7 @@ String getKey() {
 
   private enum Resource {
     CLOUD_RUN("cloud_run_revision"),
+    CLOUD_RUN_JOB("cloud_run_job"),
     CLOUD_FUNCTION("cloud_function"),
     APP_ENGINE("gae_app"),
     GCE_INSTANCE("gce_instance"),
@@ -93,6 +95,9 @@ String getKey() {
               Label.ServiceName,
               Label.CloudRunLocation,
               Label.ConfigurationName)
+          .putAll(Resource.CLOUD_RUN_JOB.getKey(),
+              Label.JobName,
+              Label.CloudRunLocation)
           .putAll(
               Resource.APP_ENGINE.getKey(), Label.ModuleId, Label.VersionId, Label.Zone, Label.Env)
           .putAll(Resource.GCE_INSTANCE.getKey(), Label.InstanceId, Label.Zone)
@@ -177,6 +182,9 @@ private static Resource detectResourceType() {
         && getter.getEnv("K_CONFIGURATION") != null) {
       return Resource.CLOUD_RUN;
     }
+    if (getter.getEnv("CLOUD_RUN_JOB") != null) {
+      return Resource.CLOUD_RUN_JOB;
+    }
     if (getter.getEnv("GAE_INSTANCE") != null
         && getter.getEnv("GAE_SERVICE") != null
         && getter.getEnv("GAE_VERSION") != null) {

google-cloud-logging/src/test/java/com/google/cloud/logging/MonitoredResourceUtilTest.java

@@ -286,4 +286,29 @@ public void testResourceTypeCloudRun() {
     assertEquals("cloud_run_revision", response.getType());
     assertEquals(expectedLabels, response.getLabels());
   }
+
+  @Test
+  public void testResourceTypeCloudRunJob() {
+    final String mockedJobName = "mocked-job-name";
+    final ImmutableMap<String, String> expectedLabels =
+        ImmutableMap.of(
+            "project_id",
+            MonitoredResourceUtilTest.MOCKED_PROJECT_ID,
+            "job_name",
+            mockedJobName,
+            "location",
+            MOCKED_REGION);
+
+    // setup
+    expect(getterMock.getAttribute("instance/region")).andReturn(MOCKED_QUALIFIED_REGION).once();
+    expect(getterMock.getAttribute(anyString())).andReturn(null).anyTimes();
+    expect(getterMock.getEnv("CLOUD_RUN_JOB")).andReturn(mockedJobName).times(2);
+    expect(getterMock.getEnv(anyString())).andReturn(null).anyTimes();
+    replay(getterMock);
+    // exercise
+    MonitoredResource response = MonitoredResourceUtil.getResource("", "");
+    // verify
+    assertEquals("cloud_run_job", response.getType());
+    assertEquals(expectedLabels, response.getLabels());
+  }
 }