more metrics for grpc executor - only if extended enabled

2022-12-05 13:41:27 +04:00
parent 8372799cfd
commit a9763bb6a4
1 changed files with 11 additions and 7 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt
@@ -67,14 +67,18 @@ open class GrpcServer(
            serverBuilder.addService(it)
        }

-        serverBuilder.executor(
-            ExecutorServiceMetrics.monitor(
-                Metrics.globalRegistry,
-                Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()),
-                "fixed-grpc-executor",
-                "grpc_"
-            )
+        val pool = Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build())

+        serverBuilder.executor(
+            if (mainConfig.monitoring.enableExtended)
+                ExecutorServiceMetrics.monitor(
+                    Metrics.globalRegistry,
+                    pool,
+                    "fixed-grpc-executor",
+                    "grpc_"
+                )
+            else
+                pool
        )

        val server = serverBuilder.build()