func applySecrets()

in fleet-argocd-plugin/fleetclient/fleetclient.go [269:290]


func applySecrets(ctx context.Context, clientset *kubernetes.Clientset, clusterSecrets map[string]string) error {
	secretsClient := clientset.CoreV1().Secrets("argocd")
	for _, manifest := range clusterSecrets {
		secret, err := secretFromManifest(manifest)
		if err != nil {
			return fmt.Errorf("error converting manifest %q to a k8s secret: %v", manifest, err)
		}
		_, err = secretsClient.Create(ctx, secret, metav1.CreateOptions{})
		if err != nil {
			// Check if "already exists", then update.
			if !errors.IsAlreadyExists(err) {
				return fmt.Errorf("error creating secret: %v", err)
			}
			_, err = secretsClient.Update(ctx, secret, metav1.UpdateOptions{})
			if err != nil {
				return fmt.Errorf("error updating secret: %v", err)
			}
		}
	}
	fmt.Println("Successfully applied Secrets.")
	return nil
}