From 135b7a0b6d8f208d6bac08f728e85a11fffa1a09 Mon Sep 17 00:00:00 2001 From: Reto Kaiser Date: Sat, 24 Feb 2018 14:27:31 +0100 Subject: [PATCH] Change metric names Via https://github.com/prometheus/docs/pull/980#pullrequestreview-98177431 --- README.md | 30 +++++++++++++++--------------- collector.go | 36 ++++++++++++++++++------------------ 2 files changed, 33 insertions(+), 33 deletions(-) diff --git a/README.md b/README.md index 1590f43..afdef28 100644 --- a/README.md +++ b/README.md @@ -49,21 +49,21 @@ Metrics will be exposes on `/metrics` ``` curl http://localhost:9418/metrics -# HELP gearman_status_running number of running jobs -# TYPE gearman_status_running gauge -gearman_status_running{function="bar"} 0 -gearman_status_running{function="baz"} 0 -gearman_status_running{function="foo"} 0 -# HELP gearman_status_total number of jobs in the queue -# TYPE gearman_status_total gauge -gearman_status_total{function="bar"} 0 -gearman_status_total{function="baz"} 0 -gearman_status_total{function="foo"} 0 -# HELP gearman_status_workers number of number of capable workers -# TYPE gearman_status_workers gauge -gearman_status_workers{function="bar"} 1 -gearman_status_workers{function="baz"} 1 -gearman_status_workers{function="foo"} 1 +# HELP gearman_jobs number of jobs queued or running +# TYPE gearman_jobs gauge +gearman_jobs{function="bar"} 0 +gearman_jobs{function="foo"} 0 +# HELP gearman_jobs_running number of running jobs +# TYPE gearman_jobs_running gauge +gearman_jobs_running{function="bar"} 0 +gearman_jobs_running{function="foo"} 0 +# HELP gearman_up is gearman up +# TYPE gearman_up gauge +gearman_up{version="1.1.18"} 1 +# HELP gearman_workers number of capable workers +# TYPE gearman_workers gauge +gearman_workers{function="bar"} 1 +gearman_workers{function="foo"} 1 # HELP gearman_up is gearman up # TYPE gearman_up gauge gearman_up 1 diff --git a/collector.go b/collector.go index 90e3e2e..14373c6 100644 --- a/collector.go +++ b/collector.go @@ -6,13 +6,13 @@ import ( ) type collector struct { - exporter *Exporter - gearman *gearman - up *prometheus.Desc - versionInfo *prometheus.Desc - statusTotal *prometheus.Desc - statusRunning *prometheus.Desc - statusWorkers *prometheus.Desc + exporter *Exporter + gearman *gearman + up *prometheus.Desc + versionInfo *prometheus.Desc + statusJobs *prometheus.Desc + statusJobsRunning *prometheus.Desc + statusWorkers *prometheus.Desc } // based on https://github.com/hnlq715/nginx-vts-exporter/ @@ -25,21 +25,21 @@ func newFuncMetric(metricName string, docString string, labels []string) *promet func (e *Exporter) newCollector(g *gearman) *collector { return &collector{ - exporter: e, - gearman: g, - up: newFuncMetric("up", "is gearman up", []string{}), - versionInfo: newFuncMetric("version_info", "gearman version", []string{"version"}), - statusTotal: newFuncMetric("status_total", "number of jobs in the queue", []string{"function"}), - statusRunning: newFuncMetric("status_running", "number of running jobs", []string{"function"}), - statusWorkers: newFuncMetric("status_workers", "number of number of capable workers", []string{"function"}), + exporter: e, + gearman: g, + up: newFuncMetric("up", "is gearman up", []string{}), + versionInfo: newFuncMetric("version_info", "gearman version", []string{"version"}), + statusJobs: newFuncMetric("jobs", "number of jobs queued or running", []string{"function"}), + statusJobsRunning: newFuncMetric("jobs_running", "number of running jobs", []string{"function"}), + statusWorkers: newFuncMetric("workers", "number of capable workers", []string{"function"}), } } func (c *collector) Describe(ch chan<- *prometheus.Desc) { ch <- c.up ch <- c.versionInfo - ch <- c.statusTotal - ch <- c.statusRunning + ch <- c.statusJobs + ch <- c.statusJobsRunning ch <- c.statusWorkers } @@ -71,13 +71,13 @@ func (c *collector) collectStatus(ch chan<- prometheus.Metric) { for k, v := range s { ch <- prometheus.MustNewConstMetric( - c.statusTotal, + c.statusJobs, prometheus.GaugeValue, float64(v.total), k) ch <- prometheus.MustNewConstMetric( - c.statusRunning, + c.statusJobsRunning, prometheus.GaugeValue, float64(v.running), k)