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
- type EventInfo
Constants ¶
const ( EventReasonStatusRefreshed = "StatusRefreshed" EventReasonResourceCreated = "ResourceCreated" EventReasonResourceUpdated = "ResourceUpdated" EventReasonResourceDeleted = "ResourceDeleted" EventReasonOperationStarted = "OperationStarted" EventReasonOperationCompleted = "OperationCompleted" )
Variables ¶
This section is empty.
Functions ¶
func CheckValidParam ¶ added in v0.6.0
CheckValidParam checks if the parameter passed is overridable for the given appMap
func ContainsSyncResource ¶ added in v0.10.0
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 ¶ added in v0.6.0
func FilterByProjects(apps []argoappv1.Application, projects []string) []argoappv1.Application
FilterByProjects returns applications which belongs to the specified project
func FormatAppConditions ¶ added in v0.6.0
func FormatAppConditions(conditions []argoappv1.ApplicationCondition) string
FormatAppConditions returns string representation of give app condition list
func GetAppProject ¶ added in v0.6.0
func GetAppProject(spec *argoappv1.ApplicationSpec, appclientset appclientset.Interface, ns string) (*argoappv1.AppProject, error)
GetAppProject returns a project from an application
func GetSpecErrors ¶ added in v0.6.0
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 ¶ added in v0.6.0
func ParamToMap(params []argoappv1.ComponentParameter) map[string]map[string]bool
ParamToMap converts a ComponentParameter list to a map for easy filtering
func RefreshApp ¶ added in v0.4.0
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 ¶ added in v0.9.0
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 ¶ added in v0.5.3
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 ¶ added in v0.7.0
type AuditLogger struct {
// contains filtered or unexported fields
}
func NewAuditLogger ¶ added in v0.7.0
func NewAuditLogger(ns string, kIf kubernetes.Interface, component string) *AuditLogger
func (*AuditLogger) LogAppEvent ¶ added in v0.7.0
func (l *AuditLogger) LogAppEvent(app *v1alpha1.Application, info EventInfo, message string)
func (*AuditLogger) LogAppProjEvent ¶ added in v0.7.0
func (l *AuditLogger) LogAppProjEvent(proj *v1alpha1.AppProject, info EventInfo, message string)
Source Files