feat(main): add owner to endpoint (#24)

labring · Jan 14, 2022 · b6a252d · b6a252d
1 parent fb8ed90
commit b6a252d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/controllers/sync.go b/controllers/sync.go
@@ -83,6 +83,9 @@ func (c *Reconciler) syncEndpoint(ctx context.Context, cep *v1beta1.ClusterEndpo
 		ep.SetNamespace(cep.Namespace)
 		_, err := controllerutil.CreateOrUpdate(ctx, c.Client, ep, func() error {
 			ep.Labels = map[string]string{}
+			if err := controllerutil.SetControllerReference(cep, ep, c.scheme); err != nil {
+				return err
+			}
 			healthyHosts := make([]healthyHostAndPort, 0)
 			e := make([]error, 0)
 			for _, h := range cep.Spec.Hosts {