This is an automated email from the ASF dual-hosted git repository.
xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 457a0ed change to Duration.ofMiles to avoid calculate manually (#2925)
457a0ed is described below
commit 457a0ed29d142a817f7023ad9b02733ec5aa3f46
Author: Han Gao <[email protected]>
AuthorDate: Wed Feb 23 10:53:55 2022 +0800
change to Duration.ofMiles to avoid calculate manually (#2925)
---
.../shenyu/plugin/resilience4j/build/Resilience4JBuilder.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
b/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
index 61b1ece..6a97b9f 100644
---
a/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
+++
b/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
@@ -56,15 +56,15 @@ public final class Resilience4JBuilder {
handle.getSlidingWindowType() == 0
?
CircuitBreakerConfig.SlidingWindowType.COUNT_BASED
:
CircuitBreakerConfig.SlidingWindowType.TIME_BASED).waitIntervalFunctionInOpenState(IntervalFunction
-
.of(Duration.ofSeconds(handle.getWaitIntervalFunctionInOpenState() / 1000)))
+
.of(Duration.ofMillis(handle.getWaitIntervalFunctionInOpenState())))
.permittedNumberOfCallsInHalfOpenState(handle.getPermittedNumberOfCallsInHalfOpenState()).build();
}
TimeLimiterConfig timeLimiterConfig = TimeLimiterConfig.custom()
-
.timeoutDuration(Duration.ofSeconds(handle.getTimeoutDuration() /
1000)).build();
+
.timeoutDuration(Duration.ofMillis(handle.getTimeoutDuration())).build();
RateLimiterConfig rateLimiterConfig = RateLimiterConfig.custom()
.limitForPeriod(handle.getLimitForPeriod())
-
.timeoutDuration(Duration.ofSeconds(handle.getTimeoutDurationRate() / 1000))
-
.limitRefreshPeriod(Duration.ofNanos(handle.getLimitRefreshPeriod() *
1000000L)).build();
+
.timeoutDuration(Duration.ofMillis(handle.getTimeoutDurationRate()))
+
.limitRefreshPeriod(Duration.ofMillis(handle.getLimitRefreshPeriod())).build();
return new Resilience4JConf(CacheKeyUtils.INST.getKey(ruleData),
handle.getFallbackUri(), rateLimiterConfig, timeLimiterConfig,
circuitBreakerConfig);
}
}