factory

Author: csviri

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

@@ -1,8 +1,5 @@
 package io.javaoperatorsdk.operator.processing.event.source.cache;
 
-import java.util.HashSet;
-import java.util.Set;
-
 import com.github.benmanes.caffeine.cache.Cache;
 
 public class CaffeinBoundedCache<K, R> implements BoundedCache<K, R> {

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

@@ -0,0 +1,38 @@
+package io.javaoperatorsdk.operator.processing.event.source.cache;
+
+import java.time.Duration;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.fabric8.kubernetes.client.KubernetesClient;
+
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+
+public class CaffeinBoundedItemStores {
+
+  public static <R extends HasMetadata> BoundedItemStore<R> boundedItemStore(
+      KubernetesClient client, Class<R> rClass,
+      Duration accessExpireDuration, long cacheMaxSize) {
+    Cache<String, R> cache = Caffeine.newBuilder()
+        .expireAfterAccess(accessExpireDuration)
+        .maximumSize(cacheMaxSize)
+        .build();
+    return boundedItemStore(client, rClass, cache);
+  }
+
+  public static <R extends HasMetadata> BoundedItemStore<R> boundedItemStore(
+      KubernetesClient client, Class<R> rClass,
+      Duration accessExpireDuration) {
+    Cache<String, R> cache = Caffeine.newBuilder()
+        .expireAfterAccess(accessExpireDuration)
+        .build();
+    return boundedItemStore(client, rClass, cache);
+  }
+
+  public static <R extends HasMetadata> BoundedItemStore<R> boundedItemStore(
+      KubernetesClient client, Class<R> rClass, Cache<String, R> cache) {
+    return new BoundedItemStore<>(client,
+        new CaffeinBoundedCache<>(cache), rClass);
+  }
+
+}

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

@@ -1,6 +1,6 @@
 package io.javaoperatorsdk.operator.processing.event.source.cache;
 
-import java.util.concurrent.TimeUnit;
+import java.time.Duration;
 import java.util.stream.IntStream;
 
 import org.junit.jupiter.api.Test;
@@ -14,9 +14,6 @@
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.BoundedCacheTestReconciler;
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.BoundedCacheTestSpec;
 
-import com.github.benmanes.caffeine.cache.Cache;
-import com.github.benmanes.caffeine.cache.Caffeine;
-
 import static io.javaoperatorsdk.operator.processing.event.source.cache.sample.BoundedCacheTestReconciler.DATA_KEY;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
@@ -30,14 +27,10 @@ class CaffeinBoundedCacheIT {
   @RegisterExtension
   LocallyRunOperatorExtension extension =
       LocallyRunOperatorExtension.builder().withReconciler(new BoundedCacheTestReconciler(), o -> {
-        Cache<String, BoundedCacheTestCustomResource> cache = Caffeine.newBuilder()
-            .expireAfterAccess(1, TimeUnit.MINUTES)
-            .maximumSize(1)
-            .build();
-        BoundedItemStore<BoundedCacheTestCustomResource> boundedItemStore =
-            new BoundedItemStore<>(new KubernetesClientBuilder().build(),
-                new CaffeinBoundedCache<>(cache), BoundedCacheTestCustomResource.class);
-        o.withItemStore(boundedItemStore);
+        o.withItemStore(CaffeinBoundedItemStores.boundedItemStore(
+            new KubernetesClientBuilder().build(), BoundedCacheTestCustomResource.class,
+            Duration.ofMinutes(1),
+            1));
       })
           .build();
 

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

@@ -1,7 +1,7 @@
 package io.javaoperatorsdk.operator.processing.event.source.cache.sample;
 
+import java.time.Duration;
 import java.util.Map;
-import java.util.concurrent.TimeUnit;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -10,17 +10,14 @@
 import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
 import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
 import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.KubernetesClientBuilder;
 import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
 import io.javaoperatorsdk.operator.api.reconciler.*;
 import io.javaoperatorsdk.operator.junit.KubernetesClientAware;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
-import io.javaoperatorsdk.operator.processing.event.source.cache.BoundedItemStore;
-import io.javaoperatorsdk.operator.processing.event.source.cache.CaffeinBoundedCache;
+import io.javaoperatorsdk.operator.processing.event.source.cache.CaffeinBoundedItemStores;
 import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
 
-import com.github.benmanes.caffeine.cache.Cache;
-import com.github.benmanes.caffeine.cache.Caffeine;
-
 @ControllerConfiguration
 public class BoundedCacheTestReconciler implements Reconciler<BoundedCacheTestCustomResource>,
     EventSourceInitializer<BoundedCacheTestCustomResource>, KubernetesClientAware {
@@ -66,13 +63,11 @@ private void createConfigMap(BoundedCacheTestCustomResource resource) {
   @Override
   public Map<String, EventSource> prepareEventSources(
       EventSourceContext<BoundedCacheTestCustomResource> context) {
-    Cache<String, ConfigMap> cache = Caffeine.newBuilder()
-        .expireAfterAccess(1, TimeUnit.MINUTES)
-        .maximumSize(1)
-        .build();
 
-    BoundedItemStore<ConfigMap> boundedItemStore = new BoundedItemStore<>(client,
-        new CaffeinBoundedCache<>(cache), ConfigMap.class);
+    var boundedItemStore =
+        CaffeinBoundedItemStores.boundedItemStore(new KubernetesClientBuilder().build(),
+            ConfigMap.class, Duration.ofMinutes(1),
+            1);
 
     var es = new InformerEventSource<>(InformerConfiguration.from(ConfigMap.class, context)
         .withItemStore(boundedItemStore)