Add IP Num Alert

pkg/controller/controller.go

@@ -311,6 +311,8 @@ func (c *Controller) Run(stopCh <-chan struct{}) {
 		klog.Fatalf("gc failed %v", err)
 	}
 
+	c.registerSubnetMetrics()
+
 	// start workers to do all the network operations
 	c.startWorkers(stopCh)
 	<-stopCh
@@ -439,4 +441,6 @@ func (c *Controller) startWorkers(stopCh <-chan struct{}) {
 			klog.Errorf("gc lsp error %v", err)
 		}
 	}, 30*time.Second, stopCh)
+
+	go wait.Until(c.resyncSubnetMetrics, 30*time.Second, stopCh)
 }

pkg/controller/exporter.go

@@ -0,0 +1,47 @@
+package controller
+
+import (
+	"sync"
+
+	kubeovnv1 "github.com/alauda/kube-ovn/pkg/apis/kubeovn/v1"
+
+	"k8s.io/apimachinery/pkg/labels"
+	"k8s.io/klog"
+)
+
+var registerMetricsOnce sync.Once
+
+// registerSubnetMetrics register subnet metrics
+func (c *Controller) registerSubnetMetrics() {
+	registerMetricsOnce.Do(func() {
+		registerMetrics()
+	})
+}
+
+// resyncSubnetMetrics start to update subnet metrics
+func (c *Controller) resyncSubnetMetrics() {
+	for c.exportSubnetMetrics() {
+	}
+}
+
+func (c *Controller) exportSubnetMetrics() bool {
+	subnets, err := c.subnetsLister.List(labels.Everything())
+	if err != nil {
+		klog.Errorf("failed to list subnet, %v", err)
+		return false
+	}
+	for _, subnet := range subnets {
+		c.exportSubnetAvailableIPsGauge(subnet)
+		c.exportSubnetUsedIPsGauge(subnet)
+	}
+
+	return true
+}
+
+func (c *Controller) exportSubnetAvailableIPsGauge(subnet *kubeovnv1.Subnet) {
+	metricSubnetAvailableIPs.WithLabelValues(subnet.Name, subnet.Spec.Protocol, subnet.Spec.CIDRBlock).Set(subnet.Status.AvailableIPs)
+}
+
+func (c *Controller) exportSubnetUsedIPsGauge(subnet *kubeovnv1.Subnet) {
+	metricSubnetUsedIPs.WithLabelValues(subnet.Name, subnet.Spec.Protocol, subnet.Spec.CIDRBlock).Set(subnet.Status.UsingIPs)
+}

pkg/controller/net_metrics.go

@@ -0,0 +1,32 @@
+package controller
+
+import "github.com/prometheus/client_golang/prometheus"
+
+var (
+	metricSubnetAvailableIPs = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "subnet_available_ip_count",
+			Help: "The available num of ip address in subnet.",
+		},
+		[]string{
+			"subnet_name",
+			"protocol",
+			"subnet_cidr",
+		})
+
+	metricSubnetUsedIPs = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "subnet_used_ip_count",
+			Help: "The used num of ip address in subnet.",
+		},
+		[]string{
+			"subnet_name",
+			"protocol",
+			"subnet_cidr",
+		})
+)
+
+func registerMetrics() {
+	prometheus.MustRegister(metricSubnetAvailableIPs)
+	prometheus.MustRegister(metricSubnetUsedIPs)
+}