Ran sportlessApply

Author: stanley-cheung

grpc-client-spring-boot-starter/src/main/java/net/devh/boot/grpc/client/metrics/MetricsClientStreamTracers.java

@@ -173,8 +173,8 @@ static final class CallAttemptsTracerFactory extends ClientStreamTracer.Factory
             // Record here in case newClientStreamTracer() would never be called.
             this.metricsClientMeters.getAttemptCounter()
                     .withTags(Tags.of("grpc.method", fullMethodName,
-                                      "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
-                                      "instrumentation_version", Constants.PROJECT_VERSION))
+                            "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
+                            "instrumentation_version", Constants.PROJECT_VERSION))
                     .increment();
         }
 
@@ -195,8 +195,8 @@ public ClientStreamTracer newClientStreamTracer(StreamInfo info, Metadata metada
             if (attemptsPerCall.get() > 0) {
                 this.metricsClientMeters.getAttemptCounter()
                         .withTags((Tags.of("grpc.method", fullMethodName,
-                                           "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
-                                           "instrumentation_version", Constants.PROJECT_VERSION)))
+                                "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
+                                "instrumentation_version", Constants.PROJECT_VERSION)))
                         .increment();
             }
             if (!info.isTransparentRetry()) {

grpc-client-spring-boot-starter/src/test/java/net/devh/boot/grpc/client/metrics/MetricsClientStreamTracersTest.java

@@ -160,9 +160,9 @@ void clientBasicMetrics() {
 
         Tags expectedTags =
                 Tags.of(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME,
-                    GRPC_STATUS_TAG_KEY, Status.Code.OK.toString(),
-                    INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
-                    INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
+                        GRPC_STATUS_TAG_KEY, Status.Code.OK.toString(),
+                        INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
+                        INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
 
         HistogramSnapshot attemptDurationSnapshot = meterRegistry.get(CLIENT_ATTEMPT_DURATION)
                 .tags(expectedTags)
@@ -228,9 +228,9 @@ void recordAttemptMetrics() {
 
         Tags expectedUnailableStatusTags =
                 Tags.of(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME,
-                    GRPC_STATUS_TAG_KEY, Status.Code.UNAVAILABLE.toString(),
-                    INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
-                    INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
+                        GRPC_STATUS_TAG_KEY, Status.Code.UNAVAILABLE.toString(),
+                        INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
+                        INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
 
         assertThat(meterRegistry.get(CLIENT_ATTEMPT_STARTED)
                 .tag(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME)
@@ -268,9 +268,9 @@ void recordAttemptMetrics() {
 
         Tags expectedNotFoundStatusTags =
                 Tags.of(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME,
-                    GRPC_STATUS_TAG_KEY, Status.Code.NOT_FOUND.toString(),
-                    INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
-                    INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
+                        GRPC_STATUS_TAG_KEY, Status.Code.NOT_FOUND.toString(),
+                        INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
+                        INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
 
         assertThat(meterRegistry.get(CLIENT_ATTEMPT_STARTED)
                 .tag(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME)
@@ -369,9 +369,9 @@ void recordAttemptMetrics() {
 
         Tags expectedOKStatusTags =
                 Tags.of(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME,
-                    GRPC_STATUS_TAG_KEY, Status.Code.OK.toString(),
-                    INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
-                    INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
+                        GRPC_STATUS_TAG_KEY, Status.Code.OK.toString(),
+                        INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
+                        INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
 
         assertThat(meterRegistry.get(CLIENT_ATTEMPT_STARTED)
                 .tag(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME)
@@ -420,9 +420,9 @@ void clientStreamNeverCreatedStillRecordMetrics() {
 
         Tags expectedDeadlineExceededStatusTags =
                 Tags.of(GRPC_METHOD_TAG_KEY, FULL_METHOD_NAME,
-                    GRPC_STATUS_TAG_KEY, Status.Code.DEADLINE_EXCEEDED.toString(),
-                    INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
-                    INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
+                        GRPC_STATUS_TAG_KEY, Status.Code.DEADLINE_EXCEEDED.toString(),
+                        INSTRUMENTATION_SOURCE_TAG_KEY, INSTRUMENTATION_SOURCE_TAG_VALUE,
+                        INSTRUMENTATION_VERSION_TAG_KEY, INSTRUMENTATION_VERSION_TAG_VALUE);
 
         HistogramSnapshot attemptDurationSnapshot = meterRegistry.get(CLIENT_ATTEMPT_DURATION)
                 .tags(expectedDeadlineExceededStatusTags)

grpc-server-spring-boot-starter/src/main/java/net/devh/boot/grpc/server/metrics/MetricsServerStreamTracers.java

@@ -102,8 +102,8 @@ private static final class ServerTracer extends ServerStreamTracer {
         public void serverCallStarted(ServerCallInfo<?, ?> callInfo) {
             this.metricsServerMeters.getServerCallCounter()
                     .withTags(Tags.of("grpc.method", this.fullMethodName,
-                                      "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
-                                      "instrumentation_version", Constants.PROJECT_VERSION))
+                            "instrumentation_source", Constants.INSTRUMENTATION_SOURCE_TAG_VALUE,
+                            "instrumentation_version", Constants.PROJECT_VERSION))
                     .increment();
         }