Introduce Thread Safety test for UpdateSubsSyncCounterStorage

Introduces a test that ensure that the UpdateSubsSyncCounterStorage
function is thread safe and avoids concurrent map writes.

Signed-off-by: Alexander Greene <[email protected]>

Author: awgreene

Diff for: pkg/metrics/metrics_test.go

@@ -0,0 +1,33 @@
+package metrics
+
+import (
+	"fmt"
+	"testing"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
+)
+
+func TestUpdateSubsSyncCounterStorageThreadSafety(t *testing.T) {
+	sub := &operatorsv1alpha1.Subscription{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace: "foo",
+			Name:      "foo",
+		},
+		Spec: &operatorsv1alpha1.SubscriptionSpec{
+			Channel:             "foo",
+			Package:             "foo",
+			InstallPlanApproval: "automatic",
+		},
+		Status: operatorsv1alpha1.SubscriptionStatus{
+			InstalledCSV: "foo",
+		},
+	}
+	for i := 0; i < 1000; i++ {
+		go func(ii int) {
+			sub.Spec.Channel = fmt.Sprintf("bar-%v", ii)
+			UpdateSubsSyncCounterStorage(sub)
+		}(i)
+	}
+}