mudhorn/node_exporter
1
0
Fork 0
mirror of https://github.com/prometheus/node_exporter.git synced 2024-11-12 16:44:18 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #215 from tux21b/master

Browse source 
systemd-collector: support private/direct connections without dbus
This commit is contained in:
Julius Volz 2016-03-30 14:08:18 +02:00
parent bce2e0c513 5d35401a41
commit dd76a68f3c
1 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
collector/systemd_linux.go
View file

@ -16,6 +16,7 @@
package collector package collector
import ( import (
"flag"
"fmt" "fmt"
"github.com/coreos/go-systemd/dbus" "github.com/coreos/go-systemd/dbus"
@ -29,6 +30,14 @@ type systemdCollector struct {
var unitStatesName = []string{"active", "activating", "deactivating", "inactive", "failed"} var unitStatesName = []string{"active", "activating", "deactivating", "inactive", "failed"}
var (
systemdPrivate = flag.Bool(
"collector.systemd.private",
false,
"Establish a private, direct connection to systemd without dbus.",
)
)
func init() { func init() {
Factories["systemd"] = NewSystemdCollector Factories["systemd"] = NewSystemdCollector
} }
@ -92,8 +101,15 @@ func (c *systemdCollector) collectSystemState(ch chan<- prometheus.Metric, syste
ch <- prometheus.MustNewConstMetric(c.systemRunningDesc, prometheus.GaugeValue, isSystemRunning) ch <- prometheus.MustNewConstMetric(c.systemRunningDesc, prometheus.GaugeValue, isSystemRunning)
} }
func (c *systemdCollector) newDbus() (*dbus.Conn, error) {
if *systemdPrivate {
return dbus.NewSystemdConnection()
}
return dbus.New()
}
func (c *systemdCollector) listUnits() ([]dbus.UnitStatus, error) { func (c *systemdCollector) listUnits() ([]dbus.UnitStatus, error) {
conn, err := dbus.New() conn, err := c.newDbus()
if err != nil { if err != nil {
return nil, fmt.Errorf("couldn't get dbus connection: %s", err) return nil, fmt.Errorf("couldn't get dbus connection: %s", err)
} }
@ -103,7 +119,7 @@ func (c *systemdCollector) listUnits() ([]dbus.UnitStatus, error) {
} }
func (c *systemdCollector) getSystemState() (state string, err error) { func (c *systemdCollector) getSystemState() (state string, err error) {
conn, err := dbus.New() conn, err := c.newDbus()
if err != nil { if err != nil {
return "", fmt.Errorf("couldn't get dbus connection: %s", err) return "", fmt.Errorf("couldn't get dbus connection: %s", err)
} }