freifunk/fastd-exporter
0
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

add simple up metric to advertise successful crawls from the socket

Browse source
This commit is contained in:
Martin Weinelt 2017-03-30 23:17:57 +02:00
parent 9079d20e8c
commit 7b1bad216f
No known key found for this signature in database
GPG key ID: BD4AA0528F63F17E
1 changed files with 16 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
fastd-exporter.go
View file

@ -59,6 +59,7 @@ type Peer struct {
type PrometheusExporter struct { type PrometheusExporter struct {
SocketName string SocketName string
up *prometheus.Desc
uptime *prometheus.Desc uptime *prometheus.Desc
rxPackets *prometheus.Desc rxPackets *prometheus.Desc
@ -87,7 +88,8 @@ func NewPrometheusExporter(ifName string, sockName string) PrometheusExporter {
return PrometheusExporter{ return PrometheusExporter{
SocketName: sockName, SocketName: sockName,
uptime: prometheus.NewDesc(c("uptime"), "uptime of the prometheus exporter", nil, l), up: prometheus.NewDesc(c("up"), "whether the fastd process is up", nil, l),
uptime: prometheus.NewDesc(c("uptime"), "uptime of the fastd process", nil, l),
rxPackets: prometheus.NewDesc(c("rx_packets"), "rx packet count", nil, l), rxPackets: prometheus.NewDesc(c("rx_packets"), "rx packet count", nil, l),
rxBytes: prometheus.NewDesc(c("rx_bytes"), "rx byte count", nil, l), rxBytes: prometheus.NewDesc(c("rx_bytes"), "rx byte count", nil, l),
@ -102,6 +104,7 @@ func NewPrometheusExporter(ifName string, sockName string) PrometheusExporter {
} }
func (e PrometheusExporter) Describe(c chan<- *prometheus.Desc) { func (e PrometheusExporter) Describe(c chan<- *prometheus.Desc) {
c <- e.up
c <- e.uptime c <- e.uptime
c <- e.rxPackets c <- e.rxPackets
@ -116,7 +119,13 @@ func (e PrometheusExporter) Describe(c chan<- *prometheus.Desc) {
} }
func (e PrometheusExporter) Collect(c chan<- prometheus.Metric) { func (e PrometheusExporter) Collect(c chan<- prometheus.Metric) {
data := data_from_sock(e.SocketName) data, err := data_from_sock(e.SocketName)
if err != nil {
log.Print(err)
c <- prometheus.MustNewConstMetric(e.up, prometheus.GaugeValue, 0)
} else {
c <- prometheus.MustNewConstMetric(e.up, prometheus.GaugeValue, 1)
}
c <- prometheus.MustNewConstMetric(e.uptime, prometheus.GaugeValue, data.Uptime) c <- prometheus.MustNewConstMetric(e.uptime, prometheus.GaugeValue, data.Uptime)
@ -131,10 +140,10 @@ func (e PrometheusExporter) Collect(c chan<- prometheus.Metric) {
c <- prometheus.MustNewConstMetric(e.txDroppedBytes, prometheus.CounterValue, float64(data.Statistics.TX_Dropped.Bytes)) c <- prometheus.MustNewConstMetric(e.txDroppedBytes, prometheus.CounterValue, float64(data.Statistics.TX_Dropped.Bytes))
} }
func data_from_sock(sock string) Message { func data_from_sock(sock string) (Message, error) {
conn, err := net.DialTimeout("unix", sock, 2*time.Second) conn, err := net.DialTimeout("unix", sock, 2*time.Second)
if err != nil { if err != nil {
log.Fatal(err) return Message{}, err
} }
defer conn.Close() defer conn.Close()
@ -142,16 +151,16 @@ func data_from_sock(sock string) Message {
msg := Message{} msg := Message{}
err = decoder.Decode(&msg) err = decoder.Decode(&msg)
if err != nil { if err != nil {
log.Fatal(err) return Message{}, err
} }
dat, err := json.MarshalIndent(msg, "", "\t") dat, err := json.MarshalIndent(msg, "", "\t")
if err != nil { if err != nil {
log.Fatal(err) return Message{}, err
} }
log.Print(string(dat)) log.Print(string(dat))
return msg return msg, nil
} }
func config_from_instance(instance string) (string, string, error) { func config_from_instance(instance string) (string, string, error) {