improve: onList removal of ghost resources

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

@@ -155,13 +155,7 @@ public synchronized void start() {
     }
     temporaryResourceCache =
         new TemporaryResourceCache<>(
-            comparableResourceVersions,
-            configuration.getInformerConfig().getGhostResourceCacheCheckInterval().toMillis(),
-            controllerConfiguration
-                .getConfigurationService()
-                .getExecutorServiceManager()
-                .scheduledExecutorService(),
-            this);
+            comparableResourceVersions,this);
     this.cache = new InformerManager<>(client, configuration, this);
     cache.setControllerConfiguration(controllerConfiguration);
     cache.addIndexers(indexers);

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

@@ -71,18 +71,9 @@ public enum EventHandling {
 
   public TemporaryResourceCache(
       boolean comparableResourceVersions,
-      long ghostResourceCheckInterval,
-      ScheduledExecutorService ghostCheckExecutor,
       ManagedInformerEventSource<T, ?, ?> managedInformerEventSource) {
     this.comparableResourceVersions = comparableResourceVersions;
     this.managedInformerEventSource = managedInformerEventSource;
-    if (comparableResourceVersions) {
-      ghostCheckExecutor.scheduleWithFixedDelay(
-          this::checkGhostResources,
-          ghostResourceCheckInterval,
-          ghostResourceCheckInterval,
-          TimeUnit.MILLISECONDS);
-    }
   }
 
   public synchronized void startEventFilteringModify(ResourceID resourceID) {
@@ -240,7 +231,7 @@ private String getLastSyncResourceVersion(String namespace) {
    * In this case neither the ADD nor DELETE event will be propagated to the informer, but we
    * explicitly add resources to this cache. Those are cleaned up by this check.
    */
-  private void checkGhostResources() {
+  public void checkGhostResources() {
     log.debug("Checking for ghost resources.");
     var iterator = cache.entrySet().iterator();
     while (iterator.hasNext()) {

pom.xml

@@ -70,7 +70,7 @@
     <sonar.host.url>https://sonarcloud.io</sonar.host.url>
     <fabric8-httpclient-impl.name>jdk</fabric8-httpclient-impl.name>
     <junit.version>6.0.3</junit.version>
-    <fabric8-client.version>7.6.1</fabric8-client.version>
+    <fabric8-client.version>7.7-SNAPSHOT</fabric8-client.version>
     <slf4j.version>2.0.17</slf4j.version>
     <log4j.version>2.25.3</log4j.version>
     <mokito.version>5.23.0</mokito.version>
@@ -621,4 +621,15 @@
       </build>
     </profile>
   </profiles>
+
+  <repositories>
+    <repository>
+      <id>sonatype-snapshots</id>
+      <url>https://oss.sonatype.org/content/repositories/snapshots</url>
+      <snapshots>
+        <enabled>true</enabled>
+      </snapshots>
+    </repository>
+  </repositories>
+
 </project>