lifecycle

Documentation

Index

• func Failed(ctx context.Context, r utils.Reconciler, obj client.Object, issue error) (reconcile.Result, error)
• func Pending(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)
• func Running(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)
• func Success(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)
• type Classifier
  • func (in *Classifier) Classify(name string, obj client.Object)
  • func (in *Classifier) Exclude(name string, obj client.Object)
  • func (in Classifier) FailedJobs() []client.Object
  • func (in Classifier) FailedJobsList() []string
  • func (in Classifier) FailedJobsNum() int
  • func (in Classifier) IsDeletable(jobName string) (client.Object, bool)
  • func (in Classifier) IsFailed(name string) bool
  • func (in Classifier) IsPending(jobName string) bool
  • func (in Classifier) IsRunning(name string) bool
  • func (in Classifier) IsSuccessful(name string) bool
  • func (in Classifier) IsZero() bool
  • func (in Classifier) PendingJobs() []client.Object
  • func (in Classifier) PendingJobsList() []string
  • func (in Classifier) PendingJobsNum() int
  • func (in *Classifier) Reset()
  • func (in Classifier) RunningJobs() []client.Object
  • func (in Classifier) RunningJobsList() []string
  • func (in Classifier) RunningJobsNum() int
  • func (in Classifier) SuccessfulJobs() []client.Object
  • func (in Classifier) SuccessfulJobsList() []string
  • func (in Classifier) SuccessfulJobsNum() int
• type ClassifierReader
• type ReconcileStatusAware

Functions

func Failed

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

Failed is a wrap that logs the error, updates the status, and does not requeue the request.

func Pending

func Pending(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)

Pending is a wrapper that sets Phase to Pending and does not requeue the request.

func Running

func Running(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)

Running is a wrapper that sets Phase to Running and does not requeue the request.

func Success

func Success(ctx context.Context, r utils.Reconciler, obj client.Object, reason string) (reconcile.Result, error)

Success is a wrapper that sets Phase to Success and does not requeue the request.

Types

type Classifier

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

func (*Classifier) Classify

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

func (*Classifier) Exclude

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

Exclude registers a system service. Services classified by this function are not accounted, unless they have failed.

func (Classifier) FailedJobs

func (in Classifier) FailedJobs() []client.Object

func (Classifier) FailedJobsList

func (in Classifier) FailedJobsList() []string

func (Classifier) FailedJobsNum

func (in Classifier) FailedJobsNum() int

func (Classifier) IsDeletable

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

func (Classifier) IsFailed

func (in Classifier) IsFailed(name string) bool

func (Classifier) IsPending

func (in Classifier) IsPending(jobName string) bool

func (Classifier) IsRunning

func (in Classifier) IsRunning(name string) bool

func (Classifier) IsSuccessful

func (in Classifier) IsSuccessful(name string) bool

func (Classifier) IsZero

func (in Classifier) IsZero() bool

func (Classifier) PendingJobs

func (in Classifier) PendingJobs() []client.Object

func (Classifier) PendingJobsList

func (in Classifier) PendingJobsList() []string

func (Classifier) PendingJobsNum

func (in Classifier) PendingJobsNum() int

func (*Classifier) Reset

func (in *Classifier) Reset()

func (Classifier) RunningJobs

func (in Classifier) RunningJobs() []client.Object

func (Classifier) RunningJobsList

func (in Classifier) RunningJobsList() []string

func (Classifier) RunningJobsNum

func (in Classifier) RunningJobsNum() int

func (Classifier) SuccessfulJobs

func (in Classifier) SuccessfulJobs() []client.Object

func (Classifier) SuccessfulJobsList

func (in Classifier) SuccessfulJobsList() []string

func (Classifier) SuccessfulJobsNum

func (in Classifier) SuccessfulJobsNum() int

type ClassifierReader

type ClassifierReader interface {
	IsZero() bool
	IsPending(jobName string) bool
	IsRunning(name string) bool
	IsSuccessful(name string) bool
	IsFailed(name string) bool

	// IsDeletable returns true if a job is deletable: it is pending or running
	IsDeletable(jobName string) (client.Object, bool)

	PendingJobs() []client.Object
	RunningJobs() []client.Object
	SuccessfulJobs() []client.Object
	FailedJobs() []client.Object

	PendingJobsNum() int
	RunningJobsNum() int
	SuccessfulJobsNum() int
	FailedJobsNum() int

	PendingJobsList() []string
	RunningJobsList() []string
	SuccessfulJobsList() []string
	FailedJobsList() []string
}

type ReconcileStatusAware

type ReconcileStatusAware interface {
	GetReconcileStatus() v1alpha1.Lifecycle
	SetReconcileStatus(v1alpha1.Lifecycle)
}