ipmi_exporter/collector.go

122 lines
2.9 KiB
Go
Raw Normal View History

// Copyright 2021 The Prometheus Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
2017-07-25 14:17:57 +00:00
package main
import (
"path"
"time"
"github.com/go-kit/log/level"
2017-07-25 14:17:57 +00:00
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus-community/ipmi_exporter/freeipmi"
2017-07-25 14:17:57 +00:00
)
2018-09-21 09:41:59 +00:00
const (
namespace = "ipmi"
targetLocal = ""
)
type collector interface {
Name() CollectorName
Cmd() string
Args() []string
Collect(output freeipmi.Result, ch chan<- prometheus.Metric, target ipmiTarget) (int, error)
}
2017-07-25 14:17:57 +00:00
type metaCollector struct {
2017-07-25 14:17:57 +00:00
target string
module string
2017-07-25 14:17:57 +00:00
config *SafeConfig
}
type ipmiTarget struct {
host string
config IPMIConfig
}
2017-07-25 14:17:57 +00:00
var (
upDesc = prometheus.NewDesc(
prometheus.BuildFQName(namespace, "", "up"),
"'1' if a scrape of the IPMI device was successful, '0' otherwise.",
[]string{"collector"},
2017-07-25 14:17:57 +00:00
nil,
)
durationDesc = prometheus.NewDesc(
prometheus.BuildFQName(namespace, "scrape_duration", "seconds"),
"Returns how long the scrape took to complete in seconds.",
nil,
nil,
)
)
// Describe implements Prometheus.Collector.
func (c metaCollector) Describe(ch chan<- *prometheus.Desc) {
// all metrics are described ad-hoc
}
func markCollectorUp(ch chan<- prometheus.Metric, name string, up int) {
ch <- prometheus.MustNewConstMetric(
upDesc,
prometheus.GaugeValue,
float64(up),
name,
2017-07-25 14:17:57 +00:00
)
}
// Collect implements Prometheus.Collector.
func (c metaCollector) Collect(ch chan<- prometheus.Metric) {
2017-07-25 14:17:57 +00:00
start := time.Now()
defer func() {
duration := time.Since(start).Seconds()
level.Debug(logger).Log("msg", "Scrape duration", "target", targetName(c.target), "duration", duration)
2017-07-25 14:17:57 +00:00
ch <- prometheus.MustNewConstMetric(
durationDesc,
prometheus.GaugeValue,
duration,
)
}()
config := c.config.ConfigForTarget(c.target, c.module)
target := ipmiTarget{
host: c.target,
config: config,
}
for _, collector := range config.GetCollectors() {
var up int
level.Debug(logger).Log("msg", "Running collector", "target", target.host, "collector", collector.Name())
2017-07-25 14:17:57 +00:00
fqcmd := collector.Cmd()
if !path.IsAbs(fqcmd) {
fqcmd = path.Join(*executablesPath, collector.Cmd())
}
args := collector.Args()
cfg := config.GetFreeipmiConfig()
result := freeipmi.Execute(fqcmd, args, cfg, target.host, logger)
up, _ = collector.Collect(result, ch, target)
markCollectorUp(ch, string(collector.Name()), up)
}
}
func targetName(target string) string {
if target == targetLocal {
return "[local]"
}
return target
}