argo

Documentation

Index

• Constants
• func CheckValidParam(appMap map[string]map[string]bool, newParam argoappv1.ComponentParameter) 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 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

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
}