Deleting a CSV removes related CSV metrics

Problem: Bug 1843703: When creating a CSV fails, deleting it did
not clear the CSV metrics. So when the same CSV was created
again and allowed to succeed, the olm pod still retained the
old CSV metrics

Solution: Deleting a CSV will now clear its related metrics
from the olm pod

Signed-off-by: Harish <[email protected]>

Author: harishsurf

pkg/controller/operators/olm/operator.go

@@ -761,6 +761,8 @@ func (a *Operator) handleClusterServiceVersionDeletion(obj interface{}) {
 		"phase":     clusterServiceVersion.Status.Phase,
 	})
 
+	metrics.DeleteCSVMetric(clusterServiceVersion)
+
 	defer func(csv v1alpha1.ClusterServiceVersion) {
 		if clusterServiceVersion.IsCopied() {
 			logger.Debug("deleted csv is copied. skipping operatorgroup requeue")

pkg/metrics/metrics.go

@@ -188,6 +188,12 @@ func CounterForSubscription(name, installedCSV, channelName, packageName string)
 	return SubscriptionSyncCount.WithLabelValues(name, installedCSV, channelName, packageName)
 }
 
+// DeleteCSVMetric deletes old CSV metrics
+func DeleteCSVMetric(oldCSV *olmv1alpha1.ClusterServiceVersion) {
+	csvAbnormal.DeleteLabelValues(oldCSV.Namespace, oldCSV.Name, oldCSV.Spec.Version.String(), string(oldCSV.Status.Phase), string(oldCSV.Status.Reason))
+	csvSucceeded.DeleteLabelValues(oldCSV.Namespace, oldCSV.Name, oldCSV.Spec.Version.String())
+}
+
 func EmitCSVMetric(oldCSV *olmv1alpha1.ClusterServiceVersion, newCSV *olmv1alpha1.ClusterServiceVersion) {
 	if oldCSV == nil || newCSV == nil {
 		return

test/e2e/metrics_e2e_test.go

@@ -37,7 +37,6 @@ func TestMetricsEndpoint(t *testing.T) {
 
 	cleanupCSV, err := createCSV(t, c, crc, failingCSV, testNamespace, false, false)
 	require.NoError(t, err)
-	defer cleanupCSV()
 
 	_, err = fetchCSV(t, crc, failingCSV.Name, testNamespace, csvFailedChecker)
 	require.NoError(t, err)
@@ -53,9 +52,17 @@ func TestMetricsEndpoint(t *testing.T) {
 	require.Contains(t, rawOutput, "phase=\"Failed\"")
 	require.Contains(t, rawOutput, "reason=\"UnsupportedOperatorGroup\"")
 	require.Contains(t, rawOutput, "version=\"0.0.0\"")
-
 	require.Contains(t, rawOutput, "csv_succeeded")
-	log.Info(rawOutput)
+
+	cleanupCSV()
+
+	rawOutput, err = getMetricsFromPod(t, c, getOLMPodName(t, c), operatorNamespace, "8081")
+	if err != nil {
+		t.Fatalf("Failed to retrieve metrics from OLM pod because of: %v\n", err)
+	}
+	require.NotContains(t, rawOutput, "csv_abnormal{name=\""+failingCSV.Name+"\"")
+	require.NotContains(t, rawOutput, "csv_succeeded{name=\""+failingCSV.Name+"\"")
+
 }
 
 func getOLMPodName(t *testing.T, client operatorclient.ClientInterface) string {