Function SaveSecret

cloud/pkg/common/client/secret.go:34–49

saveSecret creates a secret when it does not exist, otherwise updates it.

(ctx context.Context, secret *corev1.Secret, ns string)

// saveSecret creates a secret when it does not exist, otherwise updates it.
func SaveSecret(ctx context.Context, secret *corev1.Secret, ns string) error {
	cli := GetKubeClient()
	if err := CreateNamespaceIfNeeded(ctx, ns); err != nil {
		return fmt.Errorf("failed to create Namespace kubeedge, error: %v", err)
	}
	if _, err := cli.CoreV1().Secrets(ns).Create(ctx, secret, metav1.CreateOptions{}); err != nil {
		if errors.IsAlreadyExists(err) {
			if _, err := cli.CoreV1().Secrets(ns).Update(ctx, secret, metav1.UpdateOptions{}); err != nil {
				return fmt.Errorf("failed to update the secret, namespace: %s, name: %s, err: %v", ns, secret.Name, err)
			}
		} else {
			return fmt.Errorf("failed to create the secret, namespace: %s, name: %s, err: %v", ns, secret.Name, err)
		}
	}
	return nil
}