bmp_metrics_service.go

package server

import (
	"sync/atomic"

	"github.com/bio-routing/bio-rd/protocols/bgp/metrics"
	bgp_metrics "github.com/bio-routing/bio-rd/protocols/bgp/metrics"
	"github.com/bio-routing/bio-rd/routingtable/vrf"
	vrf_metrics "github.com/bio-routing/bio-rd/routingtable/vrf/metrics"
)

type bmpMetricsService struct {
	server *BMPServer
}

func (b *bmpMetricsService) metrics() *metrics.BMPMetrics {
	return &metrics.BMPMetrics{
		Routers: b.routerMetrics(),
	}
}

func (b *bmpMetricsService) routerMetrics() []*metrics.BMPRouterMetrics {
	routers := make([]*metrics.BMPRouterMetrics, 0)

	for _, rtr := range b.server.getRouters() {
		routers = append(routers, b.metricsForRouter(rtr))
	}

	return routers
}

func (b *bmpMetricsService) metricsForRouter(rtr *Router) *metrics.BMPRouterMetrics {
	established := atomic.LoadUint32(&rtr.established)

	rm := &metrics.BMPRouterMetrics{
		Address:                      rtr.address,
		SysName:                      rtr.name,
		Established:                  established == 1,
		RouteMonitoringMessages:      atomic.LoadUint64(&rtr.counters.routeMonitoringMessages),
		StatisticsReportMessages:     atomic.LoadUint64(&rtr.counters.statisticsReportMessages),
		PeerDownNotificationMessages: atomic.LoadUint64(&rtr.counters.peerDownNotificationMessages),
		PeerUpNotificationMessages:   atomic.LoadUint64(&rtr.counters.peerUpNotificationMessages),
		InitiationMessages:           atomic.LoadUint64(&rtr.counters.initiationMessages),
		TerminationMessages:          atomic.LoadUint64(&rtr.counters.terminationMessages),
		RouteMirroringMessages:       atomic.LoadUint64(&rtr.counters.routeMirroringMessages),
	}

	vrfs := rtr.vrfRegistry.List()
	rm.VRFMetrics = make([]*vrf_metrics.VRFMetrics, 0, len(vrfs))
	for _, v := range vrfs {
		rm.VRFMetrics = append(rm.VRFMetrics, vrf.MetricsForVRF(v))
	}

	peers := rtr.neighborManager.list()
	rm.PeerMetrics = make([]*bgp_metrics.BGPPeerMetrics, len(peers))
	for i := range peers {
		rm.PeerMetrics[i] = metricsForPeer(peers[i].fsm.peer)
	}

	return rm
}