47 lines
1.1 KiB
Go
47 lines
1.1 KiB
Go
package internal
|
|
|
|
import (
|
|
"github.com/phin1x/go-ipp"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
)
|
|
|
|
func (e *Exporter) jobsMetrics(ch chan<- prometheus.Metric) error {
|
|
jobs, err := e.client.GetJobs("", "", ipp.JobStateFilterNotCompleted, false, 0, 0, []string{})
|
|
if err != nil {
|
|
e.log.Error(err, "failed to fetch completed jobs")
|
|
return err
|
|
}
|
|
|
|
activeJobs := len(jobs)
|
|
|
|
jobs, err = e.client.GetJobs("", "", ipp.JobStateFilterAll, false, e.lastJobId, 0, []string{})
|
|
if err != nil {
|
|
e.log.Error(err, "failed to fetch all jobs")
|
|
return err
|
|
}
|
|
|
|
lastJobId := getLastJobId(jobs)
|
|
if lastJobId > e.lastJobId {
|
|
e.lastJobId = lastJobId
|
|
}
|
|
|
|
ch <- prometheus.MustNewConstMetric(e.jobsTotal, prometheus.CounterValue, float64(lastJobId))
|
|
ch <- prometheus.MustNewConstMetric(e.jobsActiveTotal, prometheus.GaugeValue, float64(activeJobs))
|
|
|
|
return nil
|
|
}
|
|
|
|
/*
|
|
returns the last job id, the last completed job id and the current active jobs
|
|
*/
|
|
func getLastJobId(m map[int]ipp.Attributes) int {
|
|
lastJobId := 0
|
|
|
|
for k := range m {
|
|
if k > lastJobId {
|
|
lastJobId = k
|
|
}
|
|
}
|
|
|
|
return lastJobId
|
|
}
|