argo

Documentation

Index

• Constants
• func CheckValidParam(appMap map[string]map[string]bool, newParam argoappv1.ComponentParameter) bool
• func ContainsSyncResource(u *unstructured.Unstructured, rr []argoappv1.SyncOperationResource) bool
• func FilterByProjects(apps []argoappv1.Application, projects []string) []argoappv1.Application
• func FormatAppConditions(conditions []argoappv1.ApplicationCondition) string
• func GetAppProject(spec *argoappv1.ApplicationSpec, appclientset appclientset.Interface, ...) (*argoappv1.AppProject, error)
• func GetSpecErrors(ctx context.Context, spec *argoappv1.ApplicationSpec, ...) ([]argoappv1.ApplicationCondition, error)
• func ParamToMap(params []argoappv1.ComponentParameter) map[string]map[string]bool
• func RefreshApp(appIf v1alpha1.ApplicationInterface, name string) (*argoappv1.Application, error)
• func SetAppOperation(ctx context.Context, appIf v1alpha1.ApplicationInterface, audit *AuditLogger, ...) (*argoappv1.Application, error)
• func WaitForRefresh(appIf v1alpha1.ApplicationInterface, name string, timeout *time.Duration) (*argoappv1.Application, error)
• type AuditLogger
  • func NewAuditLogger(ns string, kIf kubernetes.Interface, component string) *AuditLogger
  • func (l *AuditLogger) LogAppEvent(app *v1alpha1.Application, info EventInfo, message string)
  • func (l *AuditLogger) LogAppProjEvent(proj *v1alpha1.AppProject, info EventInfo, message string)
• type EventInfo

Constants

const (
	EventReasonStatusRefreshed    = "StatusRefreshed"
	EventReasonResourceCreated    = "ResourceCreated"
	EventReasonResourceUpdated    = "ResourceUpdated"
	EventReasonResourceDeleted    = "ResourceDeleted"
	EventReasonOperationStarted   = "OperationStarted"
	EventReasonOperationCompleted = "OperationCompleted"
)

Functions

func CheckValidParam

func CheckValidParam(appMap map[string]map[string]bool, newParam argoappv1.ComponentParameter) bool

CheckValidParam checks if the parameter passed is overridable for the given appMap

func ContainsSyncResource

func ContainsSyncResource(u *unstructured.Unstructured, rr []argoappv1.SyncOperationResource) bool

ContainsSyncResource determines if the given resource exists in the provided slice of sync operation resources. ContainsSyncResource returns false if either argument is nil.

func FilterByProjects

func FilterByProjects(apps []argoappv1.Application, projects []string) []argoappv1.Application

FilterByProjects returns applications which belongs to the specified project

func FormatAppConditions

func FormatAppConditions(conditions []argoappv1.ApplicationCondition) string

FormatAppConditions returns string representation of give app condition list

func GetAppProject

func GetAppProject(spec *argoappv1.ApplicationSpec, appclientset appclientset.Interface, ns string) (*argoappv1.AppProject, error)

GetAppProject returns a project from an application

func GetSpecErrors

func GetSpecErrors(
	ctx context.Context, spec *argoappv1.ApplicationSpec, proj *argoappv1.AppProject, repoClientset reposerver.Clientset, db db.ArgoDB) ([]argoappv1.ApplicationCondition, error)

GetSpecErrors returns list of conditions which indicates that app spec is invalid. Following is checked: * the git repository is accessible * the git path contains a valid app.yaml * the specified environment exists * the referenced cluster has been added to ArgoCD * the app source repo and destination namespace/cluster are permitted in app project

func ParamToMap

func ParamToMap(params []argoappv1.ComponentParameter) map[string]map[string]bool

ParamToMap converts a ComponentParameter list to a map for easy filtering

func RefreshApp

func RefreshApp(appIf v1alpha1.ApplicationInterface, name string) (*argoappv1.Application, error)

RefreshApp updates the refresh annotation of an application to coerce the controller to process it

func SetAppOperation

func SetAppOperation(ctx context.Context, appIf v1alpha1.ApplicationInterface, audit *AuditLogger, appName string, op *argoappv1.Operation) (*argoappv1.Application, error)

SetAppOperation updates an application with the specified operation, retrying conflict errors

func WaitForRefresh

func WaitForRefresh(appIf v1alpha1.ApplicationInterface, name string, timeout *time.Duration) (*argoappv1.Application, error)

WaitForRefresh watches an application until its comparison timestamp is after the refresh timestamp If refresh timestamp is not present, will use current timestamp at time of call

Types

type AuditLogger

type AuditLogger struct {
	// contains filtered or unexported fields
}

func NewAuditLogger

func NewAuditLogger(ns string, kIf kubernetes.Interface, component string) *AuditLogger

func (*AuditLogger) LogAppEvent

func (l *AuditLogger) LogAppEvent(app *v1alpha1.Application, info EventInfo, message string)

func (*AuditLogger) LogAppProjEvent

func (l *AuditLogger) LogAppProjEvent(proj *v1alpha1.AppProject, info EventInfo, message string)

type EventInfo

type EventInfo struct {
	Type   string
	Reason string
}