Function Init

pkg/config/config.go:79–178

()

}

func Init() error {
	var err error

	clusterConfigPath := os.Getenv("CORTEX_CLUSTER_CONFIG_PATH")
	if clusterConfigPath == "" {
		clusterConfigPath = consts.DefaultInClusterConfigPath
	}

	clusterConfig, err := clusterconfig.NewForFile(clusterConfigPath)
	if err != nil {
		return err
	}

	ClusterConfig = clusterConfig

	AWS, err = aws.NewForRegion(clusterConfig.Region)
	if err != nil {
		return err
	}

	accountID, hashedAccountID, err := AWS.CheckCredentials()
	if err != nil {
		return err
	}

	clusterConfig.AccountID = accountID

	OperatorMetadata = &clusterconfig.OperatorMetadata{
		APIVersion:          consts.CortexVersion,
		OperatorID:          hashedAccountID,
		ClusterID:           hash.String(clusterConfig.ClusterName + clusterConfig.Region + hashedAccountID),
		IsOperatorInCluster: strings.ToLower(os.Getenv("CORTEX_OPERATOR_IN_CLUSTER")) != "false",
	}

	if K8s, err = k8s.New(consts.DefaultNamespace, OperatorMetadata.IsOperatorInCluster, nil, scheme); err != nil {
		return err
	}

	if K8sIstio, err = k8s.New(consts.IstioNamespace, OperatorMetadata.IsOperatorInCluster, nil, scheme); err != nil {
		return err
	}

	if !OperatorMetadata.IsOperatorInCluster {
		cc, err := getClusterConfigFromConfigMap()
		if err != nil {
			return err
		}
		clusterConfig.Bucket = cc.Bucket
		clusterConfig.ClusterUID = cc.ClusterUID
	}

	exists, err := AWS.DoesBucketExist(clusterConfig.Bucket)
	if err != nil {
		return err
	}
	if !exists {
		return errors.ErrorUnexpected("the specified bucket does not exist", clusterConfig.Bucket)
	}