mirror of
https://github.com/netbirdio/netbird.git
synced 2026-10-09 06:59:08 +02:00
allow defining rating dimension
This commit is contained in:
@@ -84,6 +84,12 @@ func NewServer(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
multiplier := time.Second
|
||||||
|
d, e := time.ParseDuration(os.Getenv("NB_LOGIN_RATE"))
|
||||||
|
if e == nil {
|
||||||
|
multiplier = d
|
||||||
|
}
|
||||||
|
|
||||||
loginRatePerS, err := strconv.Atoi(os.Getenv("NB_LOGIN_RATE_PER_M"))
|
loginRatePerS, err := strconv.Atoi(os.Getenv("NB_LOGIN_RATE_PER_M"))
|
||||||
if loginRatePerS == 0 || err != nil {
|
if loginRatePerS == 0 || err != nil {
|
||||||
loginRatePerS = 200
|
loginRatePerS = 200
|
||||||
@@ -112,7 +118,7 @@ func NewServer(
|
|||||||
appMetrics: appMetrics,
|
appMetrics: appMetrics,
|
||||||
ephemeralManager: ephemeralManager,
|
ephemeralManager: ephemeralManager,
|
||||||
syncLimiter: rate.NewLimiter(rate.Every(time.Minute/time.Duration(syncRatePerS)), 1),
|
syncLimiter: rate.NewLimiter(rate.Every(time.Minute/time.Duration(syncRatePerS)), 1),
|
||||||
loginLimiter: rate.NewLimiter(rate.Every(time.Minute/time.Duration(loginRatePerS)), 1),
|
loginLimiter: rate.NewLimiter(rate.Every(multiplier/time.Duration(loginRatePerS)), 1),
|
||||||
loginPeerLimit: rate.Every(time.Minute / time.Duration(loginPeerRatePerS)),
|
loginPeerLimit: rate.Every(time.Minute / time.Duration(loginPeerRatePerS)),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user