StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #61 from p2p-org/metrics-for-grpc-executor

Browse Source 
more metrics for grpc executor
This commit is contained in:
a10zn8
2022-12-03 20:55:41 +04:00
committed by GitHub
parent 0fd4a597fb 37a8a6b1c4
commit 0f1383b7f0
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt
View File

@@ -21,6 +21,8 @@ import io.emeraldpay.dshackle.config.MainConfig
import io.emeraldpay.dshackle.monitoring.accesslog.AccessHandlerGrpc import io.emeraldpay.dshackle.monitoring.accesslog.AccessHandlerGrpc
import io.grpc.Server import io.grpc.Server
import io.grpc.netty.NettyServerBuilder 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.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Autowired import org.springframework.beans.factory.annotation.Autowired
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@@ -66,10 +68,12 @@ open class GrpcServer(
} }
serverBuilder.executor( serverBuilder.executor(
Executors.newFixedThreadPool( ExecutorServiceMetrics.monitor(
20, Metrics.globalRegistry,
ThreadFactoryBuilder().setNameFormat("custom-grpc-%d").build() Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()),
"fixed-grpc-executor"
) )
) )
val server = serverBuilder.build() val server = serverBuilder.build()