mirrors/bird_exporter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

generic protocol export (new format)

Browse Source
This commit is contained in:
Daniel Czerwonk 2017-12-01 00:37:12 +01:00
parent c8354f281e
commit 5c10493514
5 changed files with 75 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
main.go
View File

@ -21,6 +21,7 @@ var (
bird6Socket = flag.String("bird.socket6", "/var/run/bird6.ctl", "Socket to communicate with bird6 routing daemon")
birdEnabled = flag.Bool("bird.ipv4", true, "Get protocols from bird")
bird6Enabled = flag.Bool("bird.ipv6", true, "Get protocols from bird6")
newFormat = flag.Bool("use-new-format", false, "New metric format (more convinient / generic)")
)
func init() {
@ -87,7 +88,7 @@ func handleMetricsRequest(w http.ResponseWriter, r *http.Request) error {
if len(protocols) > 0 {
reg := prometheus.NewRegistry()
c := NewMetricCollectorForProtocols(protocols)
c := NewMetricCollectorForProtocols(protocols, *newFormat)
reg.MustRegister(c)
promhttp.HandlerFor(reg, promhttp.HandlerOpts{

62
metric_collector.go
View File

@ -7,40 +7,66 @@ import (
"github.com/prometheus/client_golang/prometheus"
)
type MetricExporter interface {
Describe(ch chan<- *prometheus.Desc)
Export(p *protocol.Protocol, ch chan<- prometheus.Metric)
}
type MetricCollector struct {
protocols []*protocol.Protocol
exporters map[int]MetricExporter
exporters map[int][]metrics.MetricExporter
}
func NewMetricCollectorForProtocols(protocols []*protocol.Protocol) *MetricCollector {
l := &metrics.LegacyLabelStrategy{}
e := map[int]MetricExporter{
protocol.BGP: metrics.NewMetricExporter("bgp4_session", "bgp6_session", l),
protocol.Device: metrics.NewMetricExporter("device4", "device6", l),
protocol.Direct: metrics.NewMetricExporter("direct4", "direct6", l),
protocol.Kernel: metrics.NewMetricExporter("kernel4", "kernel6", l),
protocol.OSPF: ospf.NewExporter(l),
protocol.Static: metrics.NewMetricExporter("static4", "static6", l),
func NewMetricCollectorForProtocols(protocols []*protocol.Protocol, newFormat bool) *MetricCollector {
var e map[int][]metrics.MetricExporter
if newFormat {
e = exportersForDefault()
} else {
e = exportersForLegacy()
}
return &MetricCollector{protocols: protocols, exporters: e}
}
func exportersForLegacy() map[int][]metrics.MetricExporter {
l := &metrics.LegacyLabelStrategy{}
return map[int][]metrics.MetricExporter{
protocol.BGP: []metrics.MetricExporter{metrics.NewMetricExporter("bgp4_session", "bgp6_session", l)},
protocol.Device: []metrics.MetricExporter{metrics.NewMetricExporter("device4", "device6", l)},
protocol.Direct: []metrics.MetricExporter{metrics.NewMetricExporter("direct4", "direct6", l)},
protocol.Kernel: []metrics.MetricExporter{metrics.NewMetricExporter("kernel4", "kernel6", l)},
protocol.OSPF: []metrics.MetricExporter{metrics.NewMetricExporter("ospf", "ospfv3", l), ospf.NewExporter("")},
protocol.Static: []metrics.MetricExporter{metrics.NewMetricExporter("static4", "static6", l)},
}
}
func exportersForDefault() map[int][]metrics.MetricExporter {
l := &metrics.DefaultLabelStrategy{}
e := metrics.NewGenericProtocolMetricExporter("bird_protocol", l)
return map[int][]metrics.MetricExporter{
protocol.BGP: []metrics.MetricExporter{e},
protocol.Device: []metrics.MetricExporter{e},
protocol.Direct: []metrics.MetricExporter{e},
protocol.Kernel: []metrics.MetricExporter{e},
protocol.OSPF: []metrics.MetricExporter{e, ospf.NewExporter("bird_")},
protocol.Static: []metrics.MetricExporter{e},
}
}
func (m *MetricCollector) Describe(ch chan<- *prometheus.Desc) {
for _, v := range m.exporters {
v.Describe(ch)
for _, e := range v {
e.Describe(ch)
}
}
}
func (m *MetricCollector) Collect(ch chan<- prometheus.Metric) {
for _, p := range m.protocols {
if p.Proto != protocol.PROTO_UNKNOWN {
m.exporters[p.Proto].Export(p, ch)
if p.Proto == protocol.PROTO_UNKNOWN {
continue
}
for _, e := range m.exporters[p.Proto] {
e.Export(p, ch)
}
}
}

7
metrics/default_label_strategy.go
View File

@ -1,6 +1,9 @@
package metrics
import "github.com/czerwonk/bird_exporter/protocol"
import (
"github.com/czerwonk/bird_exporter/protocol"
"strconv"
)
type DefaultLabelStrategy struct {
}
@ -10,7 +13,7 @@ func (*DefaultLabelStrategy) labelNames() []string {
}
func (*DefaultLabelStrategy) labelValues(p *protocol.Protocol) []string {
return []string{p.Name, protoString(p), string(p.IpVersion)}
return []string{p.Name, protoString(p), strconv.Itoa(p.IpVersion)}
}
func protoString(p *protocol.Protocol) string {
switch p.Proto {

11
metrics/metrics_exporter.go Normal file
View File

@ -0,0 +1,11 @@
package metrics
import (
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
)
type MetricExporter interface {
Describe(ch chan<- *prometheus.Desc)
Export(p *protocol.Protocol, ch chan<- prometheus.Metric)
}

32
ospf/exporter.go
View File

@ -1,29 +1,25 @@
package ospf
import (
"github.com/czerwonk/bird_exporter/metrics"
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
"github.com/czerwonk/bird_exporter/metrics"
)
var descriptions map[int]*desc
type desc struct {
runningDesc *prometheus.Desc
}
type OspfMetricExporter struct {
genericExporter *metrics.ProtocolMetricExporter
type ospfMetricExporter struct {
descriptions map[int]*desc
}
func init() {
descriptions = make(map[int]*desc)
descriptions[4] = getDesc("ospf")
descriptions[6] = getDesc("ospfv3")
}
func NewExporter(prefix string) metrics.MetricExporter {
d := make(map[int]*desc)
d[4] = getDesc(prefix+"ospf")
d[6] = getDesc(prefix+"ospfv3")
func NewExporter(labelStrategy metrics.LabelStrategy) *OspfMetricExporter {
return &OspfMetricExporter{genericExporter: metrics.NewMetricExporter("ospf", "ospfv3", labelStrategy)}
return &ospfMetricExporter{descriptions: d}
}
func getDesc(prefix string) *desc {
@ -35,13 +31,11 @@ func getDesc(prefix string) *desc {
return d
}
func (m *OspfMetricExporter) Describe(ch chan<- *prometheus.Desc) {
m.genericExporter.Describe(ch)
ch <- descriptions[4].runningDesc
ch <- descriptions[6].runningDesc
func (m *ospfMetricExporter) Describe(ch chan<- *prometheus.Desc) {
ch <- m.descriptions[4].runningDesc
ch <- m.descriptions[6].runningDesc
}
func (m *OspfMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
m.genericExporter.Export(p, ch)
ch <- prometheus.MustNewConstMetric(descriptions[p.IpVersion].runningDesc, prometheus.GaugeValue, p.Attributes["running"], p.Name)
func (m *ospfMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
ch <- prometheus.MustNewConstMetric(m.descriptions[p.IpVersion].runningDesc, prometheus.GaugeValue, p.Attributes["running"], p.Name)
}