util

Documentation

Index

• Variables
• func AddAppFlags(command *cobra.Command, opts *AppOptions)
• func AddClusterFlags(command *cobra.Command, opts *ClusterOptions)
• func AddProjFlags(command *cobra.Command, opts *ProjectOpts)
• func AddRepoFlags(command *cobra.Command, opts *RepoOptions)
• func ConstructAppProj(fileURL string, args []string, opts ProjectOpts, c *cobra.Command) (*v1alpha1.AppProject, error)
• func ConstructApplicationSet(fileURL string) ([]*argoprojiov1alpha1.ApplicationSet, error)
• func ConstructApps(fileURL, appName string, labels, annotations, args []string, ...) ([]*argoappv1.Application, error)
• func ConstructSource(source *argoappv1.ApplicationSource, appOpts AppOptions, flags *pflag.FlagSet) (*argoappv1.ApplicationSource, int)
• func FilterResources(groupChanged bool, resources []*argoappv1.ResourceDiff, ...) ([]*unstructured.Unstructured, error)
• func GetKubePublicEndpoint(client kubernetes.Interface) (string, error)
• func GetOrphanedResourcesSettings(flagSet *pflag.FlagSet, opts ProjectOpts) *v1alpha1.OrphanedResourcesMonitorSettings
• func LiveObjects(resources []*argoappv1.ResourceDiff) ([]*unstructured.Unstructured, error)
• func NewCluster(name string, namespaces []string, clusterResources bool, conf *rest.Config, ...) *argoappv1.Cluster
• func PrintKubeContexts(ca clientcmd.ConfigAccess)
• func SetAppSpecOptions(flags *pflag.FlagSet, spec *argoappv1.ApplicationSpec, appOpts *AppOptions, ...) int
• func SetParameterOverrides(app *argoappv1.Application, parameters []string, index int)
• func SetProjSpecOptions(flags *pflag.FlagSet, spec *v1alpha1.AppProjectSpec, projOpts *ProjectOpts) int
• type AppOptions
• type ClusterEndpoint
• type ClusterOptions
  • func (o ClusterOptions) InClusterEndpoint() bool
• type ProjectOpts
  • func (opts *ProjectOpts) GetAllowedClusterResources() []v1.GroupKind
  • func (opts *ProjectOpts) GetAllowedNamespacedResources() []v1.GroupKind
  • func (opts *ProjectOpts) GetDeniedClusterResources() []v1.GroupKind
  • func (opts *ProjectOpts) GetDeniedNamespacedResources() []v1.GroupKind
  • func (opts *ProjectOpts) GetDestinations() []v1alpha1.ApplicationDestination
  • func (opts *ProjectOpts) GetSignatureKeys() []v1alpha1.SignatureKey
  • func (opts *ProjectOpts) GetSourceNamespaces() []string
• type RepoOptions

Variables

var (
	LogFormat string
	LogLevel  string
)

Functions

func AddAppFlags

func AddAppFlags(command *cobra.Command, opts *AppOptions)

func AddClusterFlags

func AddClusterFlags(command *cobra.Command, opts *ClusterOptions)

func AddProjFlags

func AddProjFlags(command *cobra.Command, opts *ProjectOpts)

func AddRepoFlags

func AddRepoFlags(command *cobra.Command, opts *RepoOptions)

func ConstructAppProj

func ConstructAppProj(fileURL string, args []string, opts ProjectOpts, c *cobra.Command) (*v1alpha1.AppProject, error)

func ConstructApplicationSet

func ConstructApplicationSet(fileURL string) ([]*argoprojiov1alpha1.ApplicationSet, error)

func ConstructApps

func ConstructApps(fileURL, appName string, labels, annotations, args []string, appOpts AppOptions, flags *pflag.FlagSet) ([]*argoappv1.Application, error)

func ConstructSource

func ConstructSource(source *argoappv1.ApplicationSource, appOpts AppOptions, flags *pflag.FlagSet) (*argoappv1.ApplicationSource, int)

func FilterResources

func FilterResources(groupChanged bool, resources []*argoappv1.ResourceDiff, group, kind, namespace, resourceName string, all bool) ([]*unstructured.Unstructured, error)

func GetKubePublicEndpoint

func GetKubePublicEndpoint(client kubernetes.Interface) (string, error)

GetKubePublicEndpoint returns the kubernetes apiserver endpoint as published in the kube-public.

func GetOrphanedResourcesSettings

