format

Author: zeitlinger

instrumentation/ktor/ktor-1.0/library/src/main/kotlin/io/opentelemetry/instrumentation/ktor/v1_0/KtorServerTracing.kt

@@ -48,7 +48,7 @@ class KtorServerTracing private constructor(
     fun setStatusExtractor(
       extractor: (SpanStatusExtractor<ApplicationRequest, ApplicationResponse>) -> SpanStatusExtractor<in ApplicationRequest, in ApplicationResponse>
     ) {
-      serverBuilder.setStatusExtractor{ prevExtractor ->
+      serverBuilder.setStatusExtractor { prevExtractor ->
         SpanStatusExtractor { spanStatusBuilder: SpanStatusBuilder,
                               request: ApplicationRequest,
                               response: ApplicationResponse?,

instrumentation/ktor/ktor-2.0/library/src/main/kotlin/io/opentelemetry/instrumentation/ktor/v2_0/server/KtorServerTracing.kt

@@ -59,13 +59,16 @@ class KtorServerTracing private constructor(
     }
 
     fun spanStatusExtractor(extract: SpanStatusData.(SpanStatusExtractor<ApplicationRequest, ApplicationResponse>) -> Unit) {
-      serverBuilder.setStatusExtractor{ prevExtractor ->
+      serverBuilder.setStatusExtractor { prevExtractor ->
         SpanStatusExtractor { spanStatusBuilder: SpanStatusBuilder,
                               request: ApplicationRequest,
                               response: ApplicationResponse?,
                               throwable: Throwable? ->
           @Suppress("UNCHECKED_CAST")
-          extract(SpanStatusData(spanStatusBuilder, request, response, throwable), prevExtractor as SpanStatusExtractor<ApplicationRequest, ApplicationResponse>)
+          extract(
+            SpanStatusData(spanStatusBuilder, request, response, throwable),
+            prevExtractor as SpanStatusExtractor<ApplicationRequest, ApplicationResponse>
+          )
         }
       }
     }

instrumentation/pekko/pekko-http-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/server/PekkoHttpServerSingletons.java

@@ -17,10 +17,11 @@ public final class PekkoHttpServerSingletons {
   private static final Instrumenter<HttpRequest, HttpResponse> INSTRUMENTER;
 
   static {
-    INSTRUMENTER = JavaagentHttpServerInstrumenterBuilder.create(
-        PekkoHttpUtil.instrumentationName(),
-        new PekkoHttpServerAttributesGetter(),
-        Optional.of(PekkoHttpServerHeaders.INSTANCE));
+    INSTRUMENTER =
+        JavaagentHttpServerInstrumenterBuilder.create(
+            PekkoHttpUtil.instrumentationName(),
+            new PekkoHttpServerAttributesGetter(),
+            Optional.of(PekkoHttpServerHeaders.INSTANCE));
   }
 
   public static Instrumenter<HttpRequest, HttpResponse> instrumenter() {

instrumentation/ratpack/ratpack-1.7/library/src/main/java/io/opentelemetry/instrumentation/ratpack/v1_7/RatpackTelemetryBuilder.java

@@ -31,12 +31,18 @@ public final class RatpackTelemetryBuilder {
   private final DefaultHttpServerTelemetryBuilder<Request, Response> serverBuilder;
 
   RatpackTelemetryBuilder(OpenTelemetry openTelemetry) {
-    clientBuilder = new DefaultHttpClientTelemetryBuilder<>(INSTRUMENTATION_NAME,
-           openTelemetry,
-        RatpackHttpClientAttributesGetter.INSTANCE,
-           Optional.of(RequestHeaderSetter.INSTANCE));
-       serverBuilder = new DefaultHttpServerTelemetryBuilder<>(INSTRUMENTATION_NAME, openTelemetry,
-           RatpackHttpAttributesGetter.INSTANCE, Optional.of(RatpackGetter.INSTANCE));
+    clientBuilder =
+        new DefaultHttpClientTelemetryBuilder<>(
+            INSTRUMENTATION_NAME,
+            openTelemetry,
+            RatpackHttpClientAttributesGetter.INSTANCE,
+            Optional.of(RequestHeaderSetter.INSTANCE));
+    serverBuilder =
+        new DefaultHttpServerTelemetryBuilder<>(
+            INSTRUMENTATION_NAME,
+            openTelemetry,
+            RatpackHttpAttributesGetter.INSTANCE,
+            Optional.of(RatpackGetter.INSTANCE));
   }
 
   /**
@@ -47,8 +53,8 @@ public final class RatpackTelemetryBuilder {
   @CanIgnoreReturnValue
   public RatpackTelemetryBuilder addAttributeExtractor(
       AttributesExtractor<? super Request, ? super Response> attributesExtractor) {
-    clientBuilder.addAttributeExtractor((AttributesExtractor)attributesExtractor);
-       serverBuilder.addAttributesExtractor((AttributesExtractor)attributesExtractor);
+    clientBuilder.addAttributeExtractor((AttributesExtractor) attributesExtractor);
+    serverBuilder.addAttributesExtractor((AttributesExtractor) attributesExtractor);
     return this;
   }
 

instrumentation/reactor/reactor-netty/reactor-netty-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactornetty/v1_0/ReactorNettySingletons.java

@@ -37,12 +37,12 @@ public final class ReactorNettySingletons {
             new ReactorNettyHttpClientAttributesGetter(),
             Optional.of(HttpClientRequestHeadersSetter.INSTANCE));
 
-    NettyClientInstrumenterBuilder builder = new NettyClientInstrumenterBuilder(
-            INSTRUMENTATION_NAME, GlobalOpenTelemetry.get());
-        HttpClientInstrumenterBuilder.configure(CommonConfig.get(), builder);
+    NettyClientInstrumenterBuilder builder =
+        new NettyClientInstrumenterBuilder(INSTRUMENTATION_NAME, GlobalOpenTelemetry.get());
+    HttpClientInstrumenterBuilder.configure(CommonConfig.get(), builder);
     NettyClientInstrumenterFactory instrumenterFactory =
         new NettyClientInstrumenterFactory(
-           builder,
+            builder,
             connectionTelemetryEnabled
                 ? NettyConnectionInstrumentationFlag.ENABLED
                 : NettyConnectionInstrumentationFlag.DISABLED,

instrumentation/restlet/restlet-1.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/RestletSingletons.java

@@ -19,8 +19,9 @@ public final class RestletSingletons {
   private static final Instrumenter<Request, Response> INSTRUMENTER;
 
   static {
-    INSTRUMENTER = JavaagentHttpServerInstrumenterBuilder.create(
-        RestletTelemetry.builder(GlobalOpenTelemetry.get()));
+    INSTRUMENTER =
+        JavaagentHttpServerInstrumenterBuilder.create(
+            RestletTelemetry.builder(GlobalOpenTelemetry.get()));
   }
 
   public static Instrumenter<Request, Response> instrumenter() {

instrumentation/restlet/restlet-1.1/library/src/main/java/io/opentelemetry/instrumentation/restlet/v1_1/RestletTelemetryBuilder.java

@@ -26,7 +26,12 @@ public final class RestletTelemetryBuilder {
   private final DefaultHttpServerTelemetryBuilder<Request, Response> serverBuilder;
 
   RestletTelemetryBuilder(OpenTelemetry openTelemetry) {
-    serverBuilder = new DefaultHttpServerTelemetryBuilder<>(INSTRUMENTATION_NAME, openTelemetry,  RestletHttpAttributesGetter.INSTANCE, Optional.of(RestletHeadersGetter.INSTANCE));
+    serverBuilder =
+        new DefaultHttpServerTelemetryBuilder<>(
+            INSTRUMENTATION_NAME,
+            openTelemetry,
+            RestletHttpAttributesGetter.INSTANCE,
+            Optional.of(RestletHeadersGetter.INSTANCE));
   }
 
   /**

instrumentation/servlet/servlet-common/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/servlet/ServletInstrumenterBuilder.java

@@ -45,9 +45,14 @@ public Instrumenter<ServletRequestContext<REQUEST>, ServletResponseContext<RESPO
       HttpServerAttributesGetter<ServletRequestContext<REQUEST>, ServletResponseContext<RESPONSE>>
           httpAttributesGetter) {
 
-    DefaultHttpServerTelemetryBuilder<ServletRequestContext<REQUEST>, ServletResponseContext<RESPONSE>> serverBuilder = new DefaultHttpServerTelemetryBuilder<>(
-        instrumentationName, GlobalOpenTelemetry.get(), httpAttributesGetter,
-        Optional.of(new ServletRequestGetter<>(accessor)));
+    DefaultHttpServerTelemetryBuilder<
+            ServletRequestContext<REQUEST>, ServletResponseContext<RESPONSE>>
+        serverBuilder =
+            new DefaultHttpServerTelemetryBuilder<>(
+                instrumentationName,
+                GlobalOpenTelemetry.get(),
+                httpAttributesGetter,
+                Optional.of(new ServletRequestGetter<>(accessor)));
     serverBuilder.setSpanNameExtractor(e -> spanNameExtractor);
     return JavaagentHttpServerInstrumenterBuilder.createWithCustomizer(
         serverBuilder,
@@ -63,8 +68,7 @@ public Instrumenter<ServletRequestContext<REQUEST>, ServletResponseContext<RESPO
           }
 
           builder
-              .addAttributesExtractor(
-                  new ServletAdditionalAttributesExtractor<>(accessor))
+              .addAttributesExtractor(new ServletAdditionalAttributesExtractor<>(accessor))
               .setErrorCauseExtractor(new ServletErrorCauseExtractor<>(accessor));
         });
   }

instrumentation/spring/spring-webflux/spring-webflux-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/spring/webflux/v5_0/client/WebClientHelper.java

@@ -18,11 +18,11 @@
 
 public final class WebClientHelper {
 
-  private static final Instrumenter<ClientRequest, ClientResponse> instrumenter = JavaagentHttpClientInstrumenterBuilder.create(
-      "io.opentelemetry.spring-webflux-5.3",
-      WebClientHttpAttributesGetter.INSTANCE,
-      Optional.empty()
-      );
+  private static final Instrumenter<ClientRequest, ClientResponse> instrumenter =
+      JavaagentHttpClientInstrumenterBuilder.create(
+          "io.opentelemetry.spring-webflux-5.3",
+          WebClientHttpAttributesGetter.INSTANCE,
+          Optional.empty());
 
   public static void addFilter(List<ExchangeFilterFunction> exchangeFilterFunctions) {
     for (ExchangeFilterFunction filterFunction : exchangeFilterFunctions) {

instrumentation/spring/spring-webmvc/spring-webmvc-5.3/library/src/main/java/io/opentelemetry/instrumentation/spring/webmvc/v5_3/SpringWebMvcTelemetryBuilder.java

@@ -23,14 +23,16 @@ public final class SpringWebMvcTelemetryBuilder {
 
   private static final String INSTRUMENTATION_NAME = "io.opentelemetry.spring-webmvc-5.3";
 
-  private final DefaultHttpServerTelemetryBuilder<HttpServletRequest, HttpServletResponse> serverBuilder;
+  private final DefaultHttpServerTelemetryBuilder<HttpServletRequest, HttpServletResponse>
+      serverBuilder;
 
   SpringWebMvcTelemetryBuilder(OpenTelemetry openTelemetry) {
-    serverBuilder = new DefaultHttpServerTelemetryBuilder<>(
-        INSTRUMENTATION_NAME,
-        openTelemetry,
-        SpringWebMvcHttpAttributesGetter.INSTANCE,
-        Optional.of(JavaxHttpServletRequestGetter.INSTANCE));
+    serverBuilder =
+        new DefaultHttpServerTelemetryBuilder<>(
+            INSTRUMENTATION_NAME,
+            openTelemetry,
+            SpringWebMvcHttpAttributesGetter.INSTANCE,
+            Optional.of(JavaxHttpServletRequestGetter.INSTANCE));
   }
 
   /**
@@ -70,8 +72,8 @@ public SpringWebMvcTelemetryBuilder setCapturedResponseHeaders(List<String> resp
   @CanIgnoreReturnValue
   public SpringWebMvcTelemetryBuilder setSpanNameExtractor(
       Function<
-          SpanNameExtractor<HttpServletRequest>,
-          ? extends SpanNameExtractor<? super HttpServletRequest>>
+              SpanNameExtractor<HttpServletRequest>,
+              ? extends SpanNameExtractor<? super HttpServletRequest>>
           spanNameExtractor) {
     serverBuilder.setSpanNameExtractor(spanNameExtractor);
     return this;