Function Initialize

center/center.go:44–168

(configDir string, cryptoKey string)

)

func Initialize(configDir string, cryptoKey string) (func(), error) {
	config, err := conf.InitConfig(configDir, cryptoKey)
	if err != nil {
		return nil, fmt.Errorf("failed to init config: %v", err)
	}

	cconf.LoadMetricsYaml(configDir, config.Center.MetricsYamlFile)
	cconf.LoadOpsYaml(configDir, config.Center.OpsYamlFile)

	cconf.MergeOperationConf()

	if config.Alert.Heartbeat.EngineName == "" {
		config.Alert.Heartbeat.EngineName = "default"
	}

	logxClean, err := logx.Init(config.Log)
	if err != nil {
		return nil, err
	}

	i18nx.Init(configDir)
	flashduty.Init(config.Center.FlashDuty)

	db, err := storage.New(config.DB)
	if err != nil {
		return nil, err
	}
	ctx := ctx.NewContext(context.Background(), db, true)
	migrate.Migrate(db)
	isRootInit := models.InitRoot(ctx)

	config.HTTP.JWTAuth.SigningKey = models.InitJWTSigningKey(ctx)

	err = rsa.InitRSAConfig(ctx, &config.HTTP.RSA)
	if err != nil {
		return nil, err
	}

	go integration.Init(ctx, config.Center.BuiltinIntegrationsDir)
	var redis storage.Redis
	redis, err = storage.NewRedis(config.Redis)
	if err != nil {
		return nil, err
	}

	metas := metas.New(redis)
	idents := idents.New(ctx, redis, config.Pushgw)

	syncStats := memsto.NewSyncStats()
	alertStats := astats.NewSyncStats()

	if config.Center.MigrateBusiGroupLabel || models.CanMigrateBg(ctx) {
		models.MigrateBg(ctx, config.Pushgw.BusiGroupLabelKey)
	}
	if models.CanMigrateEP(ctx) {
		models.MigrateEP(ctx)
	}