diff options
author | Kristian Aune <kraune@verizonmedia.com> | 2023-01-10 17:05:30 +0100 |
---|---|---|
committer | Kristian Aune <kraune@verizonmedia.com> | 2023-01-10 17:05:30 +0100 |
commit | 585e11b507f58b796945fa654a8d252447f05877 (patch) | |
tree | 8293daea4219ba74e84c476a692ab8dafdf221bd /container-core/src/main/java/com/yahoo/container | |
parent | 3e5d7fbea7cc63af994c9bb82ed7117f76ab127e (diff) |
Move metric definitions to ContainerMetrics.java
Diffstat (limited to 'container-core/src/main/java/com/yahoo/container')
-rw-r--r-- | container-core/src/main/java/com/yahoo/container/handler/threadpool/ThreadPoolMetric.java | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ThreadPoolMetric.java b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ThreadPoolMetric.java index 1c7a1cc4ebe..3f53b05dd6a 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ThreadPoolMetric.java +++ b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ThreadPoolMetric.java @@ -2,6 +2,7 @@ package com.yahoo.container.handler.threadpool; import com.yahoo.jdisc.Metric; +import com.yahoo.metrics.ContainerMetrics; import java.util.Map; @@ -24,28 +25,36 @@ class ThreadPoolMetric { void reportRejectRequest() { metric.add("serverRejectedRequests", 1L, defaultContext); - metric.add("jdisc.thread_pool.rejected_tasks", 1L, defaultContext); + metric.add(ContainerMetrics.JDISC_THREAD_POOL_REJECTED_TASKS.baseName(), 1L, defaultContext); } void reportThreadPoolSize(long size) { metric.set("serverThreadPoolSize", size, defaultContext); - metric.set("jdisc.thread_pool.size", size, defaultContext); + metric.set(ContainerMetrics.JDISC_THREAD_POOL_SIZE.baseName(), size, defaultContext); } - void reportMaxAllowedThreadPoolSize(long size) { metric.set("jdisc.thread_pool.max_allowed_size", size, defaultContext); } + void reportMaxAllowedThreadPoolSize(long size) { + metric.set(ContainerMetrics.JDISC_THREAD_POOL_MAX_ALLOWED_SIZE.baseName(), size, defaultContext); + } void reportActiveThreads(long threads) { metric.set("serverActiveThreads", threads, defaultContext); - metric.set("jdisc.thread_pool.active_threads", threads, defaultContext); + metric.set(ContainerMetrics.JDISC_THREAD_POOL_ACTIVE_THREADS.baseName(), threads, defaultContext); + } + + void reportWorkQueueCapacity(long capacity) { + metric.set(ContainerMetrics.JDISC_THREAD_POOL_WORK_QUEUE_CAPACITY.baseName(), capacity, defaultContext); + } + + void reportWorkQueueSize(long size) { + metric.set(ContainerMetrics.JDISC_THREAD_POOL_WORK_QUEUE_SIZE.baseName(), size, defaultContext); } - void reportWorkQueueCapacity(long capacity) { metric.set("jdisc.thread_pool.work_queue.capacity", capacity, defaultContext); } - void reportWorkQueueSize(long size) { metric.set("jdisc.thread_pool.work_queue.size", size, defaultContext); } void reportUnhandledException(Throwable t) { Metric.Context ctx = metric.createContext(Map.of( THREAD_POOL_NAME_DIMENSION, threadPoolName, "exception", t.getClass().getSimpleName())); - metric.set("jdisc.thread_pool.unhandled_exceptions", 1L, ctx); + metric.set(ContainerMetrics.JDISC_THREAD_POOL_UNHANDLED_EXCEPTIONS.baseName(), 1L, ctx); } } |