From ec98de3ad42560c051eb06a5a9f6f2c9a12cd64c Mon Sep 17 00:00:00 2001 From: SimFG Date: Mon, 20 May 2024 10:35:38 +0800 Subject: [PATCH] fix: reset the quota value when init the limiter (#33111) issue: #33107 /kind improvement Signed-off-by: SimFG --- internal/proxy/simple_rate_limiter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/proxy/simple_rate_limiter.go b/internal/proxy/simple_rate_limiter.go index 120bf36036..b6652e6279 100644 --- a/internal/proxy/simple_rate_limiter.go +++ b/internal/proxy/simple_rate_limiter.go @@ -202,7 +202,7 @@ func initLimiter(rln *rlinternal.RateLimiterNode, rateLimiterConfigs map[interna for rt, p := range rateLimiterConfigs { limit := ratelimitutil.Limit(p.GetAsFloat()) burst := p.GetAsFloat() // use rate as burst, because SimpleLimiter is with punishment mechanism, burst is insignificant. - rln.GetLimiters().GetOrInsert(rt, ratelimitutil.NewLimiter(limit, burst)) + rln.GetLimiters().Insert(rt, ratelimitutil.NewLimiter(limit, burst)) log.RatedDebug(30, "RateLimiter register for rateType", zap.String("rateType", internalpb.RateType_name[(int32(rt))]), zap.String("rateLimit", ratelimitutil.Limit(p.GetAsFloat()).String()),