func()

in ecrtokenrefresher/pkg/secrets/registrymirror/registrymirror.go [51:77]

• 27 lines of code
• 4 McCabe index (conditional complexity)

func (mirror *RegistryMirrorSecret) GetClusterCredentials(clientSets secrets.ClusterClientSet) (secrets.ClusterCredential, error) {
	clusterCredentials := make(secrets.ClusterCredential)
	defaultClientSet := mirror.clientSets[mirror.mgmtClusterName]
	for clusterName := range clientSets {
		utils.InfoLogger.Printf("fetching registry mirror auth data for cluster %s...\n", clusterName)
		namespace := constants.PackagesNamespace
		if clusterName != mirror.mgmtClusterName {
			namespace = constants.NamespacePrefix + clusterName
		}
		secret, err := k8s.GetSecret(defaultClientSet, secretName, namespace)
		if err == nil {
			credential := &secrets.Credential{
				Registry: string(secret.Data[endpointKey]),
				Username: string(secret.Data[usernameKey]),
				Password: string(secret.Data[passwordKey]),
				CA:       string(secret.Data[caKey]),
				Insecure: string(secret.Data[insecureKey]),
			}
			clusterCredentials[clusterName] = []*secrets.Credential{credential}
			utils.InfoLogger.Println("success.")
		} else {
			utils.ErrorLogger.Println(err)
			return nil, err
		}
	}
	return clusterCredentials, nil
}