Skip to content

Commit f912a2e

Browse files
committed
fix: adapt default state and clean up
1 parent 02507ad commit f912a2e

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

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

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
import java.util.Optional;
66

77
import io.javaoperatorsdk.operator.api.config.AnnotationConfigurable;
8-
import io.javaoperatorsdk.operator.processing.event.ResourceID;
98

109
/**
1110
* A simple rate limiter that limits the number of permission for a time interval.
@@ -16,20 +15,18 @@ public class LinearRateLimiter
1615
/** To turn off rate limiting set limit for period to a non-positive number */
1716
public static final int NO_LIMIT_PERIOD = -1;
1817
public static final int DEFAULT_REFRESH_PERIOD_SECONDS = 10;
19-
public static final int DEFAULT_LIMIT_FOR_PERIOD = 3;
2018
public static final Duration DEFAULT_REFRESH_PERIOD =
2119
Duration.ofSeconds(DEFAULT_REFRESH_PERIOD_SECONDS);
2220

23-
2421
private Duration refreshPeriod;
25-
private int limitForPeriod = NO_LIMIT_PERIOD;
22+
private int limitForPeriod;
2623

2724
public static LinearRateLimiter deactivatedRateLimiter() {
2825
return new LinearRateLimiter();
2926
}
3027

3128
public LinearRateLimiter() {
32-
this(DEFAULT_REFRESH_PERIOD, DEFAULT_LIMIT_FOR_PERIOD);
29+
this(DEFAULT_REFRESH_PERIOD, NO_LIMIT_PERIOD);
3330
}
3431

3532
public LinearRateLimiter(Duration refreshPeriod, int limitForPeriod) {

0 commit comments

Comments
 (0)