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)
• func WaitUntil(src <-chan *v1alpha1.Lifecycle, phase v1alpha1.Phase) 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) FailedList() []string
  • 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) NumFailedJobs() int
  • func (in Classifier) NumPendingJobs() int
  • func (in Classifier) NumRunningJobs() int
  • func (in Classifier) NumSuccessfulJobs() int
  • func (in Classifier) PendingJobs() []client.Object
  • func (in Classifier) PendingList() []string
  • func (in *Classifier) Reset()
  • func (in Classifier) RunningJobs() []client.Object
  • func (in Classifier) RunningList() []string
  • func (in Classifier) SuccessfulJobs() []client.Object
  • func (in Classifier) SuccessfulList() []string
• 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.

func WaitUntil

func WaitUntil(src <-chan *v1alpha1.Lifecycle, phase v1alpha1.Phase) error

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) FailedList

func (in Classifier) FailedList() []string

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) NumFailedJobs

func (in Classifier) NumFailedJobs() int

func (Classifier) NumPendingJobs

func (in Classifier) NumPendingJobs() int

func (Classifier) NumRunningJobs

func (in Classifier) NumRunningJobs() int

func (Classifier) NumSuccessfulJobs

func (in Classifier) NumSuccessfulJobs() int

func (Classifier) PendingJobs

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

func (Classifier) PendingList

func (in Classifier) PendingList() []string

func (*Classifier) Reset

func (in *Classifier) Reset()

func (Classifier) RunningJobs

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

func (Classifier) RunningList

func (in Classifier) RunningList() []string

func (Classifier) SuccessfulJobs

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

func (Classifier) SuccessfulList

func (in Classifier) SuccessfulList() []string

type ClassifierReader

type ClassifierReader interface {
	IsZero() bool
	IsPending(jobName string) bool
	IsRunning(name string) bool
	IsSuccessful(name string) bool
	IsFailed(name string) bool
	NumPendingJobs() int
	NumRunningJobs() int
	NumSuccessfulJobs() int
	NumFailedJobs() int
	PendingList() []string
	RunningList() []string
	SuccessfulList() []string
	FailedList() []string
	PendingJobs() []client.Object
	RunningJobs() []client.Object
	SuccessfulJobs() []client.Object
	FailedJobs() []client.Object

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

type ReconcileStatusAware

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