Function Start

server/controller/controller/controller.go:63–221

(ctx context.Context, revision, configPath, serverLogFile string, shared *servercommon.ControllerIngesterShared)

type Controller struct{}

func Start(ctx context.Context, revision, configPath, serverLogFile string, shared *servercommon.ControllerIngesterShared) {
	common.InitEnvData()
	flag.Parse()

	serverCfg := config.DefaultConfig()
	serverCfg.Load(configPath)
	cfg := &serverCfg.ControllerConfig
	bytes, _ := yaml.Marshal(cfg)
	log.Info("==================== Launching DeepFlow-Server-Controller ====================")
	log.Infof("controller config:\n%s", string(bytes))
	setGlobalConfig(cfg)

	httpServer := http.NewServer(serverLogFile, cfg)
	httpServer.Start()

	defer router.SetInitStageForHealthChecker(router.OK)

	router.SetInitStageForHealthChecker("Election init")
	// start election
	if common.IsStandaloneRunningMode() == false {
		// in standalone mode, We have no way to elect because there is no k8s module
		go election.Start(ctx, cfg)
	}

	isMasterController := IsMasterController(cfg)
	if isMasterController {
		router.SetInitStageForHealthChecker(router.StageMetadbMigration)
		migrateMetadb(cfg)
	}

	router.SetInitStageForHealthChecker("Metadb init")
	// 初始化 Metadb
	if err := metadb.GetDBs().Init(cfg.MetadbCfg); err != nil {
		log.Errorf("init metadb failed: %s", err.Error())
		time.Sleep(time.Second)
		os.Exit(0)
	}

	if isMasterController && revision != "" {
		var masterSysConfig model.SysConfiguration
		err := metadb.DefaultDB.
			Where(model.SysConfiguration{ParamName: common.SYS_CONFIG_MASTER_COMMIT_ID}).
			Assign(model.SysConfiguration{Value: revision}).
			FirstOrCreate(&masterSysConfig).Error
		if err != nil {
			log.Warningf("upsert master sys config param (%s:%s) failed: %s", common.SYS_CONFIG_MASTER_COMMIT_ID, revision, err.Error())
		}
	} else if !IsMasterRegion(cfg) {
		var masterSysConfig model.SysConfiguration
		err := metadb.DefaultDB.Where(model.SysConfiguration{ParamName: common.SYS_CONFIG_MASTER_COMMIT_ID}).First(&masterSysConfig).Error
		if err != nil {
			log.Warningf("get master sys config param (%s) failed: %s", common.SYS_CONFIG_MASTER_COMMIT_ID, err.Error())
		} else {
			if revision != masterSysConfig.Value {
				log.Errorf("current commit id (%s) is different from master commit id (%s)", revision, masterSysConfig.Value)
				os.Exit(0)
			}
		}