Add gRPC export for profiles signal type.

Changes per code review feedback

Author: jhalliday

exporters/common/src/main/java/io/opentelemetry/exporter/internal/grpc/GrpcExporterUtil.java

@@ -28,6 +28,19 @@ public final class GrpcExporterUtil {
   public static final int GRPC_STATUS_DATA_LOSS = 15;
 
   static void logUnimplemented(Logger logger, String type, @Nullable String fullErrorMessage) {
+
+    // hopefully temporary special handling for profile signal as it evolves towards stability.
+    if ("profile".equals(type)) {
+      logger.log(
+          Level.SEVERE,
+          "Failed to export profile. The profile signal type is still under development "
+              + "and the endpoint you are connecting to may not support it yet, "
+              + "or may support a different version. "
+              + "Full error message: "
+              + fullErrorMessage);
+      return;
+    }
+
     String envVar;
     switch (type) {
       case "span":
@@ -39,9 +52,6 @@ static void logUnimplemented(Logger logger, String type, @Nullable String fullEr
       case "log":
         envVar = "OTEL_LOGS_EXPORTER";
         break;
-      case "profile":
-        envVar = "OTEL_PROFILES_EXPORTER";
-        break;
       default:
         throw new IllegalStateException(
             "Unrecognized type, this is a programming bug in the OpenTelemetry SDK");

exporters/otlp/profiles/src/test/java/io/opentelemetry/exporter/otlp/profiles/OtlpGrpcProfileExporterTest.java

@@ -7,15 +7,21 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import io.opentelemetry.exporter.internal.grpc.GrpcExporter;
 import io.opentelemetry.exporter.internal.marshal.Marshaler;
 import io.opentelemetry.exporter.otlp.testing.internal.AbstractGrpcTelemetryExporterTest;
 import io.opentelemetry.exporter.otlp.testing.internal.TelemetryExporter;
 import io.opentelemetry.exporter.otlp.testing.internal.TelemetryExporterBuilder;
 import io.opentelemetry.exporter.sender.okhttp.internal.OkHttpGrpcSender;
+import io.opentelemetry.internal.testing.slf4j.SuppressLogger;
 import io.opentelemetry.proto.profiles.v1development.ResourceProfiles;
 import java.io.Closeable;
+import java.util.Collections;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import org.junit.jupiter.api.Test;
+import org.slf4j.event.Level;
+import org.slf4j.event.LoggingEvent;
 
 class OtlpGrpcProfileExporterTest
     extends AbstractGrpcTelemetryExporterTest<ProfileData, ResourceProfiles> {
@@ -31,6 +37,29 @@ void usingOkHttp() throws Exception {
     }
   }
 
+  @Test
+  @Override // whilst profile signal type is in development it uses a different error message
+  @SuppressLogger(GrpcExporter.class)
+  protected void testExport_Unimplemented() {
+    addGrpcError(12, "UNIMPLEMENTED");
+
+    TelemetryExporter<ProfileData> exporter = nonRetryingExporter();
+
+    try {
+      assertThat(
+              exporter
+                  .export(Collections.singletonList(generateFakeTelemetry()))
+                  .join(10, TimeUnit.SECONDS)
+                  .isSuccess())
+          .isFalse();
+
+      LoggingEvent log = logs.assertContains("The profile signal type is still under development");
+      assertThat(log.getLevel()).isEqualTo(Level.ERROR);
+    } finally {
+      exporter.shutdown();
+    }
+  }
+
   @Override
   protected TelemetryExporterBuilder<ProfileData> exporterBuilder() {
     return TelemetryExporterBuilder.wrap(OtlpGrpcProfileExporter.builder());

exporters/otlp/testing-internal/src/main/java/io/opentelemetry/exporter/otlp/testing/internal/AbstractGrpcTelemetryExporterTest.java

@@ -188,7 +188,8 @@ protected CompletionStage<byte[]> handleMessage(ServiceRequestContext ctx, byte[
     }
   }
 
-  @RegisterExtension LogCapturer logs = LogCapturer.create().captureForType(GrpcExporter.class);
+  @RegisterExtension
+  protected LogCapturer logs = LogCapturer.create().captureForType(GrpcExporter.class);
 
   private final String type;
   private final U resourceTelemetryInstance;
@@ -710,7 +711,7 @@ void testExport_Unavailable() {
 
   @Test
   @SuppressLogger(GrpcExporter.class)
-  void testExport_Unimplemented() {
+  protected void testExport_Unimplemented() {
     addGrpcError(12, "UNIMPLEMENTED");
 
     TelemetryExporter<T> exporter = nonRetryingExporter();
@@ -1160,11 +1161,11 @@ private List<U> toProto(List<T> telemetry) {
         .collect(Collectors.toList());
   }
 
-  private TelemetryExporter<T> nonRetryingExporter() {
+  protected TelemetryExporter<T> nonRetryingExporter() {
     return exporterBuilder().setEndpoint(server.httpUri().toString()).setRetryPolicy(null).build();
   }
 
-  private static void addGrpcError(int code, @Nullable String message) {
+  protected static void addGrpcError(int code, @Nullable String message) {
     grpcErrors.add(new ArmeriaStatusException(code, message));
   }
 }