lifecycle

May 12, 2023

Changes in this version

+ func CreateVirtualJob(ctx context.Context, reconciler common.Reconciler, parent client.Object, ...) error

Aug 30, 2022

Changes in this version

+ const AllJobsAreSuccessful

+ const AtLeastOneJobHasFailed

+ const AtLeastOneJobIsNotScheduled

+ const AtLeastOneJobIsRunning

+ const ExactlyOneJobIsFailed

+ const ExactlyOneJobIsPending

+ const ExactlyOneJobIsRunning

+ const ExactlyOneJobIsSuccessful

+ const ToleratedJobsAreSuccessful

+ const TooManyJobsHaveFailed

+ func Failed(ctx context.Context, r common.Reconciler, obj client.Object, issue error) (reconcile.Result, error)

+ func GroupedJobs(totalJobs int, state ClassifierReader, lf *v1alpha1.Lifecycle, ...) bool

+ func Pending(ctx context.Context, r common.Reconciler, obj client.Object, msg string) (reconcile.Result, error)

+ func Running(ctx context.Context, r common.Reconciler, obj client.Object, msg string) (reconcile.Result, error)

+ func SingleJob(state ClassifierReader, lf *v1alpha1.Lifecycle) bool

+ func Success(ctx context.Context, r common.Reconciler, obj client.Object, msg string) (reconcile.Result, error)

+ func VirtualExecution(ctx context.Context, r common.Reconciler, parent client.Object, jobName string, ...) error

+ type Classifier struct

+ func (in *Classifier) Classify(name string, obj client.Object)

+ func (in *Classifier) ClassifyExternal(name string, obj client.Object, conv Convertor)

+ func (in *Classifier) Count() int

+ func (in *Classifier) GetFailedJobs() []client.Object

+ func (in *Classifier) GetPendingJobs() []client.Object

+ func (in *Classifier) GetRunningJobs() []client.Object

+ func (in *Classifier) GetSuccessfulJobs() []client.Object

+ func (in *Classifier) GetTerminatingJobs() []client.Object

+ func (in *Classifier) IsDeletable(jobName string) (client.Object, bool)

+ func (in *Classifier) IsFailed(job ...string) bool

+ func (in *Classifier) IsPending(job ...string) bool

+ func (in *Classifier) IsRunning(job ...string) bool

+ func (in *Classifier) IsSuccessful(job ...string) bool

+ func (in *Classifier) IsTerminating(job ...string) bool

+ func (in *Classifier) ListAll() string

+ func (in *Classifier) ListFailedJobs() []string

+ func (in *Classifier) ListPendingJobs() []string

+ func (in *Classifier) ListRunningJobs() []string

+ func (in *Classifier) ListSuccessfulJobs() []string

+ func (in *Classifier) ListTerminatingJobs() []string

+ func (in *Classifier) NumAll() string

+ func (in *Classifier) NumPendingJobs() int

+ func (in *Classifier) NumRunningJobs() int

+ func (in *Classifier) NumSuccessfulJobs() int

+ func (in *Classifier) Reset()

+ func (in *Classifier) SystemState() (abort bool, err error)

+ func (in Classifier) NumFailedJobs() int

+ func (in Classifier) NumTerminatingJobs() int

+ type ClassifierReader interface

+ Count func() int

+ GetFailedJobs func() []client.Object

+ GetPendingJobs func() []client.Object

+ GetRunningJobs func() []client.Object

+ GetSuccessfulJobs func() []client.Object

+ IsDeletable func(job string) (client.Object, bool)

+ ListAll func() string

+ NumAll func() string

+ SystemState func() (abort bool, err error)

+ type Convertor func(object client.Object) v1alpha1.Lifecycle