feat: remove resource discriminator (#2299)

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

docs/documentation/v5-0-migration.md

@@ -26,3 +26,5 @@ permalink: /docs/v5-0-migration
    Also, the related part of a [workaround](https://github.com/operator-framework/java-operator-sdk/blob/main/operator-framework/src/test/java/io/javaoperatorsdk/operator/StatusPatchSSAMigrationIT.java#L110-L116).
 4. `ManagedDependentResourceContext` has been renamed to `ManagedWorkflowAndDependentResourceContext` and is accessed
    via the accordingly renamed `managedWorkflowAndDependentResourceContext` method.
+5. `ResourceDiscriminator` was removed. In most of the cases you can just delete the discriminator, everything should
+    work without it by default. To optimize and handle special cases see the relevant section in [Dependent Resource documentation](/docs/dependent-resources#multiple-dependent-resources-of-same-type).

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/Context.java

@@ -17,7 +17,7 @@ public interface Context<P extends HasMetadata> {
   Optional<RetryInfo> getRetryInfo();
 
   default <R> Optional<R> getSecondaryResource(Class<R> expectedType) {
-    return getSecondaryResource(expectedType, (String) null);
+    return getSecondaryResource(expectedType, null);
   }
 
   <R> Set<R> getSecondaryResources(Class<R> expectedType);
@@ -29,9 +29,6 @@ default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
   @Deprecated(forRemoval = true)
   <R> Optional<R> getSecondaryResource(Class<R> expectedType, String eventSourceName);
 
-  <R> Optional<R> getSecondaryResource(Class<R> expectedType,
-      ResourceDiscriminator<R, P> discriminator);
-
   ControllerConfiguration<P> getControllerConfiguration();
 
   /**

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/DefaultContext.java

@@ -68,12 +68,6 @@ public <T> Optional<T> getSecondaryResource(Class<T> expectedType, String eventS
         .getSecondaryResource(primaryResource);
   }
 
-  @Override
-  public <R> Optional<R> getSecondaryResource(Class<R> expectedType,
-      ResourceDiscriminator<R, P> discriminator) {
-    return discriminator.distinguish(expectedType, primaryResource, this);
-  }
-
   @Override
   public ControllerConfiguration<P> getControllerConfiguration() {
     return controllerConfiguration;

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/IndexDiscriminator.java

@@ -9,7 +9,6 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.Ignore;
-import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.Deleter;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.NameSetter;
@@ -28,7 +27,6 @@ public abstract class AbstractDependentResource<R, P extends HasMetadata>
 
   protected Creator<R, P> creator;
   protected Updater<R, P> updater;
-  private ResourceDiscriminator<R, P> resourceDiscriminator;
   private final DependentResourceReconciler<R, P> dependentResourceReconciler;
 
   protected String name;
@@ -105,16 +103,14 @@ protected ReconcileResult<R> reconcile(P primary, R actualResource, Context<P> c
 
   @Override
   public Optional<R> getSecondaryResource(P primary, Context<P> context) {
-    if (resourceDiscriminator != null) {
-      return resourceDiscriminator.distinguish(resourceType(), primary, context);
+
+    var secondaryResources = context.getSecondaryResources(resourceType());
+    if (secondaryResources.isEmpty()) {
+      return Optional.empty();
     } else {
-      var secondaryResources = context.getSecondaryResources(resourceType());
-      if (secondaryResources.isEmpty()) {
-        return Optional.empty();
-      } else {
-        return selectManagedSecondaryResource(secondaryResources, primary, context);
-      }
+      return selectManagedSecondaryResource(secondaryResources, primary, context);
     }
+
   }
 
   /**
@@ -205,10 +201,6 @@ protected void handleDelete(P primary, R secondary, Context<P> context) {
         "handleDelete method must be implemented if Deleter trait is supported");
   }
 
-  public void setResourceDiscriminator(ResourceDiscriminator<R, P> resourceDiscriminator) {
-    this.resourceDiscriminator = resourceDiscriminator;
-  }
-
   protected boolean isCreatable() {
     return creatable;
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ResourceDiscriminator.java

@@ -6,7 +6,6 @@
 import java.lang.annotation.Target;
 
 import io.javaoperatorsdk.operator.api.reconciler.Constants;
-import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
 import io.javaoperatorsdk.operator.processing.event.source.filter.GenericFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnAddFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnDeleteFilter;
@@ -70,8 +69,6 @@
    */
   Class<? extends GenericFilter> genericFilter() default GenericFilter.class;
 
-  Class<? extends ResourceDiscriminator> resourceDiscriminator() default ResourceDiscriminator.class;
-
   /**
    * Creates the resource only if did not exist before, this applies only if SSA is used.
    */

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ResourceIDMatcherDiscriminator.java

@@ -8,7 +8,6 @@
 import io.javaoperatorsdk.operator.api.config.Utils;
 import io.javaoperatorsdk.operator.api.config.dependent.ConfigurationConverter;
 import io.javaoperatorsdk.operator.api.reconciler.Constants;
-import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
 import io.javaoperatorsdk.operator.processing.event.source.filter.GenericFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnAddFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnDeleteFilter;
@@ -33,7 +32,6 @@ public KubernetesDependentResourceConfig<R> configFrom(KubernetesDependent confi
     OnUpdateFilter<? extends HasMetadata> onUpdateFilter = null;
     OnDeleteFilter<? extends HasMetadata> onDeleteFilter = null;
     GenericFilter<? extends HasMetadata> genericFilter = null;
-    ResourceDiscriminator<?, ?> resourceDiscriminator = null;
     Boolean useSSA = null;
     if (configAnnotation != null) {
       if (!Arrays.equals(KubernetesDependent.DEFAULT_NAMESPACES, configAnnotation.namespaces())) {
@@ -54,16 +52,13 @@ public KubernetesDependentResourceConfig<R> configFrom(KubernetesDependent confi
       genericFilter =
           Utils.instantiate(configAnnotation.genericFilter(), GenericFilter.class, context);
 
-      resourceDiscriminator =
-          Utils.instantiate(configAnnotation.resourceDiscriminator(), ResourceDiscriminator.class,
-              context);
       createResourceOnlyIfNotExistingWithSSA =
           configAnnotation.createResourceOnlyIfNotExistingWithSSA();
       useSSA = configAnnotation.useSSA().asBoolean();
     }
 
     return new KubernetesDependentResourceConfig(namespaces, labelSelector, configuredNS,
         createResourceOnlyIfNotExistingWithSSA,
-        resourceDiscriminator, useSSA, onAddFilter, onUpdateFilter, onDeleteFilter, genericFilter);
+        useSSA, onAddFilter, onUpdateFilter, onDeleteFilter, genericFilter);
   }
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/AbstractDependentResource.java

@@ -59,10 +59,6 @@ public KubernetesDependentResource(Class<R> resourceType, String name) {
   @Override
   public void configureWith(KubernetesDependentResourceConfig<R> config) {
     this.kubernetesDependentResourceConfig = config;
-    var discriminator = kubernetesDependentResourceConfig.getResourceDiscriminator();
-    if (discriminator != null) {
-      setResourceDiscriminator(discriminator);
-    }
   }
 
   private void configureWith(String labelSelector, Set<String> namespaces,
@@ -250,10 +246,6 @@ protected InformerEventSource<R, P> createEventSource(EventSourceContext<P> cont
       onUpdateFilter = kubernetesDependentResourceConfig.onUpdateFilter();
       onDeleteFilter = kubernetesDependentResourceConfig.onDeleteFilter();
       genericFilter = kubernetesDependentResourceConfig.genericFilter();
-      var discriminator = kubernetesDependentResourceConfig.getResourceDiscriminator();
-      if (discriminator != null) {
-        setResourceDiscriminator(discriminator);
-      }
       configureWith(kubernetesDependentResourceConfig.labelSelector(),
           kubernetesDependentResourceConfig.namespaces(),
           !kubernetesDependentResourceConfig.wereNamespacesConfigured(), context);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependent.java

@@ -4,7 +4,6 @@
 import java.util.Set;
 
 import io.javaoperatorsdk.operator.api.reconciler.Constants;
-import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
 import io.javaoperatorsdk.operator.processing.event.source.filter.GenericFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnAddFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnDeleteFilter;
@@ -20,7 +19,6 @@ public class KubernetesDependentResourceConfig<R> {
   private String labelSelector;
   private final boolean namespacesWereConfigured;
   private final boolean createResourceOnlyIfNotExistingWithSSA;
-  private final ResourceDiscriminator<R, ?> resourceDiscriminator;
   private final Boolean useSSA;
 
   private final OnAddFilter<R> onAddFilter;
@@ -31,15 +29,14 @@ public class KubernetesDependentResourceConfig<R> {
   public KubernetesDependentResourceConfig() {
     this(Constants.SAME_AS_CONTROLLER_NAMESPACES_SET, NO_VALUE_SET, true,
         DEFAULT_CREATE_RESOURCE_ONLY_IF_NOT_EXISTING_WITH_SSA,
-        null, null, null,
+        null, null,
         null, null, null);
   }
 
   public KubernetesDependentResourceConfig(Set<String> namespaces,
       String labelSelector,
       boolean configuredNS,
       boolean createResourceOnlyIfNotExistingWithSSA,
-      ResourceDiscriminator<R, ?> resourceDiscriminator,
       Boolean useSSA,
       OnAddFilter<R> onAddFilter,
       OnUpdateFilter<R> onUpdateFilter,
@@ -52,15 +49,14 @@ public KubernetesDependentResourceConfig(Set<String> namespaces,
     this.onUpdateFilter = onUpdateFilter;
     this.onDeleteFilter = onDeleteFilter;
     this.genericFilter = genericFilter;
-    this.resourceDiscriminator = resourceDiscriminator;
     this.useSSA = useSSA;
   }
 
   // use builder instead
   @Deprecated(forRemoval = true)
   public KubernetesDependentResourceConfig(Set<String> namespaces, String labelSelector) {
     this(namespaces, labelSelector, true, DEFAULT_CREATE_RESOURCE_ONLY_IF_NOT_EXISTING_WITH_SSA,
-        null, null, null,
+        null, null,
         null, null, null);
   }
 
@@ -104,11 +100,6 @@ public GenericFilter<R> genericFilter() {
     return genericFilter;
   }
 
-  @SuppressWarnings("rawtypes")
-  public ResourceDiscriminator getResourceDiscriminator() {
-    return resourceDiscriminator;
-  }
-
   @SuppressWarnings("unused")
   protected void setNamespaces(Set<String> namespaces) {
     if (!wereNamespacesConfigured() && namespaces != null && !namespaces.isEmpty()) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependentConverter.java

@@ -3,7 +3,6 @@
 import java.util.Set;
 
 import io.javaoperatorsdk.operator.api.reconciler.Constants;
-import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
 import io.javaoperatorsdk.operator.processing.event.source.filter.GenericFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnAddFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnDeleteFilter;
@@ -14,7 +13,6 @@ public final class KubernetesDependentResourceConfigBuilder<R> {
   private Set<String> namespaces = Constants.SAME_AS_CONTROLLER_NAMESPACES_SET;
   private String labelSelector;
   private boolean createResourceOnlyIfNotExistingWithSSA;
-  private ResourceDiscriminator<R, ?> resourceDiscriminator;
   private Boolean useSSA;
   private OnAddFilter<R> onAddFilter;
   private OnUpdateFilter<R> onUpdateFilter;
@@ -43,12 +41,6 @@ public KubernetesDependentResourceConfigBuilder<R> withCreateResourceOnlyIfNotEx
     return this;
   }
 
-  public KubernetesDependentResourceConfigBuilder<R> withResourceDiscriminator(
-      ResourceDiscriminator<R, ?> resourceDiscriminator) {
-    this.resourceDiscriminator = resourceDiscriminator;
-    return this;
-  }
-
   public KubernetesDependentResourceConfigBuilder<R> withUseSSA(Boolean useSSA) {
     this.useSSA = useSSA;
     return this;
@@ -80,7 +72,7 @@ public KubernetesDependentResourceConfigBuilder<R> withGenericFilter(
   public KubernetesDependentResourceConfig<R> build() {
     return new KubernetesDependentResourceConfig<>(namespaces, labelSelector,
         namespaces != Constants.SAME_AS_CONTROLLER_NAMESPACES_SET,
-        createResourceOnlyIfNotExistingWithSSA, resourceDiscriminator, useSSA, onAddFilter,
+        createResourceOnlyIfNotExistingWithSSA, useSSA, onAddFilter,
         onUpdateFilter, onDeleteFilter, genericFilter);
   }
 }