add empty tag reactor_scheduler_id for metric correctness (#190)
This commit is contained in:
@@ -26,6 +26,7 @@ import io.grpc.ServerInterceptor
|
|||||||
import io.grpc.netty.NettyServerBuilder
|
import io.grpc.netty.NettyServerBuilder
|
||||||
import io.grpc.protobuf.services.ProtoReflectionService
|
import io.grpc.protobuf.services.ProtoReflectionService
|
||||||
import io.micrometer.core.instrument.Metrics
|
import io.micrometer.core.instrument.Metrics
|
||||||
|
import io.micrometer.core.instrument.Tag
|
||||||
import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics
|
import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
import org.springframework.scheduling.concurrent.CustomizableThreadFactory
|
import org.springframework.scheduling.concurrent.CustomizableThreadFactory
|
||||||
@@ -95,7 +96,8 @@ open class GrpcServer(
|
|||||||
ExecutorServiceMetrics.monitor(
|
ExecutorServiceMetrics.monitor(
|
||||||
Metrics.globalRegistry,
|
Metrics.globalRegistry,
|
||||||
pool,
|
pool,
|
||||||
"fixed-grpc-executor"
|
"fixed-grpc-executor",
|
||||||
|
Tag.of("reactor_scheduler_id", "_")
|
||||||
)
|
)
|
||||||
else
|
else
|
||||||
pool
|
pool
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package io.emeraldpay.dshackle.config.context
|
|||||||
|
|
||||||
import io.emeraldpay.dshackle.config.MonitoringConfig
|
import io.emeraldpay.dshackle.config.MonitoringConfig
|
||||||
import io.micrometer.core.instrument.Metrics
|
import io.micrometer.core.instrument.Metrics
|
||||||
|
import io.micrometer.core.instrument.Tag
|
||||||
import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics
|
import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics
|
||||||
import org.springframework.context.annotation.Bean
|
import org.springframework.context.annotation.Bean
|
||||||
import org.springframework.context.annotation.Configuration
|
import org.springframework.context.annotation.Configuration
|
||||||
@@ -45,7 +46,8 @@ open class SchedulersConfig {
|
|||||||
ExecutorServiceMetrics.monitor(
|
ExecutorServiceMetrics.monitor(
|
||||||
Metrics.globalRegistry,
|
Metrics.globalRegistry,
|
||||||
pool,
|
pool,
|
||||||
name
|
name,
|
||||||
|
Tag.of("reactor_scheduler_id", "_")
|
||||||
)
|
)
|
||||||
else
|
else
|
||||||
pool
|
pool
|
||||||
|
|||||||
Reference in New Issue
Block a user