test fix

Author: csviri

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

@@ -6,13 +6,15 @@
 import java.lang.annotation.Target;
 import java.util.concurrent.TimeUnit;
 
+import io.javaoperatorsdk.operator.processing.event.rate.PeriodRateLimiter;
+
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.TYPE})
 public @interface RateLimiter {
 
-  int limitForPeriod();
+  int limitForPeriod() default PeriodRateLimiter.NO_LIMIT_PERIOD;
 
-  int refreshPeriod();
+  int refreshPeriod() default PeriodRateLimiter.DEFAULT_REFRESH_PERIOD_SECONDS;
 
   /**
    * @return time unit for max delay between reconciliations

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/rate/PeriodRateLimiter.java

@@ -13,7 +13,10 @@
  */
 public class PeriodRateLimiter implements RateLimiter {
 
-  public static final Duration DEFAULT_REFRESH_PERIOD = Duration.ofSeconds(2);
+  public static final int DEFAULT_REFRESH_PERIOD_SECONDS = 2;
+  public static final Duration DEFAULT_REFRESH_PERIOD =
+      Duration.ofSeconds(DEFAULT_REFRESH_PERIOD_SECONDS);
+
   public static final int DEFAULT_LIMIT_FOR_PERIOD = 3;
   /** To turn off rate limiting set limit fod period to a non-positive number */
   public static final int NO_LIMIT_PERIOD = -1;

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

@@ -20,11 +20,7 @@
 import io.javaoperatorsdk.operator.api.config.ConfigurationServiceProvider;
 import io.javaoperatorsdk.operator.api.config.DefaultControllerConfiguration;
 import io.javaoperatorsdk.operator.api.config.Version;
-import io.javaoperatorsdk.operator.api.reconciler.Constants;
-import io.javaoperatorsdk.operator.api.reconciler.Context;
-import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
-import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
-import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
+import io.javaoperatorsdk.operator.api.reconciler.*;
 import io.javaoperatorsdk.operator.processing.event.rate.PeriodRateLimiter;
 import io.javaoperatorsdk.operator.sample.simple.TestCustomResource;
 
@@ -142,7 +138,8 @@ public MyConfiguration() {
     }
   }
 
-  @ControllerConfiguration(namespaces = NAMESPACE)
+  @ControllerConfiguration(namespaces = NAMESPACE,
+      rateLimiter = @RateLimiter(limitForPeriod = PeriodRateLimiter.DEFAULT_LIMIT_FOR_PERIOD))
   public static class MyController implements Reconciler<TestCustomResource> {
 
     private final Consumer<TestCustomResource> consumer;