Merge branch 'main' into next

# Conflicts:
#	micrometer-support/pom.xml
#	operator-framework-core/pom.xml
#	operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/Utils.java
#	operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/Controller.java
#	operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
#	operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/ControllerResourceEventSource.java
#	operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/config/UtilsTest.java
#	operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/EventProcessorTest.java
#	operator-framework-junit5/pom.xml
#	operator-framework/pom.xml
#	pom.xml
#	sample-operators/mysql-schema/pom.xml
#	sample-operators/pom.xml
#	sample-operators/tomcat-operator/pom.xml
#	sample-operators/webpage/pom.xml
#	smoke-test-samples/common/pom.xml
#	smoke-test-samples/pom.xml
#	smoke-test-samples/pure-java/pom.xml
#	smoke-test-samples/spring-boot-plain/pom.xml

Author: csviri

docs/documentation/features.md

@@ -196,7 +196,7 @@ custom resource, the reconciliation could be skipped. This is supported out of t
 default is not triggered if the change to the main custom resource does not increase the `.metadata.generation` field.
 Note that the increase of `.metada.generation`  is handled automatically by Kubernetes.
 
-To turn on this feature set `generationAwareEventProcessing` to `false` for the `Reconciler`.
+To turn off this feature set `generationAwareEventProcessing` to `false` for the `Reconciler`.
 
 ## Support for Well Known (non-custom) Kubernetes Resources
 

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/OnceWhitelistEventFilterEventFilter.java

@@ -0,0 +1,50 @@
+package io.javaoperatorsdk.operator.processing.event.source.controller;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.event.ResourceID;
+
+public class TemporaryResourceCache<T extends HasMetadata> {
+
+  private static final Logger log = LoggerFactory.getLogger(TemporaryResourceCache.class);
+
+  private final Map<ResourceID, T> cache = new HashMap<>();
+  private final ControllerResourceCache<T> managedInformerEventSource;
+
+  public TemporaryResourceCache(ControllerResourceCache<T> managedInformerEventSource) {
+    this.managedInformerEventSource = managedInformerEventSource;
+  }
+
+  public synchronized void removeResourceFromCache(T resource) {
+    cache.remove(ResourceID.fromResource(resource));
+  }
+
+  public synchronized void putUpdatedResource(T newResource, String previousResourceVersion) {
+    var resourceId = ResourceID.fromResource(newResource);
+    var informerCacheResource = managedInformerEventSource.get(resourceId);
+    if (informerCacheResource.isEmpty()) {
+      log.debug("No cached value present for resource: {}", newResource);
+      return;
+    }
+    // if this is not true that means the cache was already updated
+    if (informerCacheResource.get().getMetadata().getResourceVersion()
+        .equals(previousResourceVersion)) {
+      log.debug("Putting resource to temporal cache with id: {}", resourceId);
+      cache.put(resourceId, newResource);
+    } else {
+      // if something is in cache it's surely obsolete now
+      cache.remove(resourceId);
+    }
+  }
+
+  public synchronized Optional<T> getResourceFromCache(ResourceID resourceID) {
+    return Optional.ofNullable(cache.get(resourceID));
+  }
+}
+

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/TemporaryResourceCache.java

@@ -21,11 +21,15 @@ public InClusterCurl(KubernetesClient client, String namespace) {
   }
 
   public String checkUrl(String url) {
+    return checkUrl("-s", "-o", "/dev/null", "-w", "%{http_code}", url);
+  }
+
+  public String checkUrl(String... args) {
     String podName = KubernetesResourceUtil.sanitizeName("curl-" + UUID.randomUUID());
     try {
       Pod curlPod = client.run().inNamespace(namespace)
           .withRunConfig(new RunConfigBuilder()
-              .withArgs("-s", "-o", "/dev/null", "-w", "%{http_code}", url)
+              .withArgs(args)
               .withName(podName)
               .withImage("curlimages/curl:7.78.0")
               .withRestartPolicy("Never")

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/OnceWhitelistEventFilterEventFilterTest.java

@@ -46,18 +46,18 @@
         <fabric8-client.version>5.12.0</fabric8-client.version>
         <slf4j.version>1.7.36</slf4j.version>
         <log4j.version>2.17.2</log4j.version>
-        <mokito.version>4.3.1</mokito.version>
+        <mokito.version>4.4.0</mokito.version>
         <commons-lang3.version>3.12.0</commons-lang3.version>
         <auto-service.version>1.0.1</auto-service.version>
         <compile-testing.version>0.19</compile-testing.version>
         <javapoet.version>1.13.0</javapoet.version>
         <assertj.version>3.22.0</assertj.version>
-        <awaitility.version>4.1.1</awaitility.version>
+        <awaitility.version>4.2.0</awaitility.version>
         <spring-boot.version>2.6.4</spring-boot.version>
         <micrometer-core.version>1.8.3</micrometer-core.version>
 
         <fmt-maven-plugin.version>2.11</fmt-maven-plugin.version>
-        <maven-compiler-plugin.version>3.10.0</maven-compiler-plugin.version>
+        <maven-compiler-plugin.version>3.10.1</maven-compiler-plugin.version>
         <maven-surefire-plugin.version>3.0.0-M5</maven-surefire-plugin.version>
         <maven-javadoc-plugin.version>3.3.2</maven-javadoc-plugin.version>
         <maven-resources-plugin.version>3.2.0</maven-resources-plugin.version>