add OwnerReference for Statefulsets

Author: Schmaetz

pkg/cluster/cluster.go

@@ -176,6 +176,19 @@ func (c *Cluster) clusterNamespace() string {
 	return c.ObjectMeta.Namespace
 }
 
+func (c *Cluster) createOwnerReference() []metav1.OwnerReference {
+	return []metav1.OwnerReference{
+		{
+			APIVersion:         c.APIVersion,
+			Kind:               c.Kind,
+			Name:               c.Name,
+			UID:                c.UID,
+			Controller:         util.True(),
+			BlockOwnerDeletion: util.True(),
+		},
+	}
+}
+
 func (c *Cluster) teamName() string {
 	// TODO: check Teams API for the actual name (in case the user passes an integer Id).
 	return c.Spec.TeamID

pkg/cluster/k8sres.go

@@ -1660,10 +1660,11 @@ func (c *Cluster) generateStatefulSet(spec *cpov1.PostgresSpec) (*appsv1.Statefu
 
 	statefulSet := &appsv1.StatefulSet{
 		ObjectMeta: metav1.ObjectMeta{
-			Name:        c.statefulSetName(),
-			Namespace:   c.Namespace,
-			Labels:      c.labelsSetWithType(true, TYPE_POSTGRESQL),
-			Annotations: c.AnnotationsToPropagate(c.annotationsSet(nil)),
+			Name:            c.statefulSetName(),
+			Namespace:       c.Namespace,
+			Labels:          c.labelsSetWithType(true, TYPE_POSTGRESQL),
+			Annotations:     c.AnnotationsToPropagate(c.annotationsSet(nil)),
+			OwnerReferences: c.createOwnerReference(),
 		},
 		Spec: appsv1.StatefulSetSpec{
 			Replicas:                             &numberOfInstances,
@@ -1921,10 +1922,11 @@ func (c *Cluster) generateRepoHostStatefulSet(spec *cpov1.PostgresSpec) (*appsv1
 
 	statefulSet := &appsv1.StatefulSet{
 		ObjectMeta: metav1.ObjectMeta{
-			Name:        c.getPgbackrestRepoHostName(),
-			Namespace:   c.Namespace,
-			Labels:      repoHostLabels,
-			Annotations: c.AnnotationsToPropagate(c.annotationsSet(nil)),
+			Name:            c.getPgbackrestRepoHostName(),
+			Namespace:       c.Namespace,
+			Labels:          repoHostLabels,
+			Annotations:     c.AnnotationsToPropagate(c.annotationsSet(nil)),
+			OwnerReferences: c.createOwnerReference(),
 		},
 		Spec: appsv1.StatefulSetSpec{
 			Replicas:                             &numberOfInstances,