spotless

Author: JonasKunz

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

@@ -10,9 +10,9 @@
 
 import io.opentelemetry.api.common.Attributes;
 import io.opentelemetry.api.metrics.MeterProvider;
-import io.opentelemetry.exporter.internal.metrics.ExporterInstrumentation;
 import io.opentelemetry.exporter.internal.FailedExportException;
 import io.opentelemetry.exporter.internal.marshal.Marshaler;
+import io.opentelemetry.exporter.internal.metrics.ExporterInstrumentation;
 import io.opentelemetry.sdk.common.CompletableResultCode;
 import io.opentelemetry.sdk.common.InternalTelemetrySchemaVersion;
 import io.opentelemetry.sdk.internal.ComponentId;
@@ -59,8 +59,7 @@ public GrpcExporter(
             meterProviderSupplier,
             componentId,
             exporterType,
-            healthMetricAttributes
-        );
+            healthMetricAttributes);
   }
 
   public CompletableResultCode export(T exportRequest, int numItems) {
@@ -129,7 +128,9 @@ private void onResponse(
   }
 
   private void onError(
-      CompletableResultCode result, ExporterInstrumentation.Recording metricRecording, Throwable e) {
+      CompletableResultCode result,
+      ExporterInstrumentation.Recording metricRecording,
+      Throwable e) {
     metricRecording.finishFailed(e, Attributes.empty());
     logger.log(
         Level.SEVERE,

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

@@ -65,7 +65,8 @@ public class GrpcExporterBuilder<T extends Marshaler> {
   private TlsConfigHelper tlsConfigHelper = new TlsConfigHelper();
   @Nullable private RetryPolicy retryPolicy = RetryPolicy.getDefault();
   private Supplier<MeterProvider> meterProviderSupplier = GlobalOpenTelemetry::getMeterProvider;
-  private InternalTelemetrySchemaVersion internalTelemetrySchemaVersion = InternalTelemetrySchemaVersion.LEGACY;
+  private InternalTelemetrySchemaVersion internalTelemetrySchemaVersion =
+      InternalTelemetrySchemaVersion.LEGACY;
 
   private ClassLoader serviceClassLoader = GrpcExporterBuilder.class.getClassLoader();
   @Nullable private ExecutorService executorService;

exporters/common/src/main/java/io/opentelemetry/exporter/internal/http/HttpExporter.java

@@ -7,10 +7,10 @@
 
 import io.opentelemetry.api.common.Attributes;
 import io.opentelemetry.api.metrics.MeterProvider;
-import io.opentelemetry.exporter.internal.metrics.ExporterInstrumentation;
 import io.opentelemetry.exporter.internal.FailedExportException;
 import io.opentelemetry.exporter.internal.grpc.GrpcExporterUtil;
 import io.opentelemetry.exporter.internal.marshal.Marshaler;
+import io.opentelemetry.exporter.internal.metrics.ExporterInstrumentation;
 import io.opentelemetry.sdk.common.CompletableResultCode;
 import io.opentelemetry.sdk.common.InternalTelemetrySchemaVersion;
 import io.opentelemetry.sdk.internal.ComponentId;
@@ -56,8 +56,7 @@ public HttpExporter(
             meterProviderSupplier,
             componentId,
             exporterType,
-            healthMetricAttributes
-        );
+            healthMetricAttributes);
   }
 
   public CompletableResultCode export(T exportRequest, int numItems) {
@@ -118,7 +117,9 @@ private void onResponse(
   }
 
   private void onError(
-          CompletableResultCode result, ExporterInstrumentation.Recording metricRecording, Throwable e) {
+      CompletableResultCode result,
+      ExporterInstrumentation.Recording metricRecording,
+      Throwable e) {
     metricRecording.finishFailed(e, Attributes.empty());
     logger.log(
         Level.SEVERE,

exporters/common/src/main/java/io/opentelemetry/exporter/internal/http/HttpExporterBuilder.java

@@ -63,13 +63,13 @@ public final class HttpExporterBuilder<T extends Marshaler> {
   private TlsConfigHelper tlsConfigHelper = new TlsConfigHelper();
   @Nullable private RetryPolicy retryPolicy = RetryPolicy.getDefault();
   private Supplier<MeterProvider> meterProviderSupplier = GlobalOpenTelemetry::getMeterProvider;
-  private InternalTelemetrySchemaVersion internalTelemetrySchemaVersion = InternalTelemetrySchemaVersion.LEGACY;
+  private InternalTelemetrySchemaVersion internalTelemetrySchemaVersion =
+      InternalTelemetrySchemaVersion.LEGACY;
   private ClassLoader serviceClassLoader = HttpExporterBuilder.class.getClassLoader();
   @Nullable private ExecutorService executorService;
 
   public HttpExporterBuilder(
-      ComponentId.StandardExporterType exporterType,
-      String defaultEndpoint) {
+      ComponentId.StandardExporterType exporterType, String defaultEndpoint) {
     this.exporterType = exporterType;
 
     endpoint = defaultEndpoint;
@@ -176,8 +176,7 @@ private static ComponentId.StandardExporterType mapToJsonTypeIfPossible(
 
   @SuppressWarnings("BuilderReturnThis")
   public HttpExporterBuilder<T> copy() {
-    HttpExporterBuilder<T> copy =
-        new HttpExporterBuilder<>(exporterType, endpoint);
+    HttpExporterBuilder<T> copy = new HttpExporterBuilder<>(exporterType, endpoint);
     copy.endpoint = endpoint;
     copy.timeoutNanos = timeoutNanos;
     copy.connectTimeoutNanos = connectTimeoutNanos;

exporters/common/src/main/java/io/opentelemetry/exporter/internal/metrics/ExporterInstrumentation.java

@@ -13,8 +13,8 @@
 import javax.annotation.Nullable;
 
 /**
- * This class is internal and is hence not for public use. Its APIs are unstable and can change
- * at any time.
+ * This class is internal and is hence not for public use. Its APIs are unstable and can change at
+ * any time.
  */
 public class ExporterInstrumentation implements ExporterMetrics {
 
@@ -32,11 +32,19 @@ public ExporterInstrumentation(
         implementation = NoopExporterMetrics.INSTANCE;
         break;
       case LEGACY:
-        implementation = LegacyExporterMetrics.isSupportedType(exporterType) ? new LegacyExporterMetrics(meterProviderSupplier,exporterType) : NoopExporterMetrics.INSTANCE;
+        implementation =
+            LegacyExporterMetrics.isSupportedType(exporterType)
+                ? new LegacyExporterMetrics(meterProviderSupplier, exporterType)
+                : NoopExporterMetrics.INSTANCE;
         break;
       case V1_33:
       case LATEST:
-        implementation = new SemConvExporterMetrics(meterProviderSupplier, exporterType.signal(), componentId, additionalAttributes == null ? Attributes.empty() : additionalAttributes);
+        implementation =
+            new SemConvExporterMetrics(
+                meterProviderSupplier,
+                exporterType.signal(),
+                componentId,
+                additionalAttributes == null ? Attributes.empty() : additionalAttributes);
         break;
       default:
         throw new IllegalStateException("Unhandled case: " + schema);
@@ -49,8 +57,8 @@ public Recording startRecordingExport(int itemCount) {
   }
 
   /**
-   * This class is internal and is hence not for public use. Its APIs are unstable and can change
-   * at any time.
+   * This class is internal and is hence not for public use. Its APIs are unstable and can change at
+   * any time.
    */
   public static class Recording extends ExporterMetrics.Recording {
 
@@ -61,7 +69,8 @@ private Recording(ExporterMetrics.Recording delegate) {
     }
 
     /**
-     * Callback to notify that the export has failed with the given {@link Throwable} as failure cause.
+     * Callback to notify that the export has failed with the given {@link Throwable} as failure
+     * cause.
      *
      * @param failureCause the cause of the failure
      * @param requestAttributes additional attributes to add to request metrics

exporters/common/src/main/java/io/opentelemetry/exporter/internal/metrics/ExporterMetrics.java

@@ -1,3 +1,8 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
 package io.opentelemetry.exporter.internal.metrics;
 
 import io.opentelemetry.api.common.Attributes;
@@ -55,7 +60,8 @@ private void ensureEndedOnce() {
     /**
      * Invoked when the export has finished, either successfully or failed.
      *
-     * @param errorType null if the export was successful, otherwise a failure reason suitable for the error.type attribute
+     * @param errorType null if the export was successful, otherwise a failure reason suitable for
+     *     the error.type attribute
      * @param requestAttributes additional attributes to add to request metrics
      */
     protected abstract void doFinish(@Nullable String errorType, Attributes requestAttributes);

exporters/common/src/main/java/io/opentelemetry/exporter/internal/metrics/LegacyExporterMetrics.java

@@ -18,7 +18,8 @@
 import javax.annotation.Nullable;
 
 /**
- * Implements health metrics for exporters which were defined prior to the standardization in semantic conventions.
+ * Implements health metrics for exporters which were defined prior to the standardization in
+ * semantic conventions.
  *
  * <p>This class is internal and is hence not for public use. Its APIs are unstable and can change
  * at any time.
@@ -43,12 +44,12 @@ public class LegacyExporterMetrics implements ExporterMetrics {
 
   LegacyExporterMetrics(
       Supplier<MeterProvider> meterProviderSupplier,
-      ComponentId.StandardExporterType exporterType
-    ) {
+      ComponentId.StandardExporterType exporterType) {
     this.meterProviderSupplier = meterProviderSupplier;
     this.exporterName = getExporterName(exporterType);
     this.transportName = getTransportName(exporterType);
-    this.seenAttrs = Attributes.builder().put(ATTRIBUTE_KEY_TYPE, getTypeString(exporterType.signal())).build();
+    this.seenAttrs =
+        Attributes.builder().put(ATTRIBUTE_KEY_TYPE, getTypeString(exporterType.signal())).build();
     this.successAttrs = this.seenAttrs.toBuilder().put(ATTRIBUTE_KEY_SUCCESS, true).build();
     this.failedAttrs = this.seenAttrs.toBuilder().put(ATTRIBUTE_KEY_SUCCESS, false).build();
   }

exporters/common/src/main/java/io/opentelemetry/exporter/internal/metrics/NoopExporterMetrics.java

@@ -1,3 +1,8 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
 package io.opentelemetry.exporter.internal.metrics;
 
 import io.opentelemetry.api.common.Attributes;
@@ -17,6 +22,6 @@ private static class NoopRecording extends Recording {
     private static final NoopRecording INSTANCE = new NoopRecording();
 
     @Override
-    protected void doFinish(@Nullable String errorType, Attributes requestAttributes) { }
+    protected void doFinish(@Nullable String errorType, Attributes requestAttributes) {}
   }
 }

exporters/common/src/main/java/io/opentelemetry/exporter/internal/metrics/SemConvExporterMetrics.java

@@ -48,7 +48,6 @@ public SemConvExporterMetrics(
     this.additionalAttributes = additionalAttributes;
   }
 
-
   @Override
   public ExporterMetrics.Recording startRecordingExport(int itemCount) {
     return new Recording(itemCount);
@@ -97,7 +96,6 @@ private Attributes allAttributes() {
     return allAttributes;
   }
 
-
   private LongUpDownCounter inflight() {
     LongUpDownCounter inflight = this.inflight;
     if (inflight == null || isNoop(inflight)) {

exporters/common/src/test/java/io/opentelemetry/exporter/internal/grpc/GrpcExporterBuilderTest.java

@@ -9,8 +9,8 @@
 
 import io.opentelemetry.exporter.internal.compression.GzipCompressor;
 import io.opentelemetry.exporter.internal.marshal.Marshaler;
-import java.net.URI;
 import io.opentelemetry.sdk.internal.ComponentId;
+import java.net.URI;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;