util

package
v3.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 24, 2025 License: Apache-2.0 Imports: 32 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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, []byte, error)

GetKubePublicEndpoint returns the kubernetes apiserver endpoint and certificate authority data 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

func ValidateBearerTokenAndPasswordCombo 

func ValidateBearerTokenAndPasswordCombo(bearerToken string, password string) error

func ValidateBearerTokenForGitOnly 

func ValidateBearerTokenForGitOnly(bearerToken string, repoType string) error

func ValidateBearerTokenForHTTPSRepoOnly 

func ValidateBearerTokenForHTTPSRepoOnly(bearerToken string, isHTTPS bool) error

Types

type AppOptions 

type AppOptions struct {
	Parameters []string

	Validate bool

	SourceName string
	// 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
	DisableCompression      bool
	ProxyUrl                string //nolint:revive //FIXME(var-naming)
}

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() []metav1.GroupKind

func (*ProjectOpts) GetAllowedNamespacedResources 

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

func (*ProjectOpts) GetDeniedClusterResources 

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

func (*ProjectOpts) GetDeniedNamespacedResources 

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

func (*ProjectOpts) GetDestinationServiceAccounts 

func (opts *ProjectOpts) GetDestinationServiceAccounts() []v1alpha1.ApplicationDestinationServiceAccount

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 //nolint:revive //FIXME(var-naming)
	InsecureOCIForceHTTP           bool
	InsecureIgnoreHostKey          bool
	InsecureSkipServerVerification bool
	TlsClientCertPath              string //nolint:revive //FIXME(var-naming)
	TlsClientCertKeyPath           string //nolint:revive //FIXME(var-naming)
	EnableLfs                      bool
	EnableOci                      bool
	GithubAppId                    int64
	GithubAppInstallationId        int64
	GithubAppPrivateKeyPath        string
	GitHubAppEnterpriseBaseURL     string
	Proxy                          string
	NoProxy                        string
	GCPServiceAccountKeyPath       string
	ForceHttpBasicAuth             bool //nolint:revive //FIXME(var-naming)
	UseAzureWorkloadIdentity       bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.