Skip to content

Commit ce4d996

Browse files
committed
rate limiter turned off by default
1 parent 25ee8e1 commit ce4d996

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
@Target({ElementType.TYPE})
1313
public @interface RateLimiter {
1414

15-
int limitForPeriod() default PeriodRateLimiter.DEFAULT_LIMIT_FOR_PERIOD;
15+
int limitForPeriod() default PeriodRateLimiter.NO_LIMIT_PERIOD;
1616

1717
int refreshPeriod() default PeriodRateLimiter.DEFAULT_REFRESH_PERIOD_SECONDS;
1818

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,6 @@ public PeriodRateLimiter(Duration refreshPeriod, int limitForPeriod) {
3535
this.limitForPeriod = limitForPeriod;
3636
}
3737

38-
/**
39-
* @param resourceID id of the resource
40-
* @return empty if permission acquired or minimal duration until a permission could be acquired
41-
* again
42-
*/
4338
@Override
4439
public Optional<Duration> acquirePermission(ResourceID resourceID) {
4540
if (limitForPeriod <= 0) {

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,11 @@
77

88
public interface RateLimiter {
99

10+
/**
11+
* @param resourceID id of the resource
12+
* @return empty if permission acquired or minimal duration until a permission could be acquired
13+
* again
14+
*/
1015
Optional<Duration> acquirePermission(ResourceID resourceID);
1116

1217
void clear(ResourceID resourceID);

0 commit comments

Comments
 (0)