func BroadcastDockerAuthConfig()

in ecrtokenrefresher/pkg/secrets/common/common.go [136:156]

21 lines of code
6 McCabe index (conditional complexity)


func BroadcastDockerAuthConfig(configJson []byte, defaultClientSet, remoteClientSet kubernetes.Interface, secretName, clusterName string) {
	namespaces, err := getNamespacesFromConfigMap(defaultClientSet, constants.NamespacePrefix+clusterName)
	if err != nil {
		utils.WarningLogger.Printf("failed to find config map for cluster %s\n", clusterName)
		return
	}
	for _, ns := range namespaces {
		secret, _ := k8s.GetSecret(remoteClientSet, secretName, ns)
		if secret == nil {
			_, err = k8s.CreateSecret(remoteClientSet, secretName, ns, map[string][]byte{corev1.DockerConfigJsonKey: configJson})
			if err != nil {
				utils.WarningLogger.Printf("failed to create %s in %s namespace\n", secretName, ns)
			}
		} else {
			_, err = k8s.UpdateSecret(remoteClientSet, ns, secret, map[string][]byte{corev1.DockerConfigJsonKey: configJson})
			if err != nil {
				utils.WarningLogger.Printf("failed to update %s in %s namespace\n", secretName, ns)
			}
		}
	}
}