From 6b86350b9deb9bfcf396f36265e88d02c55a4ced Mon Sep 17 00:00:00 2001 From: Pascal Fischer Date: Thu, 8 May 2025 14:57:21 +0200 Subject: [PATCH] configurable burst --- management/server/grpcserver.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/management/server/grpcserver.go b/management/server/grpcserver.go index 0df1f4aea..d426f6f2f 100644 --- a/management/server/grpcserver.go +++ b/management/server/grpcserver.go @@ -131,7 +131,7 @@ func NewServer( authManager: authManager, appMetrics: appMetrics, ephemeralManager: ephemeralManager, - syncLimiter: rate.NewLimiter(rate.Every(time.Minute/time.Duration(syncRatePerS)), 100), + syncLimiter: rate.NewLimiter(rate.Every(time.Minute/time.Duration(syncRatePerS)), syncBurst), loginLimiter: rate.NewLimiter(rate.Every(multiplier/time.Duration(loginRatePerS)), loginBurst), loginPeerLimit: rate.Every(time.Minute / time.Duration(loginPeerRatePerS)), }, nil @@ -479,7 +479,7 @@ func (s *GRPCServer) Login(ctx context.Context, req *proto.EncryptedMessage) (*p } // Create new limiter for this peer - newLimiter := rate.NewLimiter(s.loginPeerLimit, 100) + newLimiter := rate.NewLimiter(s.loginPeerLimit, 1000) s.loginLimiterStore.Store(req.WgPubKey, newLimiter) if !newLimiter.Allow() {