Added IP Usage metrics at Rest server.

Azure · May 1, 2023 · 1c31c0a · 1c31c0a
1 parent ccb30bf
commit 1c31c0a
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 20 deletions.
diff --git a/cns/restserver/api.go b/cns/restserver/api.go
@@ -410,8 +410,7 @@ func (service *HTTPRestService) reserveIPAddress(w http.ResponseWriter, r *http.
 
 	if resp.ReturnCode == 0 {
 		// If Response is success i.e. code 0, then publish metrics.
-		state := service.buildIPState()
-		publishIPStateMetrics(state)
+		publishIPStateMetrics(service.buildIPState())
 	}
 
 	reserveResp := &cns.ReserveIPAddressResponse{Response: resp, IPAddress: address}
@@ -483,8 +482,7 @@ func (service *HTTPRestService) releaseIPAddress(w http.ResponseWriter, r *http.
 
 	if resp.ReturnCode == 0 {
 		// If Response is success i.e. code 0, then publish metrics.
-		state := service.buildIPState()
-		publishIPStateMetrics(state)
+		publishIPStateMetrics(service.buildIPState())
 	}
 
 	err = service.Listener.Encode(w, &resp)

diff --git a/cns/restserver/internalapi.go b/cns/restserver/internalapi.go
@@ -396,8 +396,7 @@ func (service *HTTPRestService) CreateOrUpdateNetworkContainerInternal(req *cns.
 	if returnCode == 0 {
 		logNCSnapshot(*req)
 
-		state := service.buildIPState()
-		publishIPStateMetrics(state)
+		publishIPStateMetrics(service.buildIPState())
 	} else {
 		logger.Errorf(returnMessage)
 	}

diff --git a/cns/restserver/ipusage.go b/cns/restserver/ipusage.go
@@ -18,7 +18,7 @@ type ipState struct {
 	releasingIPs int64
 }
 
-func (service *HTTPRestService) buildIPState() ipState {
+func (service *HTTPRestService) buildIPState() *ipState {
 	service.Lock()
 	defer service.Unlock()
 
@@ -28,6 +28,7 @@ func (service *HTTPRestService) buildIPState() ipState {
 		availableIPs: 0,
 	}
 
+	//nolint:gocritic // This has to iterate over the IP Config state to get the counts.
 	for _, ipConfig := range service.PodIPConfigState {
 		state.allocatedIPs++
 		if ipConfig.GetState() == types.Assigned {
@@ -45,5 +46,5 @@ func (service *HTTPRestService) buildIPState() ipState {
 	}
 
 	logger.Printf("[IP Usage] allocated IPs: %d, assigned IPs: %d, available IPs: %d", state.allocatedIPs, state.assignedIPs, state.availableIPs)
-	return state
+	return &state
 }
diff --git a/cns/restserver/metrics.go b/cns/restserver/metrics.go
@@ -14,7 +14,7 @@ const (
 	subnetLabel              = "subnet"
 	subnetCIDRLabel          = "subnet_cidr"
 	podnetARMIDLabel         = "podnet_arm_id"
-	cnsReturnCode            = "Cns-Return-Code"
+	cnsReturnCode            = "cns_return_code"
 	customerMetricLabel      = "customer_metric"
 	customerMetricLabelValue = "customer metric"
 )
@@ -64,43 +64,43 @@ var (
 	)
 	allocatedIPCount = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
-			Name:        "cx_allocated_ips",
+			Name:        "cx_allocated_ips_v2",
 			Help:        "Count of IPs CNS has Allocated",
 			ConstLabels: prometheus.Labels{customerMetricLabel: customerMetricLabelValue},
 		},
-		[]string{subnetLabel, subnetCIDRLabel, podnetARMIDLabel},
+		[]string{},
 	)
 	assignedIPCount = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
-			Name:        "cx_assigned_ips",
+			Name:        "cx_assigned_ips_v2",
 			Help:        "Count of IPs CNS has Assigned to Pods",
 			ConstLabels: prometheus.Labels{customerMetricLabel: customerMetricLabelValue},
 		},
-		[]string{subnetLabel, subnetCIDRLabel, podnetARMIDLabel},
+		[]string{},
 	)
 	availableIPCount = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
-			Name:        "cx_available_ips",
+			Name:        "cx_available_ips_v2",
 			Help:        "Count of IPs Available",
 			ConstLabels: prometheus.Labels{customerMetricLabel: customerMetricLabelValue},
 		},
-		[]string{subnetLabel, subnetCIDRLabel, podnetARMIDLabel},
+		[]string{},
 	)
 	pendingProgrammingIPCount = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
-			Name:        "cx_pending_programming_ips",
+			Name:        "cx_pending_programming_ips_v2",
 			Help:        "Count of IPs in Pending Programming State",
 			ConstLabels: prometheus.Labels{customerMetricLabel: customerMetricLabelValue},
 		},
-		[]string{subnetLabel, subnetCIDRLabel, podnetARMIDLabel},
+		[]string{},
 	)
 	pendingReleaseIPCount = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
-			Name:        "cx_pending_release_ips",
+			Name:        "cx_pending_release_ips_v2",
 			Help:        "Count of IPs in Pending Release State",
 			ConstLabels: prometheus.Labels{customerMetricLabel: customerMetricLabelValue},
 		},
-		[]string{subnetLabel, subnetCIDRLabel, podnetARMIDLabel},
+		[]string{},
 	)
 )
 
@@ -142,7 +142,7 @@ func stateTransitionMiddleware(i *cns.IPConfigurationStatus, s types.IPState) {
 	ipConfigStatusStateTransitionTime.WithLabelValues(string(i.GetState()), string(s)).Observe(time.Since(i.LastStateTransition).Seconds())
 }
 
-func publishIPStateMetrics(state ipState) {
+func publishIPStateMetrics(state *ipState) {
 	labels := []string{} // TODO. ragasthya Add dimensions to the IP Usage metrics.
 	allocatedIPCount.WithLabelValues(labels...).Set(float64(state.allocatedIPs))
 	assignedIPCount.WithLabelValues(labels...).Set(float64(state.assignedIPs))