wip

Author: csviri

caffein-bounded-cache-support/src/main/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCache.java

@@ -2,6 +2,9 @@
 
 import com.github.benmanes.caffeine.cache.Cache;
 
+/**
+ * Caffein cache wrapper to be used in a {@link BoundedItemStore}
+ * */
 public class CaffeinBoundedCache<K, R> implements BoundedCache<K, R> {
 
   private Cache<K, R> cache;

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/BoundedCacheTestBase.java

@@ -1,5 +1,6 @@
 package io.javaoperatorsdk.operator.processing.event.source.cache;
 
+import java.time.Duration;
 import java.util.stream.IntStream;
 
 import org.junit.jupiter.api.Test;
@@ -37,7 +38,7 @@ void reconciliationWorksWithLimitedCache() {
   }
 
   private void assertConfigMapsDeleted() {
-    await().untilAsserted(() -> IntStream.range(0, NUMBER_OF_RESOURCE_TO_TEST).forEach(i -> {
+    await().atMost(Duration.ofSeconds(20)).untilAsserted(() -> IntStream.range(0, NUMBER_OF_RESOURCE_TO_TEST).forEach(i -> {
       var cm = extension().get(ConfigMap.class, RESOURCE_NAME_PREFIX + i);
       assertThat(cm).isNull();
     }));

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

@@ -124,6 +124,17 @@ default Set<String> getEffectiveNamespaces() {
     return targetNamespaces;
   }
 
+  /**
+   * See <a href="https://github.com/fabric8io/kubernetes-client/blob/43b67939fde91046ab7fb0c362f500c2b46eb59e/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/impl/DefaultSharedIndexInformer.java#L273">related method</a>
+   * in fabric8 client.
+   *
+   * The main goal, is to be able to use limited caches.
+   *
+   * See {@link io.javaoperatorsdk.operator.processing.event.source.cache.BoundedItemStore} and <a href="https://github.com/java-operator-sdk/java-operator-sdk/blob/d6eda0138dba6d93c0ff22a5ffcaa7663fa65ca2/caffein-bounded-cache-support/src/main/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCache.java">
+   *     CaffeinBoundedCache</a>
+   *
+   * @return Optional ItemStore implementation. If present this item store will be used inside the informers.
+   */
   default Optional<ItemStore<R>> getItemStore() {
     return Optional.empty();
   }