Add Prometheus Metrics to Loadbalancers (#48)

* nearly there, pushing for questions Signed-off-by: Dejon Gill [email protected] Signed-off-by: Dejon Gill <[email protected]> * add prom metrics to server package Signed-off-by: Dejon Gill <[email protected]> * Separate requested/released IP gauges Signed-off-by: Dejon Gill <[email protected]> * Remove unused type PromGauge Signed-off-by: Dejon Gill <[email protected]> --------- Signed-off-by: Dejon Gill [email protected] Signed-off-by: Dejon Gill <[email protected]>
infratographer · Feb 8, 2024 · e727520 · e727520
1 parent c767bb5
commit e727520
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 0 deletions.
diff --git a/internal/server/changes.go b/internal/server/changes.go
@@ -28,6 +28,8 @@ func (s *Server) processLoadBalancerChangeCreate(ctx context.Context, lb *loadba
 				AdditionalSubjectIDs: []gidx.PrefixedID{gidx.PrefixedID(lb.LbData.Location.ID)},
 			}
 
+			numberIPsRequestedGauge.Inc()
+
 			if _, err := s.EventsConnection.PublishEvent(ctx, "load-balancer", msg); err != nil {
 				s.Logger.Debugw("failed to publish event", "error", err, "ip", ip, "loadbalancer", lb.LoadBalancerID, "block", s.IPBlock)
 				return err
@@ -55,6 +57,8 @@ func (s *Server) processLoadBalancerChangeDelete(ctx context.Context, lb *loadba
 		AdditionalSubjectIDs: []gidx.PrefixedID{gidx.PrefixedID(lb.LbData.Location.ID)},
 	}
 
+	numberIPsReleasedGauge.Inc()
+
 	if _, err := s.EventsConnection.PublishEvent(ctx, "load-balancer", msg); err != nil {
 		s.Logger.Debugw("failed to publish event", "error", err, "loadbalancer", lb.LoadBalancerID, "block", s.IPBlock)
 		return err

diff --git a/internal/server/prom.go b/internal/server/prom.go
@@ -0,0 +1,25 @@
+package server
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
+)
+
+const subsystem = "loadbalancer_provider_haproxy"
+
+var (
+	numberIPsRequestedGauge = promauto.NewGauge(
+		prometheus.GaugeOpts{
+			Subsystem: subsystem,
+			Name:      "ips_requested_count",
+			Help:      "The total number of IPs requested",
+		},
+	)
+	numberIPsReleasedGauge = promauto.NewGauge(
+		prometheus.GaugeOpts{
+			Subsystem: subsystem,
+			Name:      "ips_released_count",
+			Help:      "The total number of IPs released",
+		},
+	)
+)