mirror of
https://github.com/argoproj/argo-cd
synced 2026-04-21 17:07:16 +00:00
ec3b3dc83b
* Add application CRD definition. Implement CRD install CLI command * Remove unnecessary argo package dependency
110 lines
3.6 KiB
Go
110 lines
3.6 KiB
Go
package commands
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/argoproj/argo-cd/pkg/apis/application"
|
|
appv1 "github.com/argoproj/argo-cd/pkg/apis/application/v1alpha1"
|
|
"github.com/argoproj/argo/pkg/apis/workflow"
|
|
"github.com/ghodss/yaml"
|
|
log "github.com/sirupsen/logrus"
|
|
"github.com/spf13/cobra"
|
|
apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
|
|
apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
|
|
apierr "k8s.io/apimachinery/pkg/api/errors"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/util/wait"
|
|
"k8s.io/client-go/kubernetes"
|
|
)
|
|
|
|
// InstallFlags has all the required parameters for installing Argo CD.
|
|
type InstallFlags struct {
|
|
DryRun bool // --dry-run
|
|
}
|
|
|
|
// NewInstallCommand returns a new instance of `argocd install` command
|
|
func NewInstallCommand(globalArgs *globalFlags) *cobra.Command {
|
|
var (
|
|
installArgs InstallFlags
|
|
)
|
|
var command = &cobra.Command{
|
|
Use: "install",
|
|
Short: "Install the argocd components",
|
|
Long: "Install the argocd components",
|
|
Run: func(c *cobra.Command, args []string) {
|
|
client := getKubeClient(globalArgs.kubeConfigPath, globalArgs.kubeConfigOverrides)
|
|
extensionsClient := apiextensionsclient.NewForConfigOrDie(getKubeConfig(globalArgs.kubeConfigPath, globalArgs.kubeConfigOverrides))
|
|
installCRD(client, extensionsClient, installArgs)
|
|
},
|
|
}
|
|
command.Flags().BoolVar(&installArgs.DryRun, "dry-run", false, "print the kubernetes manifests to stdout instead of installing")
|
|
|
|
return command
|
|
}
|
|
|
|
func installCRD(clientset *kubernetes.Clientset, extensionsClient *apiextensionsclient.Clientset, args InstallFlags) {
|
|
applicationCRD := apiextensionsv1beta1.CustomResourceDefinition{
|
|
TypeMeta: metav1.TypeMeta{
|
|
APIVersion: "apiextensions.k8s.io/v1alpha1",
|
|
Kind: "CustomResourceDefinition",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: application.FullName,
|
|
},
|
|
Spec: apiextensionsv1beta1.CustomResourceDefinitionSpec{
|
|
Group: application.Group,
|
|
Version: appv1.SchemeGroupVersion.Version,
|
|
Scope: apiextensionsv1beta1.NamespaceScoped,
|
|
Names: apiextensionsv1beta1.CustomResourceDefinitionNames{
|
|
Plural: application.Plural,
|
|
Kind: application.Kind,
|
|
ShortNames: []string{application.ShortName},
|
|
},
|
|
},
|
|
}
|
|
if args.DryRun {
|
|
printYAML(applicationCRD)
|
|
return
|
|
}
|
|
|
|
_, err := extensionsClient.ApiextensionsV1beta1().CustomResourceDefinitions().Create(&applicationCRD)
|
|
if err != nil {
|
|
if !apierr.IsAlreadyExists(err) {
|
|
log.Fatalf("Failed to create CustomResourceDefinition: %v", err)
|
|
}
|
|
fmt.Printf("CustomResourceDefinition '%s' already exists\n", workflow.FullName)
|
|
}
|
|
// wait for CRD being established
|
|
var crd *apiextensionsv1beta1.CustomResourceDefinition
|
|
err = wait.Poll(500*time.Millisecond, 60*time.Second, func() (bool, error) {
|
|
crd, err = extensionsClient.ApiextensionsV1beta1().CustomResourceDefinitions().Get(workflow.FullName, metav1.GetOptions{})
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
for _, cond := range crd.Status.Conditions {
|
|
switch cond.Type {
|
|
case apiextensionsv1beta1.Established:
|
|
if cond.Status == apiextensionsv1beta1.ConditionTrue {
|
|
return true, err
|
|
}
|
|
case apiextensionsv1beta1.NamesAccepted:
|
|
if cond.Status == apiextensionsv1beta1.ConditionFalse {
|
|
log.Errorf("Name conflict: %v", cond.Reason)
|
|
}
|
|
}
|
|
}
|
|
return false, err
|
|
})
|
|
if err != nil {
|
|
log.Fatalf("Failed to wait for CustomResourceDefinition: %v", err)
|
|
}
|
|
}
|
|
|
|
func printYAML(obj interface{}) {
|
|
objBytes, err := yaml.Marshal(obj)
|
|
if err != nil {
|
|
log.Fatalf("Failed to marshal %v", obj)
|
|
}
|
|
fmt.Printf("---\n%s\n", string(objBytes))
|
|
}
|