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) ActiveJobs() []client.Object
  • func (in *Classifier) ActiveList() []string
  • func (in *Classifier) Classify(name string, obj client.Object)
  • func (in *Classifier) ClassifyAsFrisbeeService(name string, obj client.Object)
  • func (in *Classifier) FailedJobs() []client.Object
  • func (in *Classifier) FailedList() []string
  • func (in *Classifier) IsActive(jobName string) bool
  • func (in *Classifier) IsFailed(name string) bool
  • func (in *Classifier) IsRunning(name string) bool
  • func (in *Classifier) IsSuccessful(name string) bool
  • func (in *Classifier) NumActiveJobs() int
  • func (in *Classifier) NumFailedJobs() int
  • func (in *Classifier) NumRunningJobs() int
  • func (in *Classifier) NumSuccessfulJobs() int
  • 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 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) ActiveJobs

func (in *Classifier) ActiveJobs() []client.Object

func (*Classifier) ActiveList

func (in *Classifier) ActiveList() []string

func (*Classifier) Classify

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

func (*Classifier) ClassifyAsFrisbeeService

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

ClassifyAsFrisbeeService 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) IsActive

func (in *Classifier) IsActive(jobName string) bool

func (*Classifier) IsFailed

func (in *Classifier) IsFailed(name string) bool

func (*Classifier) IsRunning

func (in *Classifier) IsRunning(name string) bool

func (*Classifier) IsSuccessful

func (in *Classifier) IsSuccessful(name string) bool

func (*Classifier) NumActiveJobs

func (in *Classifier) NumActiveJobs() int

func (*Classifier) NumFailedJobs

func (in *Classifier) NumFailedJobs() int

func (*Classifier) NumRunningJobs

func (in *Classifier) NumRunningJobs() int

func (*Classifier) NumSuccessfulJobs

func (in *Classifier) NumSuccessfulJobs() int

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 ReconcileStatusAware

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