workflow

Feb 1, 2022

Changes in this version

type Controller

+ func (r *Controller) WatchStopJobs() predicate.Funcs

+ func (r *Controller) WatchStopJobsCreate(e event.CreateEvent) bool

+ func (r *Controller) WatchStopJobsDelete(e event.DeleteEvent) bool

+ func (r *Controller) WatchStopJobsGeneric(event.GenericEvent) bool

+ func (r *Controller) WatchStopJobsUpdate(e event.UpdateEvent) bool

Jan 24, 2022

Changes in this version

type Controller

+ func (r *Controller) WatchVirtualObjects() predicate.Funcs

+ func (r *Controller) WatchVirtualObjectsCreate(e event.CreateEvent) bool

+ func (r *Controller) WatchVirtualObjectsDelete(e event.DeleteEvent) bool

+ func (r *Controller) WatchVirtualObjectsGeneric(event.GenericEvent) bool

+ func (r *Controller) WatchVirtualObjectsUpdate(e event.UpdateEvent) bool

Jan 18, 2022

Changes in this version

+ func RandomFixedIndexes(start, end, count uint) []uint

+ type SList []*v1alpha1.Service

+ func Select(ctx context.Context, s *Controller, nm string, ss *v1alpha1.ServiceSelector) (SList, error)

+ func (in SList) GetNames() []string

+ func (in SList) ToString() string

Nov 29, 2021

Changes in this version

type Controller

+ func (r *Controller) ConnectToGrafana(ctx context.Context, cr *v1alpha1.Workflow) error

Nov 23, 2021

Changes in this version

+ const JobHasSLA

+ const SLAViolationFired

+ const SLAViolationInfo

+ func AssertSLA(w *v1alpha1.Workflow) (string, bool)

+ func AssertState(expr string, state *BuiltinState) error

+ func GetNextLogicalJob(obj metav1.Object, all v1alpha1.ActionList, gs lifecycle.Classifier, ...) (v1alpha1.ActionList, time.Time)

+ func InsertSLAAlert(action v1alpha1.Action, w *v1alpha1.Workflow, job metav1.Object) error

+ func NewController(mgr ctrl.Manager, logger logr.Logger) error

+ func ValidateDAG(list v1alpha1.ActionList) error

+ type BuiltinState struct

+ Runtime *lifecycle.Classifier

+ type Controller struct

+ func (r *Controller) Finalize(obj client.Object) error

+ func (r *Controller) Finalizer() string

+ func (r *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *Controller) WatchChaos() predicate.Funcs

+ func (r *Controller) WatchClusters() predicate.Funcs

+ func (r *Controller) WatchServices() predicate.Funcs

+ func (r *Controller) WatchTelemetry() predicate.Funcs