INNER CODE UNIT · Go

UpdateASyncAdmiralConfig

istio-ecosystem/admiral · admiral/pkg/clusters/admiralDatabaseClient.go:186

func UpdateASyncAdmiralConfig(ctxDynamicConfig context.Context, rr *RemoteRegistry, syncTime int) {
	//pull once on startup
	ReadAndUpdateSyncAdmiralConfig(rr)
	ticker := time.NewTicker(time.Minute * time.Duration(syncTime))
	defer ticker.Stop()

	for {
		select {
		case <-ctxDynamicConfig.Done():
			log.Infof("task=%v, context done stopping ticker", common.DynamicConfigUpdate)
			return
		case <-ticker.C:
			ReadAndUpdateSyncAdmiralConfig(rr)
		}
	}
}

func ReadAndUpdateSyncAdmiralConfig(rr *RemoteRegistry) error {

View source record →