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

resolves #11

Browse Source
This commit is contained in:
Daniel Czerwonk 2017-11-29 21:03:39 +01:00
parent 1d04ab2bd5
commit df402c4387
9 changed files with 150 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
bgp/bgp_collector.go → bgp/exporter.go
View File

@ -7,8 +7,7 @@ import (
var exporter map[int]*protocol.GenericProtocolMetricExporter
type BgpCollector struct {
protocols []*protocol.Protocol
type BgpMetricExporter struct {
}
func init() {
@ -17,17 +16,11 @@ func init() {
exporter[6] = protocol.NewGenericProtocolMetricExporter("bgp6_session")
}
func NewCollector(p []*protocol.Protocol) prometheus.Collector {
return &BgpCollector{protocols: p}
}
func (m *BgpCollector) Describe(ch chan<- *prometheus.Desc) {
func (*BgpMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
}
func (m *BgpCollector) Collect(ch chan<- prometheus.Metric) {
for _, p := range m.protocols {
exporter[p.IpVersion].Export(p, ch)
}
func (*BgpMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
}

26
device/exporter.go Normal file
View File

@ -0,0 +1,26 @@
package device
import (
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
)
var exporter map[int]*protocol.GenericProtocolMetricExporter
type DeviceMetricExporter struct {
}
func init() {
exporter = make(map[int]*protocol.GenericProtocolMetricExporter)
exporter[4] = protocol.NewGenericProtocolMetricExporter("device4")
exporter[6] = protocol.NewGenericProtocolMetricExporter("device6")
}
func (m *DeviceMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
}
func (m *DeviceMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
}

27
direct/exporter.go Normal file
View File

@ -0,0 +1,27 @@
package direct
import (
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
)
var exporter map[int]*protocol.GenericProtocolMetricExporter
type DirectMetricExporter struct {
protocols []*protocol.Protocol
}
func init() {
exporter = make(map[int]*protocol.GenericProtocolMetricExporter)
exporter[4] = protocol.NewGenericProtocolMetricExporter("direct4")
exporter[6] = protocol.NewGenericProtocolMetricExporter("direct6")
}
func (*DirectMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
}
func (*DirectMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
}

26
kernel/exporter.go Normal file
View File

@ -0,0 +1,26 @@
package kernel
import (
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
)
var exporter map[int]*protocol.GenericProtocolMetricExporter
type KernelMetricExporter struct {
}
func init() {
exporter = make(map[int]*protocol.GenericProtocolMetricExporter)
exporter[4] = protocol.NewGenericProtocolMetricExporter("kernel4")
exporter[6] = protocol.NewGenericProtocolMetricExporter("kernel6")
}
func (*KernelMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
}
func (*KernelMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
}

48
metric_collector.go
View File

@ -2,46 +2,48 @@ package main
import (
"github.com/czerwonk/bird_exporter/bgp"
"github.com/czerwonk/bird_exporter/device"
"github.com/czerwonk/bird_exporter/direct"
"github.com/czerwonk/bird_exporter/kernel"
"github.com/czerwonk/bird_exporter/ospf"
"github.com/czerwonk/bird_exporter/protocol"
"github.com/czerwonk/bird_exporter/static"
"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 {
collectors []prometheus.Collector
protocols []*protocol.Protocol
exporters map[int]MetricExporter
}
func NewMetricCollectorForProtocols(protocols []*protocol.Protocol) *MetricCollector {
b := make([]*protocol.Protocol, 0)
o := make([]*protocol.Protocol, 0)
for _, p := range protocols {
if p.Proto == protocol.BGP {
b = append(b, p)
} else if p.Proto == protocol.OSPF {
o = append(o, p)
}
e := map[int]MetricExporter{
protocol.BGP: &bgp.BgpMetricExporter{},
protocol.Device: &device.DeviceMetricExporter{},
protocol.Direct: &direct.DirectMetricExporter{},
protocol.Kernel: &kernel.KernelMetricExporter{},
protocol.OSPF: &ospf.OspfMetricExporter{},
protocol.Static: &static.StaticMetricExporter{},
}
c := make([]prometheus.Collector, 0)
if len(b) > 0 {
c = append(c, bgp.NewCollector(b))
}
if len(o) > 0 {
c = append(c, ospf.NewCollector(o))
}
return &MetricCollector{collectors: c}
return &MetricCollector{protocols: protocols, exporters: e}
}
func (m *MetricCollector) Describe(ch chan<- *prometheus.Desc) {
for _, c := range m.collectors {
c.Describe(ch)
for _, v := range m.exporters {
v.Describe(ch)
}
}
func (m *MetricCollector) Collect(ch chan<- prometheus.Metric) {
for _, c := range m.collectors {
c.Collect(ch)
for _, p := range m.protocols {
if p.Proto != protocol.PROTO_UNKNOWN {
m.exporters[p.Proto].Export(p, ch)
}
}
}

17
ospf/ospf_collector.go → ospf/exporter.go
View File

@ -12,8 +12,7 @@ type desc struct {
runningDesc *prometheus.Desc
}
type OspfCollector struct {
protocols []*protocol.Protocol
type OspfMetricExporter struct {
}
func init() {
@ -35,20 +34,14 @@ func getDesc(prefix string) *desc {
return d
}
func NewCollector(p []*protocol.Protocol) prometheus.Collector {
return &OspfCollector{protocols: p}
}
func (m *OspfCollector) Describe(ch chan<- *prometheus.Desc) {
func (*OspfMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
ch <- descriptions[4].runningDesc
ch <- descriptions[6].runningDesc
}
func (m *OspfCollector) Collect(ch chan<- prometheus.Metric) {
for _, p := range m.protocols {
exporter[p.IpVersion].Export(p, ch)
ch <- prometheus.MustNewConstMetric(descriptions[p.IpVersion].runningDesc, prometheus.GaugeValue, p.Attributes["running"], p.Name)
}
func (*OspfMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
ch <- prometheus.MustNewConstMetric(descriptions[p.IpVersion].runningDesc, prometheus.GaugeValue, p.Attributes["running"], p.Name)
}

8
parser.go
View File

@ -21,7 +21,7 @@ var (
)
func init() {
protocolRegex = regexp.MustCompile("^(?:1002\\-)?([^\\s]+)\\s+(BGP|OSPF)\\s+([^\\s]+)\\s+([^\\s]+)\\s+([^\\s]+)(?:\\s+(.*?))?$")
protocolRegex = regexp.MustCompile("^(?:1002\\-)?([^\\s]+)\\s+(BGP|OSPF|Direct|Device|Kernel)\\s+([^\\s]+)\\s+([^\\s]+)\\s+([^\\s]+)(?:\\s+(.*?))?$")
routeRegex = regexp.MustCompile("^\\s+Routes:\\s+(\\d+) imported, (?:(\\d+) filtered, )?(\\d+) exported(?:, (\\d+) preferred)?")
uptimeRegex = regexp.MustCompile("^(?:((\\d+):(\\d{2}):(\\d{2}))|\\d+)$")
routeChangeRegex = regexp.MustCompile("(Import|Export) (updates|withdraws):\\s+(\\d+|---)\\s+(\\d+|---)\\s+(\\d+|---)\\s+(\\d+|---)\\s+(\\d+|---)\\s*")
@ -78,6 +78,12 @@ func parseProto(val string) int {
return protocol.BGP
case "OSPF":
return protocol.OSPF
case "Direct":
return protocol.Direct
case "Device":
return protocol.Device
case "Kernel":
return protocol.Kernel
}
return protocol.PROTO_UNKNOWN

4
protocol/protocol.go
View File

@ -4,6 +4,10 @@ const (
PROTO_UNKNOWN = 0
BGP = 1
OSPF = 2
Kernel = 3
Static = 4
Direct = 5
Device = 6
)
type Protocol struct {

26
static/exporter.go Normal file
View File

@ -0,0 +1,26 @@
package static
import (
"github.com/czerwonk/bird_exporter/protocol"
"github.com/prometheus/client_golang/prometheus"
)
var exporter map[int]*protocol.GenericProtocolMetricExporter
type StaticMetricExporter struct {
}
func init() {
exporter = make(map[int]*protocol.GenericProtocolMetricExporter)
exporter[4] = protocol.NewGenericProtocolMetricExporter("static4")
exporter[6] = protocol.NewGenericProtocolMetricExporter("static6")
}
func (m *StaticMetricExporter) Describe(ch chan<- *prometheus.Desc) {
exporter[4].Describe(ch)
exporter[6].Describe(ch)
}
func (m *StaticMetricExporter) Export(p *protocol.Protocol, ch chan<- prometheus.Metric) {
exporter[p.IpVersion].Export(p, ch)
}