Skip to content

K
k3s
Unverified Commit 3ebbbda3 authored by Kubernetes Prow Robot's avatar Kubernetes Prow Robot Committed by GitHub
Browse files
Options

Merge pull request #72679 from danielqsj/wqn

Mark deprecated in related workqueue metrics
parents 771baea3 9325c75f
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 7 deletions
pkg/util/workqueue/prometheus/prometheus.go
View file @ 3ebbbda3
...@@ -131,7 +131,7 @@ func (prometheusMetricsProvider) NewDeprecatedDepthMetric(name string) workqueue ...@@ -131,7 +131,7 @@ func (prometheusMetricsProvider) NewDeprecatedDepthMetric(name string) workqueue
depth := prometheus.NewGauge(prometheus.GaugeOpts{ depth := prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: name, Subsystem: name,
Name: "depth", Name: "depth",
Help: "Current depth of workqueue: " + name, Help: "(Deprecated) Current depth of workqueue: " + name,
}) })
prometheus.Register(depth) prometheus.Register(depth)
return depth return depth
...@@ -141,7 +141,7 @@ func (prometheusMetricsProvider) NewDeprecatedAddsMetric(name string) workqueue. ...@@ -141,7 +141,7 @@ func (prometheusMetricsProvider) NewDeprecatedAddsMetric(name string) workqueue.
adds := prometheus.NewCounter(prometheus.CounterOpts{ adds := prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: name, Subsystem: name,
Name: "adds", Name: "adds",
Help: "Total number of adds handled by workqueue: " + name, Help: "(Deprecated) Total number of adds handled by workqueue: " + name,
}) })
prometheus.Register(adds) prometheus.Register(adds)
return adds return adds
...@@ -151,7 +151,7 @@ func (prometheusMetricsProvider) NewDeprecatedLatencyMetric(name string) workque ...@@ -151,7 +151,7 @@ func (prometheusMetricsProvider) NewDeprecatedLatencyMetric(name string) workque
latency := prometheus.NewSummary(prometheus.SummaryOpts{ latency := prometheus.NewSummary(prometheus.SummaryOpts{
Subsystem: name, Subsystem: name,
Name: "queue_latency", Name: "queue_latency",
Help: "How long an item stays in workqueue" + name + " before being requested.", Help: "(Deprecated) How long an item stays in workqueue" + name + " before being requested.",
}) })
prometheus.Register(latency) prometheus.Register(latency)
return latency return latency
...@@ -161,7 +161,7 @@ func (prometheusMetricsProvider) NewDeprecatedWorkDurationMetric(name string) wo ...@@ -161,7 +161,7 @@ func (prometheusMetricsProvider) NewDeprecatedWorkDurationMetric(name string) wo
workDuration := prometheus.NewSummary(prometheus.SummaryOpts{ workDuration := prometheus.NewSummary(prometheus.SummaryOpts{
Subsystem: name, Subsystem: name,
Name: "work_duration", Name: "work_duration",
Help: "How long processing an item from workqueue" + name + " takes.", Help: "(Deprecated) How long processing an item from workqueue" + name + " takes.",
}) })
prometheus.Register(workDuration) prometheus.Register(workDuration)
return workDuration return workDuration
...@@ -171,7 +171,7 @@ func (prometheusMetricsProvider) NewDeprecatedUnfinishedWorkSecondsMetric(name s ...@@ -171,7 +171,7 @@ func (prometheusMetricsProvider) NewDeprecatedUnfinishedWorkSecondsMetric(name s
unfinished := prometheus.NewGauge(prometheus.GaugeOpts{ unfinished := prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: name, Subsystem: name,
Name: "unfinished_work_seconds", Name: "unfinished_work_seconds",
Help: "How many seconds of work " + name + " has done that " + Help: "(Deprecated) How many seconds of work " + name + " has done that " +
"is in progress and hasn't been observed by work_duration. Large " + "is in progress and hasn't been observed by work_duration. Large " +
"values indicate stuck threads. One can deduce the number of stuck " + "values indicate stuck threads. One can deduce the number of stuck " +
"threads by observing the rate at which this increases.", "threads by observing the rate at which this increases.",
...@@ -184,7 +184,7 @@ func (prometheusMetricsProvider) NewDeprecatedLongestRunningProcessorMicrosecond ...@@ -184,7 +184,7 @@ func (prometheusMetricsProvider) NewDeprecatedLongestRunningProcessorMicrosecond
unfinished := prometheus.NewGauge(prometheus.GaugeOpts{ unfinished := prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: name, Subsystem: name,
Name: "longest_running_processor_microseconds", Name: "longest_running_processor_microseconds",
Help: "How many microseconds has the longest running " + Help: "(Deprecated) How many microseconds has the longest running " +
"processor for " + name + " been running.", "processor for " + name + " been running.",
}) })
prometheus.Register(unfinished) prometheus.Register(unfinished)
...@@ -195,7 +195,7 @@ func (prometheusMetricsProvider) NewDeprecatedRetriesMetric(name string) workque ...@@ -195,7 +195,7 @@ func (prometheusMetricsProvider) NewDeprecatedRetriesMetric(name string) workque
retries := prometheus.NewCounter(prometheus.CounterOpts{ retries := prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: name, Subsystem: name,
Name: "retries", Name: "retries",
Help: "Total number of retries handled by workqueue: " + name, Help: "(Deprecated) Total number of retries handled by workqueue: " + name,
}) })
prometheus.Register(retries) prometheus.Register(retries)
return retries return retries
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment