Method Refresh

server/controller/recorder/cache/cache.go:238–327

所有缓存的刷新入口

()

// 所有缓存的刷新入口
func (c *Cache) Refresh() {
	defer c.ResetRefreshSignal(RefreshSignalCallerSelfHeal)
	c.triggerTagrecorderHealers()

	if !c.needSelfHealing() {
		log.Info("self-healing is disabled", c.metadata.LogPrefixes)
		return
	}

	log.Infof("cache self-healing started, sequence now: %d", c.Sequence, c.metadata.LogPrefixes)
	oldDiffBaseDataSet := c.DiffBaseDataSet
	oldToolDataSet := c.ToolDataSet

	c.DiffBaseDataSet = diffbase.NewDataSet(c.metadata)
	c.ToolDataSet = tool.NewDataSet(c.metadata)
	c.SetLogLevel(logging.DEBUG, RefreshSignalCallerSelfHeal)
	c.refreshFailed = false

	// 分类刷新资源的相关缓存

	// TODO refactor
	// sub domain需要使用vpc、vm的映射数据
	c.refreshRegions()
	c.refreshAZs()
	c.refreshVPCs()
	c.refreshHosts()
	c.randomSleep()
	c.refreshVMs()
	c.randomSleep()

	// 仅domain缓存需要刷新的资源
	if c.metadata.GetSubDomainLcuuid() == "" {
		c.refreshSubDomains()
		vrouterIDs := c.refreshVRouters()
		c.refreshRoutingTables(vrouterIDs)
		c.refreshDHCPPorts()
		c.refreshFloatingIPs()
		c.refreshNATGateways()
		c.refreshNATRules()
		c.refreshNATVMConnections()
		c.refreshLBs()
		c.refreshLBListeners()
		c.refreshLBTargetServers()
		c.refreshLBVMConnections()
		c.refreshPeeConnections()
		c.refreshCENs()
		c.refreshRDSInstances()
		c.refreshRedisInstances()
		c.refreshVIP()
	}

	c.refreshPodClusters()
	c.refreshPodNodes()
	c.refreshVMPodNodeConnections()
	c.refreshPodNamespaces()
	podIngressIDs := c.refreshPodIngresses()
	c.refreshPodIngressRules(podIngressIDs)
	c.refreshPodIngresseRuleBackends(podIngressIDs)