remove schedulers metrics prefix (#188)

This commit is contained in:
a10zn8
2023-03-29 18:44:39 +04:00
committed by GitHub
parent 8a2455fcd1
commit e9061be3d7
2 changed files with 9 additions and 11 deletions

View File

@@ -95,8 +95,7 @@ open class GrpcServer(
ExecutorServiceMetrics.monitor( ExecutorServiceMetrics.monitor(
Metrics.globalRegistry, Metrics.globalRegistry,
pool, pool,
"fixed-grpc-executor", "fixed-grpc-executor"
"grpc_"
) )
else else
pool pool

View File

@@ -16,37 +16,36 @@ import java.util.concurrent.Executors
open class SchedulersConfig { open class SchedulersConfig {
@Bean @Bean
open fun rpcScheduler(monitoringConfig: MonitoringConfig): Scheduler { open fun rpcScheduler(monitoringConfig: MonitoringConfig): Scheduler {
return makeScheduler("blockchain-rpc-scheduler", "blockchain_rpc", 30, monitoringConfig) return makeScheduler("blockchain-rpc-scheduler", 30, monitoringConfig)
} }
@Bean @Bean
open fun trackTxScheduler(monitoringConfig: MonitoringConfig): Scheduler { open fun trackTxScheduler(monitoringConfig: MonitoringConfig): Scheduler {
return makeScheduler("tracktx-scheduler", "tracktx", 5, monitoringConfig) return makeScheduler("tracktx-scheduler", 5, monitoringConfig)
} }
@Bean @Bean
open fun headMergedScheduler(monitoringConfig: MonitoringConfig): Scheduler { open fun headMergedScheduler(monitoringConfig: MonitoringConfig): Scheduler {
return makeScheduler("head-scheduler", "head_merge", 5, monitoringConfig) return makeScheduler("head-scheduler", 5, monitoringConfig)
} }
@Bean @Bean
open fun grpcChannelExecutor(monitoringConfig: MonitoringConfig): Executor { open fun grpcChannelExecutor(monitoringConfig: MonitoringConfig): Executor {
return makePool("grpc-client-channel", "grpc_client_channel", 10, monitoringConfig) return makePool("grpc-client-channel", 10, monitoringConfig)
} }
private fun makeScheduler(name: String, prefix: String, size: Int, monitoringConfig: MonitoringConfig): Scheduler { private fun makeScheduler(name: String, size: Int, monitoringConfig: MonitoringConfig): Scheduler {
return Schedulers.fromExecutorService(makePool(name, prefix, size, monitoringConfig)) return Schedulers.fromExecutorService(makePool(name, size, monitoringConfig))
} }
private fun makePool(name: String, prefix: String, size: Int, monitoringConfig: MonitoringConfig): ExecutorService { private fun makePool(name: String, size: Int, monitoringConfig: MonitoringConfig): ExecutorService {
val pool = Executors.newFixedThreadPool(size, CustomizableThreadFactory("$name-")) val pool = Executors.newFixedThreadPool(size, CustomizableThreadFactory("$name-"))
return if (monitoringConfig.enableExtended) return if (monitoringConfig.enableExtended)
ExecutorServiceMetrics.monitor( ExecutorServiceMetrics.monitor(
Metrics.globalRegistry, Metrics.globalRegistry,
pool, pool,
name, name
prefix
) )
else else
pool pool