From 37a8a6b1c4d095145c63f27a031dbd7493215733 Mon Sep 17 00:00:00 2001 From: a10zn8 Date: Sat, 3 Dec 2022 20:45:29 +0400 Subject: [PATCH] more metrics for grpc executor --- src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt b/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt index 2102fe77..65406c21 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt @@ -21,6 +21,8 @@ import io.emeraldpay.dshackle.config.MainConfig import io.emeraldpay.dshackle.monitoring.accesslog.AccessHandlerGrpc import io.grpc.Server import io.grpc.netty.NettyServerBuilder +import io.micrometer.core.instrument.Metrics +import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics import org.slf4j.LoggerFactory import org.springframework.beans.factory.annotation.Autowired import org.springframework.stereotype.Service @@ -66,10 +68,12 @@ open class GrpcServer( } serverBuilder.executor( - Executors.newFixedThreadPool( - 20, - ThreadFactoryBuilder().setNameFormat("custom-grpc-%d").build() + ExecutorServiceMetrics.monitor( + Metrics.globalRegistry, + Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()), + "fixed-grpc-executor" ) + ) val server = serverBuilder.build()