Method run

server/controller/cloud/cloud.go:397–429

()

}

func (c *Cloud) run() {
	log.Infof("cloud (%s) started", c.basicInfo.Name, logger.NewORGPrefix(c.orgID))

	if err := c.platform.CheckAuth(); err != nil {
		log.Errorf("cloud (%+v) check auth failed", c.basicInfo, logger.NewORGPrefix(c.orgID))
	}

	// execute immediately upon startup
	if c.dailyTrigger() {
		c.getCloudData()
	}

	cloudGatherInterval := c.getCloudGatherInterval()
	c.basicInfo.Interval = cloudGatherInterval
	ticker := time.NewTicker(time.Second * time.Duration(cloudGatherInterval))
	defer ticker.Stop()

	for {
		select {
		case <-ticker.C:
			if c.synchronizing {
				continue
			}
			if !c.dailyTrigger() {
				continue
			}
			c.getCloudData()
		case <-c.cCtx.Done():
			log.Infof("cloud (%s) stopped", c.basicInfo.Name, logger.NewORGPrefix(c.orgID))
			return
		}
	}
}

func (c *Cloud) startKubernetesGatherTask() {
	log.Infof("cloud (%s) kubernetes gather task started", c.basicInfo.Name, logger.NewORGPrefix(c.orgID))