Reducing resync time to 15 mins (#789)

This commit is contained in:
Vamsi Kalapala 2021-02-24 12:45:51 -08:00 коммит произвёл GitHub
Родитель effc4294d3
Коммит c4f007e709
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
1 изменённых файлов: 15 добавлений и 3 удалений

Просмотреть файл

@ -3,6 +3,7 @@
package main
import (
"math/rand"
"time"
"github.com/Azure/azure-container-networking/log"
@ -14,7 +15,10 @@ import (
"k8s.io/client-go/rest"
)
const waitForTelemetryInSeconds = 60
const (
waitForTelemetryInSeconds = 60
resyncPeriodInMinutes = 15
)
// Version is populated by make during build.
var version string
@ -58,7 +62,15 @@ func main() {
panic(err.Error())
}
factory := informers.NewSharedInformerFactory(clientset, time.Hour*24)
// Setting reSyncPeriod to 15 mins
minResyncPeriod := resyncPeriodInMinutes * time.Minute
// Adding some randomness so all NPM pods will not request for info at once.
factor := rand.Float64() + 1
resyncPeriod := time.Duration(float64(minResyncPeriod.Nanoseconds()) * factor)
log.Logf("[INFO] Resync period for NPM pod is set to %d.", int(resyncPeriod/time.Minute))
factory := informers.NewSharedInformerFactory(clientset, resyncPeriod)
npMgr := npm.NewNetworkPolicyManager(clientset, factory, version)
metrics.CreateTelemetryHandle(npMgr.GetAppVersion(), npm.GetAIMetadata())
@ -73,4 +85,4 @@ func main() {
metrics.StartHTTP(0)
select {}
}
}