func GetOrphanedResourcesSettings(flagSet *pflag.FlagSet, opts ProjectOpts) *v1alpha1.OrphanedResourcesMonitorSettings

func LiveObjects

func LiveObjects(resources []*argoappv1.ResourceDiff) ([]*unstructured.Unstructured, error)

LiveObjects deserializes the list of live states into unstructured objects

func NewCluster

func NewCluster(name string, namespaces []string, clusterResources bool, conf *rest.Config, managerBearerToken string, awsAuthConf *argoappv1.AWSAuthConfig, execProviderConf *argoappv1.ExecProviderConfig, labels, annotations map[string]string) *argoappv1.Cluster

func PrintKubeContexts

func PrintKubeContexts(ca clientcmd.ConfigAccess)

func SetAppSpecOptions

func SetAppSpecOptions(flags *pflag.FlagSet, spec *argoappv1.ApplicationSpec, appOpts *AppOptions, sourcePosition int) int

func SetParameterOverrides

func SetParameterOverrides(app *argoappv1.Application, parameters []string, index int)

SetParameterOverrides updates an existing or appends a new parameter override in the application The app is assumed to be a helm app and is expected to be in the form: param=value

func SetProjSpecOptions

func SetProjSpecOptions(flags *pflag.FlagSet, spec *v1alpha1.AppProjectSpec, projOpts *ProjectOpts) int

Types

type AppOptions

type AppOptions struct {
	Parameters []string

	Validate bool
	// contains filtered or unexported fields
}

type ClusterEndpoint

type ClusterEndpoint string

const (
	KubeConfigEndpoint   ClusterEndpoint = "kubeconfig"
	KubePublicEndpoint   ClusterEndpoint = "kube-public"
	KubeInternalEndpoint ClusterEndpoint = "internal"
)

type ClusterOptions

type ClusterOptions struct {
	InCluster               bool
	Upsert                  bool
	ServiceAccount          string
	AwsRoleArn              string
	AwsProfile              string
	AwsClusterName          string
	SystemNamespace         string
	Namespaces              []string
	ClusterResources        bool
	Name                    string
	Project                 string
	Shard                   int64
	ExecProviderCommand     string
	ExecProviderArgs        []string
	ExecProviderEnv         map[string]string
	ExecProviderAPIVersion  string
	ExecProviderInstallHint string
	ClusterEndpoint         string
}

func (ClusterOptions) InClusterEndpoint

func (o ClusterOptions) InClusterEndpoint() bool

InClusterEndpoint returns true if ArgoCD should reference the in-cluster endpoint when registering the target cluster.

type ProjectOpts

type ProjectOpts struct {
	Description string

	Sources          []string
	SignatureKeys    []string
	SourceNamespaces []string
	// contains filtered or unexported fields
}

func (*ProjectOpts) GetAllowedClusterResources

func (opts *ProjectOpts) GetAllowedClusterResources() []v1.GroupKind

func (*ProjectOpts) GetAllowedNamespacedResources

func (opts *ProjectOpts) GetAllowedNamespacedResources() []v1.GroupKind

func (*ProjectOpts) GetDeniedClusterResources

func (opts *ProjectOpts) GetDeniedClusterResources() []v1.GroupKind

func (*ProjectOpts) GetDeniedNamespacedResources

func (opts *ProjectOpts) GetDeniedNamespacedResources() []v1.GroupKind

func (*ProjectOpts) GetDestinations

func (opts *ProjectOpts) GetDestinations() []v1alpha1.ApplicationDestination

func (*ProjectOpts) GetSignatureKeys

func (opts *ProjectOpts) GetSignatureKeys() []v1alpha1.SignatureKey

GetSignatureKeys TODO: Get configured keys and emit warning when a key is specified that is not configured

func (*ProjectOpts) GetSourceNamespaces

func (opts *ProjectOpts) GetSourceNamespaces() []string

type RepoOptions

type RepoOptions struct {
	Repo                           appsv1.Repository
	Upsert                         bool
	SshPrivateKeyPath              string
	InsecureIgnoreHostKey          bool
	InsecureSkipServerVerification bool
	TlsClientCertPath              string
	TlsClientCertKeyPath           string
	EnableLfs                      bool
	EnableOci                      bool
	GithubAppId                    int64
	GithubAppInstallationId        int64
	GithubAppPrivateKeyPath        string
	GitHubAppEnterpriseBaseURL     string
	Proxy                          string
	GCPServiceAccountKeyPath       string
	ForceHttpBasicAuth             bool
}