Added grpc calls latency metric

Author: alex268

jdbc/ydb-token-app/pom.xml

@@ -72,6 +72,17 @@
                 <artifactId>spring-boot-maven-plugin</artifactId>
                 <version>${spring.boot.version}</version>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.12.1</version>
+                <configuration>
+                    <release>17</release>
+                    <compilerArgs>
+                        <arg>-Xlint</arg>
+                    </compilerArgs>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 

jdbc/ydb-token-app/src/main/java/tech/ydb/apps/Application.java

@@ -67,6 +67,7 @@ public Application(Config config, SchemeService scheme, WorkloadService worload,
         this.workloadService = worload;
         this.ticker = new AppMetrics(logger, registry);
 
+        logger.info("Create fixed thread pool with size {}", config.getThreadCount());
         this.executor = Executors.newFixedThreadPool(config.getThreadCount(), this::threadFactory);
     }
 

jdbc/ydb-token-app/src/main/java/tech/ydb/apps/GrpcMetrics.java

@@ -1,5 +1,6 @@
 package tech.ydb.apps;
 
+import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 
 import javax.annotation.Nullable;
@@ -15,6 +16,7 @@
 import io.grpc.Status;
 import io.micrometer.core.instrument.Counter;
 import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Timer;
 
 /**
  *
@@ -23,6 +25,8 @@
 public class GrpcMetrics implements Consumer<ManagedChannelBuilder<?>>, ClientInterceptor {
     private static final Counter.Builder REQUEST = Counter.builder("grpc.request");
     private static final Counter.Builder RESPONSE = Counter.builder("grpc.response");
+    private static final Timer.Builder LATENCY = Timer.builder("grpc.latency")
+            .publishPercentiles(0.5, 0.9, 0.95, 0.99);
 
     private static MeterRegistry REGISTRY = null;
 
@@ -101,9 +105,11 @@ public void sendMessage(ReqT message) {
 
         private class ProxyListener extends Listener<RespT> {
             private final Listener<RespT> delegate;
+            private final long startedAt;
 
             public ProxyListener(Listener<RespT> delegate) {
                 this.delegate = delegate;
+                this.startedAt = System.currentTimeMillis();
             }
 
 
@@ -119,8 +125,11 @@ public void onMessage(RespT message) {
 
             @Override
             public void onClose(Status status, Metadata trailers) {
+                long ms = System.currentTimeMillis() - startedAt;
                 RESPONSE.tag("method", method).tag("authority", authority).tag("status", status.getCode().toString())
                         .register(registry).increment();
+                LATENCY.tag("method", method).tag("authority", authority)
+                        .register(registry).record(ms, TimeUnit.MILLISECONDS);
                 delegate.onClose(status, trailers);
             }