azure component provider

Author: zeitlinger

azure-resources/build.gradle.kts

@@ -15,6 +15,7 @@ java {
 
 dependencies {
   api("io.opentelemetry:opentelemetry-api")
+  compileOnly("io.opentelemetry:opentelemetry-api-incubator")
   api("io.opentelemetry:opentelemetry-sdk")
 
   implementation("io.opentelemetry.semconv:opentelemetry-semconv")
@@ -26,6 +27,7 @@ dependencies {
 
   testImplementation("io.opentelemetry.semconv:opentelemetry-semconv-incubating")
   testImplementation("io.opentelemetry:opentelemetry-sdk-extension-autoconfigure")
+  testImplementation("io.opentelemetry:opentelemetry-api-incubator")
   testImplementation("io.opentelemetry:opentelemetry-sdk-testing")
 
 //  testImplementation("org.mockito:mockito-core")

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureAksResourceProvider.java

@@ -56,7 +56,7 @@ public AzureAksResourceProvider() {
   @Override
   public int order() {
     // run after the fast cloud resource providers that only check environment variables
-    // and before the AKS provider
+    // and before the VM provider
     return 100;
   }
 

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureResourceDetector.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.contrib.azure.resource;
+
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
+import io.opentelemetry.sdk.autoconfigure.spi.ResourceProvider;
+import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import io.opentelemetry.sdk.resources.Resource;
+import io.opentelemetry.sdk.resources.ResourceBuilder;
+
+public class AzureResourceDetector implements ComponentProvider<Resource> {
+
+  @Override
+  public Class<Resource> getType() {
+    return Resource.class;
+  }
+
+  @Override
+  public String getName() {
+    return "azure";
+  }
+
+  @Override
+  public Resource create(DeclarativeConfigProperties config) {
+    Builder builder = new Builder();
+    builder.add(new AzureFunctionsResourceProvider());
+    builder.add(new AzureAppServiceResourceProvider());
+    builder.add(new AzureContainersResourceProvider());
+    builder.addIfEmpty(new AzureAksResourceProvider());
+    builder.addIfEmpty(new AzureVmResourceProvider());
+    return builder.builder.build();
+  }
+
+  static class Builder {
+    ResourceBuilder builder = Resource.builder();
+    int attributesCount = 0;
+
+    @SuppressWarnings("NullAway")
+    private void add(
+        ResourceProvider provider) {
+      Attributes attributes = provider.createResource(null).getAttributes();
+      builder.putAll(attributes);
+      attributesCount += attributes.size();
+    }
+
+    private void addIfEmpty(
+        ResourceProvider provider) {
+      if (attributesCount == 0) {
+        add(provider);
+      }
+    }
+
+  }
+
+}

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureVmResourceProvider.java

@@ -84,7 +84,7 @@ public AzureVmResourceProvider() {
   public int order() {
     // run after the fast cloud resource providers that only check environment variables
     // and after the AKS provider
-    return 100;
+    return 101;
   }
 
   @Override

azure-resources/src/main/resources/META-INF/services/io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider

@@ -0,0 +1 @@
+io.opentelemetry.contrib.azure.resource.AzureResourceDetector

azure-resources/src/test/java/io/opentelemetry/contrib/azure/resource/ComponentProviderTest.java

@@ -0,0 +1,21 @@
+package io.opentelemetry.contrib.azure.resource;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.opentelemetry.sdk.autoconfigure.internal.SpiHelper;
+import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import java.util.List;
+import org.junit.jupiter.api.Test;
+
+public class ComponentProviderTest {
+
+  @Test
+  @SuppressWarnings("rawtypes")
+  void providerIsLoaded() {
+    List<ComponentProvider> providers = SpiHelper.create(
+            ComponentProviderTest.class.getClassLoader())
+        .load(ComponentProvider.class);
+    assertThat(providers).extracting(ComponentProvider::getName)
+        .containsExactly("azure");
+  }
+}