managed by

internal/controller/cache/cache.go

@@ -21,20 +21,20 @@ func New(config *rest.Config, options cache.Options) (cache.Cache, error) {
 
 func applySelectors(options cache.Options) cache.Options {
 	// The only objects we allow are the ones with the 'created-by: nats-manager' label applied.
-	createdByNATSManager := fromLabelSelector(label.SelectorCreatedByNATS())
+	labelSelector := fromLabelSelector(label.SelectorManagedByNATS())
 
 	// Apply the label selector to all relevant objects.
 	options.ByObject = map[client.Object]cache.ByObject{
-		&appsv1.Deployment{}:                     createdByNATSManager,
-		&autoscalingv1.HorizontalPodAutoscaler{}: createdByNATSManager,
-		&corev1.ServiceAccount{}:                 createdByNATSManager,
-		&rbacv1.ClusterRole{}:                    createdByNATSManager,
-		&rbacv1.ClusterRoleBinding{}:             createdByNATSManager,
-		&policyv1.PodDisruptionBudget{}:          createdByNATSManager,
+		&appsv1.Deployment{}:                     labelSelector,
+		&autoscalingv1.HorizontalPodAutoscaler{}: labelSelector,
+		&corev1.ServiceAccount{}:                 labelSelector,
+		&rbacv1.ClusterRole{}:                    labelSelector,
+		&rbacv1.ClusterRoleBinding{}:             labelSelector,
+		&policyv1.PodDisruptionBudget{}:          labelSelector,
 
-		&corev1.ConfigMap{}: createdByNATSManager,
-		&corev1.Secret{}:    createdByNATSManager,
-		&corev1.Service{}:   createdByNATSManager,
+		&corev1.ConfigMap{}: labelSelector,
+		&corev1.Secret{}:    labelSelector,
+		&corev1.Service{}:   labelSelector,
 	}
 	return options
 }

pkg/label/label.go

@@ -30,3 +30,8 @@ func SelectorInstanceNATS() labels.Selector {
 func SelectorCreatedByNATS() labels.Selector {
 	return labels.SelectorFromSet(map[string]string{KeyCreatedBy: ValueNATSManager})
 }
+
+// TODO
+func SelectorManagedByNATS() labels.Selector {
+	return labels.SelectorFromSet(map[string]string{KeyManagedBy: ValueNATSManager})
+}