Informer based CustomResourceEventSource and caching (#581)

feat: This is a major change and backbone of v2. We change also how the Resources are addressed both internally and from event source with CustomResourceID. Additional improvements also added.


* chore: renaming vars named k8sClient to kubernetsClient

* chore(deps): bump jandex-maven-plugin from 1.1.1 to 1.2.1 (#592)

Bumps [jandex-maven-plugin](https://github.com/wildfly/jandex-maven-plugin) from 1.1.1 to 1.2.1.
- [Release notes](https://github.com/wildfly/jandex-maven-plugin/releases)
- [Commits](wildfly/jandex-maven-plugin@1.1.1...1.2.1)

---
updated-dependencies:
- dependency-name: org.jboss.jandex:jandex-maven-plugin
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* chore(deps-dev): bump mockito-core from 3.12.4 to 4.0.0 (#591)

Bumps [mockito-core](https://github.com/mockito/mockito) from 3.12.4 to 4.0.0.
- [Release notes](https://github.com/mockito/mockito/releases)
- [Commits](mockito/mockito@v3.12.4...v4.0.0)

---
updated-dependencies:
- dependency-name: org.mockito:mockito-core
  dependency-type: direct:development
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* feature: Build PR on v2

* chore(ci): use Java 17

* chore(ci): use only Temurin distribution

* chore: add generics to PostExecutionControl to reduce IDEs noise (#594)

* chore: polish the junit5 extension (#593)

* feat: Use informers as CustomResourceEventSource backbone and cache


Co-authored-by: Ioannis Canellos <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Chris Laprun <[email protected]>
Co-authored-by: Luca Burgazzoli <[email protected]>

Author: 5 people

.gitignore

@@ -10,3 +10,5 @@ target/
 
 #  VSCode
 .factorypath
+
+.mvn/wrapper/maven-wrapper.jar

micrometer-support/src/main/java/io/javaoperatorsdk/operator/micrometer/MicrometerMetrics.java

@@ -5,6 +5,7 @@
 
 import io.javaoperatorsdk.operator.Metrics;
 import io.javaoperatorsdk.operator.processing.DefaultEventHandler.EventMonitor;
+import io.javaoperatorsdk.operator.processing.event.CustomResourceID;
 import io.javaoperatorsdk.operator.processing.event.Event;
 import io.micrometer.core.instrument.MeterRegistry;
 import io.micrometer.core.instrument.Timer;
@@ -15,12 +16,12 @@ public class MicrometerMetrics implements Metrics {
   private final MeterRegistry registry;
   private final EventMonitor monitor = new EventMonitor() {
     @Override
-    public void processedEvent(String uid, Event event) {
+    public void processedEvent(CustomResourceID uid, Event event) {
       incrementProcessedEventsNumber();
     }
 
     @Override
-    public void failedEvent(String uid, Event event) {
+    public void failedEvent(CustomResourceID uid, Event event) {
       incrementControllerRetriesNumber();
     }
   };

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/ControllerUtils.java

@@ -18,7 +18,7 @@ public static String getNameFor(Class<? extends ResourceController> controllerCl
     final var annotation = controllerClass.getAnnotation(Controller.class);
     if (annotation != null) {
       final var name = annotation.name();
-      if (!Controller.NULL.equals(name)) {
+      if (!Controller.EMPTY_STRING.equals(name)) {
         return name;
       }
     }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/EventListUtils.java

@@ -2,9 +2,9 @@
 
 import java.util.List;
 
-import io.fabric8.kubernetes.client.Watcher;
 import io.javaoperatorsdk.operator.processing.event.Event;
 import io.javaoperatorsdk.operator.processing.event.internal.CustomResourceEvent;
+import io.javaoperatorsdk.operator.processing.event.internal.ResourceAction;
 
 public class EventListUtils {
 
@@ -13,7 +13,7 @@ public static boolean containsCustomResourceDeletedEvent(List<Event> events) {
         .anyMatch(
             e -> {
               if (e instanceof CustomResourceEvent) {
-                return ((CustomResourceEvent) e).getAction() == Watcher.Action.DELETED;
+                return ((CustomResourceEvent) e).getAction() == ResourceAction.DELETED;
               } else {
                 return false;
               }

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

@@ -11,11 +11,11 @@
 @Target({ElementType.TYPE})
 public @interface Controller {
 
-  String NULL = "";
+  String EMPTY_STRING = "";
   String WATCH_CURRENT_NAMESPACE = "JOSDK_WATCH_CURRENT";
   String NO_FINALIZER = "JOSDK_NO_FINALIZER";
 
-  String name() default NULL;
+  String name() default EMPTY_STRING;
 
   /**
    * Optional finalizer name, if it is not provided, one will be automatically generated. If the
@@ -24,7 +24,7 @@
    *
    * @return the finalizer name
    */
-  String finalizerName() default NULL;
+  String finalizerName() default EMPTY_STRING;
 
   /**
    * If true, will dispatch new event to the controller if generation increased since the last
@@ -50,7 +50,7 @@
    *
    * @return the label selector
    */
-  String labelSelector() default NULL;
+  String labelSelector() default EMPTY_STRING;
 
 
   /**

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/AbstractControllerConfiguration.java

@@ -19,7 +19,7 @@ public class DefaultControllerConfiguration<R extends CustomResource<?, ?>>
   private final RetryConfiguration retryConfiguration;
   private final String labelSelector;
   private final CustomResourceEventFilter<R> customResourceEventFilter;
-  private Class<R> customResourceClass;
+  private final Class<R> customResourceClass;
   private ConfigurationService service;
 
   public DefaultControllerConfiguration(
@@ -54,29 +54,6 @@ public DefaultControllerConfiguration(
     setConfigurationService(service);
   }
 
-  @Deprecated
-  public DefaultControllerConfiguration(
-      String associatedControllerClassName,
-      String name,
-      String crdName,
-      String finalizer,
-      boolean generationAware,
-      Set<String> namespaces,
-      RetryConfiguration retryConfiguration) {
-    this(
-        associatedControllerClassName,
-        name,
-        crdName,
-        finalizer,
-        generationAware,
-        namespaces,
-        retryConfiguration,
-        null,
-        null,
-        null,
-        null);
-  }
-
   @Override
   public String getName() {
     return name;