Merge pull request #64 from p2p-org/monitor-grpc-pool-only-if-extended
more metrics for grpc executor - only if extended enabled
This commit is contained in:
@@ -67,14 +67,18 @@ open class GrpcServer(
|
|||||||
serverBuilder.addService(it)
|
serverBuilder.addService(it)
|
||||||
}
|
}
|
||||||
|
|
||||||
serverBuilder.executor(
|
val pool = Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build())
|
||||||
ExecutorServiceMetrics.monitor(
|
|
||||||
Metrics.globalRegistry,
|
|
||||||
Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()),
|
|
||||||
"fixed-grpc-executor",
|
|
||||||
"grpc_"
|
|
||||||
)
|
|
||||||
|
|
||||||
|
serverBuilder.executor(
|
||||||
|
if (mainConfig.monitoring.enableExtended)
|
||||||
|
ExecutorServiceMetrics.monitor(
|
||||||
|
Metrics.globalRegistry,
|
||||||
|
pool,
|
||||||
|
"fixed-grpc-executor",
|
||||||
|
"grpc_"
|
||||||
|
)
|
||||||
|
else
|
||||||
|
pool
|
||||||
)
|
)
|
||||||
|
|
||||||
val server = serverBuilder.build()
|
val server = serverBuilder.build()
|
||||||
|
|||||||
Reference in New Issue
Block a user