chore: append ownerRef to resources owned by Features (opendatahub-io…

…#1039)

* rename / chg FeatureOwner func

* remove unused old ownerref func

pkg/cluster/cluster_operations_int_test.go

@@ -92,6 +92,13 @@ var _ = Describe("Creating cluster resources", func() {
 			Namespace: "default",
 		}
 
+		owner := &v1.Namespace{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: "default",
+				UID:  "default",
+			},
+		}
+
 		It("should create configmap with labels and owner reference", func() {
 			// given
 			configMap := &v1.ConfigMap{
@@ -107,12 +114,7 @@ var _ = Describe("Creating cluster resources", func() {
 				envTestClient,
 				configMap,
 				cluster.WithLabels(labels.K8SCommon.PartOf, "opendatahub"),
-				cluster.WithOwnerReference(metav1.OwnerReference{
-					APIVersion: "v1",
-					Kind:       "Namespace",
-					Name:       "default",
-					UID:        "default",
-				}),
+				cluster.OwnedBy(owner, envTestClient.Scheme()),
 			)
 			Expect(err).ToNot(HaveOccurred())
 			defer objectCleaner.DeleteAll(configMap)

pkg/cluster/meta.go

@@ -22,13 +22,6 @@ func ApplyMetaOptions(obj metav1.Object, opts ...MetaOptions) error {
 	return nil
 }
 
-func WithOwnerReference(ownerReferences ...metav1.OwnerReference) MetaOptions {
-	return func(obj metav1.Object) error {
-		obj.SetOwnerReferences(ownerReferences)
-		return nil
-	}
-}
-
 func OwnedBy(owner metav1.Object, scheme *runtime.Scheme) MetaOptions {
 	return func(obj metav1.Object) error {
 		return controllerutil.SetOwnerReference(owner, obj, scheme)

pkg/feature/feature.go

@@ -160,7 +160,7 @@ func (f *Feature) createApplier(m Manifest) applier {
 	}
 
 	return func(objects []*unstructured.Unstructured) error {
-		return applyResources(f.Client, objects, OwnedBy(f))
+		return applyResources(f.Client, objects, OwnedByFeatureTracker(f))
 	}
 }
 
@@ -197,6 +197,6 @@ func (f *Feature) AsOwnerReference() metav1.OwnerReference {
 	return f.Tracker.ToOwnerReference()
 }
 
-func OwnedBy(f *Feature) cluster.MetaOptions {
-	return cluster.WithOwnerReference(f.AsOwnerReference())
+func OwnedByFeatureTracker(f *Feature) cluster.MetaOptions {
+	return cluster.OwnedBy(f.Tracker, f.Client.Scheme())
 }

pkg/feature/servicemesh/conditions.go

@@ -28,7 +28,7 @@ func EnsureAuthNamespaceExists(f *feature.Feature) error {
 		return resolveNsErr
 	}
 
-	_, err := cluster.CreateNamespace(context.TODO(), f.Client, f.Spec.Auth.Namespace, feature.OwnedBy(f), cluster.WithLabels(labels.ODH.OwnedNamespace, "true"))
+	_, err := cluster.CreateNamespace(context.TODO(), f.Client, f.Spec.Auth.Namespace, feature.OwnedByFeatureTracker(f), cluster.WithLabels(labels.ODH.OwnedNamespace, "true"))
 	return err
 }
 

pkg/feature/servicemesh/resources.go

@@ -32,7 +32,7 @@ func MeshRefs(f *feature.Feature) error {
 			},
 			Data: data,
 		},
-		feature.OwnedBy(f),
+		feature.OwnedByFeatureTracker(f),
 	)
 }
 
@@ -66,6 +66,6 @@ func AuthRefs(f *feature.Feature) error {
 			},
 			Data: data,
 		},
-		feature.OwnedBy(f),
+		feature.OwnedByFeatureTracker(f),
 	)
 }