ROX-22557: Count expired centrals (#1677)

internal/dinosaur/pkg/workers/dinosaurmgrs/expiration_date_mgr.go

@@ -13,6 +13,7 @@ import (
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/services"
 	"github.com/stackrox/acs-fleet-manager/pkg/api"
 	serviceErr "github.com/stackrox/acs-fleet-manager/pkg/errors"
+	"github.com/stackrox/acs-fleet-manager/pkg/metrics"
 	"github.com/stackrox/acs-fleet-manager/pkg/workers"
 )
 
@@ -112,7 +113,13 @@ func (k *ExpirationDateManager) reconcileCentralExpiredAt(centrals dbapi.Central
 			}
 		}
 	}
-
+	expiredInstances := 0
+	for _, central := range centrals {
+		if central.ExpiredAt != nil {
+			expiredInstances++
+		}
+	}
+	metrics.UpdateCentralsExpiredMetric(float64(expiredInstances))
 	return svcErrors
 }
 

pkg/metrics/metrics.go

@@ -43,6 +43,8 @@ const (
 	ClusterOperationsTotalCount = "cluster_operations_total_count"
 	labelOperation              = "operation"
 
+	expiredCentralsCount = "expired_centrals_count"
+
 	ReconcilerDuration     = "reconciler_duration_in_seconds"
 	ReconcilerSuccessCount = "reconciler_success_count"
 	ReconcilerFailureCount = "reconciler_failure_count"
@@ -326,6 +328,20 @@ func UpdateCentralPerClusterCountMetric(clusterID string, clusterExternalID stri
 	centralPerClusterCountMetric.With(labels).Set(float64(count))
 }
 
+// create a new gaugeVec with the total number of expired centrals
+var expiredCentralsMetric = prometheus.NewGaugeVec(
+	prometheus.GaugeOpts{
+		Subsystem: FleetManager,
+		Name:      expiredCentralsCount,
+		Help:      "total number of expired centrals",
+	},
+	[]string{},
+)
+
+func UpdateCentralsExpiredMetric(n float64) {
+	expiredCentralsMetric.WithLabelValues().Set(n)
+}
+
 // #### Metrics for Dataplane clusters - End ####
 
 // #### Metrics for Centrals - Start ####
@@ -723,6 +739,7 @@ func init() {
 	prometheus.MustRegister(centralOperationsTotalCountMetric)
 	prometheus.MustRegister(centralStatusSinceCreatedMetric)
 	prometheus.MustRegister(CentralStatusCountMetric)
+	prometheus.MustRegister(expiredCentralsMetric)
 
 	// metrics for reconcilers
 	prometheus.MustRegister(reconcilerDurationMetric)
@@ -791,6 +808,7 @@ func Reset() {
 	centralOperationsTotalCountMetric.Reset()
 	centralStatusSinceCreatedMetric.Reset()
 	CentralStatusCountMetric.Reset()
+	expiredCentralsMetric.Reset()
 
 	reconcilerDurationMetric.Reset()
 	reconcilerSuccessCountMetric.Reset()