utils

Documentation

Index

• Constants
• Variables
• func CheckInvalidGenerators(applicationSetInfo *argoappsv1.ApplicationSet) error
• func CombineStringMaps(aSI map[string]interface{}, bSI map[string]interface{}) (map[string]string, error)
• func CombineStringMapsAllowDuplicates(aSI map[string]interface{}, bSI map[string]interface{}) (map[string]string, error)
• func ConvertToMapStringInterface(mapStringString map[string]string) map[string]interface{}
• func ConvertToMapStringString(mapStringInterface map[string]interface{}) map[string]string
• func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, ...) (controllerutil.OperationResult, error)
• func ListClusters(ctx context.Context, clientset kubernetes.Interface, namespace string) (*appv1.ClusterList, error)
• func NormalizeBitbucketBasePath(basePath string) string
• func SanitizeName(name string) string
• func ValidateDestination(ctx context.Context, dest *appv1.ApplicationDestination, ...) error
• type CreateDeletePolicy
  • func (p *CreateDeletePolicy) Delete() bool
  • func (p *CreateDeletePolicy) Update() bool
• type CreateOnlyPolicy
  • func (p *CreateOnlyPolicy) Delete() bool
  • func (p *CreateOnlyPolicy) Update() bool
• type CreateUpdatePolicy
  • func (p *CreateUpdatePolicy) Delete() bool
  • func (p *CreateUpdatePolicy) Update() bool
• type Policy
• type Render
  • func (r *Render) RenderTemplateParams(tmpl *argoappsv1.Application, syncPolicy *argoappsv1.ApplicationSetSyncPolicy, ...) (*argoappsv1.Application, error)
  • func (r *Render) Replace(tmpl string, replaceMap map[string]interface{}, useGoTemplate bool) (string, error)
• type Renderer
• type SyncPolicy
  • func (p *SyncPolicy) Delete() bool
  • func (p *SyncPolicy) Update() bool

Constants

const (
	ArgoCDSecretTypeLabel   = "argocd.argoproj.io/secret-type"
	ArgoCDSecretTypeCluster = "cluster"
)

Variables

var Policies = map[string]Policy{
	"sync":          &SyncPolicy{},
	"create-only":   &CreateOnlyPolicy{},
	"create-update": &CreateUpdatePolicy{},
	"create-delete": &CreateDeletePolicy{},
}

Policies is a registry of available policies.

Functions

func CheckInvalidGenerators

func CheckInvalidGenerators(applicationSetInfo *argoappsv1.ApplicationSet) error

Log a warning if there are unrecognized generators

func CombineStringMaps

func CombineStringMaps(aSI map[string]interface{}, bSI map[string]interface{}) (map[string]string, error)

func CombineStringMapsAllowDuplicates

func CombineStringMapsAllowDuplicates(aSI map[string]interface{}, bSI map[string]interface{}) (map[string]string, error)

CombineStringMapsAllowDuplicates merges two maps. Where there are duplicates, take the latter map's value.

func ConvertToMapStringInterface

func ConvertToMapStringInterface(mapStringString map[string]string) map[string]interface{}

func ConvertToMapStringString

func ConvertToMapStringString(mapStringInterface map[string]interface{}) map[string]string

func CreateOrUpdate

func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, f controllerutil.MutateFn) (controllerutil.OperationResult, error)

CreateOrUpdate overrides "sigs.k8s.io/controller-runtime" function in sigs.k8s.io/controller-runtime/pkg/controller/controllerutil/controllerutil.go to add equality for argov1alpha1.ApplicationDestination argov1alpha1.ApplicationDestination has a private variable, so the default implementation fails to compare it.

CreateOrUpdate creates or updates the given object in the Kubernetes cluster. The object's desired state must be reconciled with the existing state inside the passed in callback MutateFn.

The MutateFn is called regardless of creating or updating an object.

It returns the executed operation and an error.

func ListClusters

func ListClusters(ctx context.Context, clientset kubernetes.Interface, namespace string) (*appv1.ClusterList, error)

func NormalizeBitbucketBasePath

func NormalizeBitbucketBasePath(basePath string) string

func SanitizeName

func SanitizeName(name string) string

SanitizeName sanitizes the name in accordance with the below rules 1. contain no more than 253 characters 2. contain only lowercase alphanumeric characters, '-' or '.' 3. start and end with an alphanumeric character

func ValidateDestination

func ValidateDestination(ctx context.Context, dest *appv1.ApplicationDestination, clientset kubernetes.Interface, namespace string) error

ValidateDestination checks: if we used destination name we infer the server url if we used both name and server then we return an invalid spec error

Types

type CreateDeletePolicy

type CreateDeletePolicy struct{}

func (*CreateDeletePolicy) Delete

func (p *CreateDeletePolicy) Delete() bool

func (*CreateDeletePolicy) Update

func (p *CreateDeletePolicy) Update() bool

type CreateOnlyPolicy

type CreateOnlyPolicy struct{}

func (*CreateOnlyPolicy) Delete

func (p *CreateOnlyPolicy) Delete() bool

func (*CreateOnlyPolicy) Update

func (p *CreateOnlyPolicy) Update() bool

type CreateUpdatePolicy

type CreateUpdatePolicy struct{}

func (*CreateUpdatePolicy) Delete

func (p *CreateUpdatePolicy) Delete() bool

func (*CreateUpdatePolicy) Update

func (p *CreateUpdatePolicy) Update() bool

type Policy

type Policy interface {
	Update() bool
	Delete() bool
}

Policy allows to apply different rules to a set of changes.

type Render

type Render struct {
}

func (*Render) RenderTemplateParams

func (r *Render) RenderTemplateParams(tmpl *argoappsv1.Application, syncPolicy *argoappsv1.ApplicationSetSyncPolicy, params map[string]interface{}, useGoTemplate bool) (*argoappsv1.Application, error)

func (*Render) Replace

func (r *Render) Replace(tmpl string, replaceMap map[string]interface{}, useGoTemplate bool) (string, error)

Replace executes basic string substitution of a template with replacement values. remaining in the substituted template.

type Renderer

type Renderer interface {
	RenderTemplateParams(tmpl *argoappsv1.Application, syncPolicy *argoappsv1.ApplicationSetSyncPolicy, params map[string]interface{}, useGoTemplate bool) (*argoappsv1.Application, error)
}

type SyncPolicy

type SyncPolicy struct{}

func (*SyncPolicy) Delete

func (p *SyncPolicy) Delete() bool

func (*SyncPolicy) Update

func (p *SyncPolicy) Update() bool