@@ -6,13 +6,13 @@ import (
66)
77
88type collector struct {
9- exporter * Exporter
10- gearman * gearman
11- up * prometheus.Desc
12- versionInfo * prometheus.Desc
13- statusTotal * prometheus.Desc
14- statusRunning * prometheus.Desc
15- statusWorkers * prometheus.Desc
9+ exporter * Exporter
10+ gearman * gearman
11+ up * prometheus.Desc
12+ versionInfo * prometheus.Desc
13+ statusJobs * prometheus.Desc
14+ statusJobsRunning * prometheus.Desc
15+ statusWorkers * prometheus.Desc
1616}
1717
1818// based on https://github.com/hnlq715/nginx-vts-exporter/
@@ -25,21 +25,21 @@ func newFuncMetric(metricName string, docString string, labels []string) *promet
2525
2626func (e * Exporter ) newCollector (g * gearman ) * collector {
2727 return & collector {
28- exporter : e ,
29- gearman : g ,
30- up : newFuncMetric ("up" , "is gearman up" , []string {}),
31- versionInfo : newFuncMetric ("version_info" , "gearman version" , []string {"version" }),
32- statusTotal : newFuncMetric ("status_total " , "number of jobs in the queue " , []string {"function" }),
33- statusRunning : newFuncMetric ("status_running " , "number of running jobs" , []string {"function" }),
34- statusWorkers : newFuncMetric ("status_workers " , "number of number of capable workers" , []string {"function" }),
28+ exporter : e ,
29+ gearman : g ,
30+ up : newFuncMetric ("up" , "is gearman up" , []string {}),
31+ versionInfo : newFuncMetric ("version_info" , "gearman version" , []string {"version" }),
32+ statusJobs : newFuncMetric ("jobs " , "number of jobs queued or running " , []string {"function" }),
33+ statusJobsRunning : newFuncMetric ("jobs_running " , "number of running jobs" , []string {"function" }),
34+ statusWorkers : newFuncMetric ("workers " , "number of capable workers" , []string {"function" }),
3535 }
3636}
3737
3838func (c * collector ) Describe (ch chan <- * prometheus.Desc ) {
3939 ch <- c .up
4040 ch <- c .versionInfo
41- ch <- c .statusTotal
42- ch <- c .statusRunning
41+ ch <- c .statusJobs
42+ ch <- c .statusJobsRunning
4343 ch <- c .statusWorkers
4444}
4545
@@ -71,13 +71,13 @@ func (c *collector) collectStatus(ch chan<- prometheus.Metric) {
7171
7272 for k , v := range s {
7373 ch <- prometheus .MustNewConstMetric (
74- c .statusTotal ,
74+ c .statusJobs ,
7575 prometheus .GaugeValue ,
7676 float64 (v .total ),
7777 k )
7878
7979 ch <- prometheus .MustNewConstMetric (
80- c .statusRunning ,
80+ c .statusJobsRunning ,
8181 prometheus .GaugeValue ,
8282 float64 (v .running ),
8383 k )
0 commit comments