sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-09-05 22:41:30 +02:00
Code Issues Packages Projects Releases Wiki Activity

make interval configurable

Browse Source
This commit is contained in:
Pascal Fischer
2025-05-20 18:13:29 +02:00
parent 118ca450a6
commit 694a54d196
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
management/server/grpcserver.go
View File

@@ -84,11 +84,16 @@ func NewServer(
}
}
syncRatePerS, err := strconv.Atoi(os.Getenv("NB_SYNC_RATE_PER_M"))
if syncRatePerS == 0 || err != nil {
syncRatePerS = 200
syncTokenPerInterval, err := strconv.Atoi(os.Getenv("NB_SYNC_RATE_PER_M"))
if syncTokenPerInterval == 0 || err != nil {
syncTokenPerInterval = 200
}
log.WithContext(ctx).Infof("sync rate limit set to %d/min", syncTokenPerInterval)
syncTokenInterval, err := time.ParseDuration(os.Getenv("NB_SYNC_RATE_INTERVAL"))
if syncTokenInterval == 0 || err != nil {
syncTokenInterval = time.Minute
}
log.WithContext(ctx).Infof("sync rate limit set to %d/min", syncRatePerS)
syncBurst, err := strconv.Atoi(os.Getenv("NB_SYNC_BURST"))
if syncBurst == 0 || err != nil {
@@ -107,7 +112,7 @@ func NewServer(
authManager: authManager,
appMetrics: appMetrics,
ephemeralManager: ephemeralManager,
syncRate: rate.Every(time.Minute / time.Duration(syncRatePerS)),
syncRate: rate.Every(syncTokenInterval / time.Duration(syncTokenPerInterval)),
syncBurst: syncBurst,
}, nil
}