lifecycle

Documentation

Index

• Constants
• type LifecycleManager
  • func NewLifecycleManager(logger *logger.Logger, operatorName string, controllerName string, ...) *LifecycleManager
  • func (l *LifecycleManager) Reconcile(ctx context.Context, req ctrl.Request, instance RuntimeObject) (ctrl.Result, error)
  • func (l *LifecycleManager) SetupWithManager(mgr ctrl.Manager, maxReconciles int, reconcilerName string, ...) error
  • func (l *LifecycleManager) WithSpreadingReconciles() *LifecycleManager
• type RuntimeObject
• type RuntimeObjectSpreadReconcileStatus
• type Subroutine

Constants

const SpreadReconcileRefreshLabel = "openmfp.io/refresh-reconcile"

Types

type LifecycleManager

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

func NewLifecycleManager

func NewLifecycleManager(logger *logger.Logger, operatorName string, controllerName string, client client.Client, subroutines []Subroutine) *LifecycleManager

func (*LifecycleManager) Reconcile

func (l *LifecycleManager) Reconcile(ctx context.Context, req ctrl.Request, instance RuntimeObject) (ctrl.Result, error)

func (*LifecycleManager) SetupWithManager

func (l *LifecycleManager) SetupWithManager(mgr ctrl.Manager, maxReconciles int, reconcilerName string, instance RuntimeObject, debugLabelValue string, r reconcile.Reconciler, eventPredicates ...predicate.Predicate) error

func (*LifecycleManager) WithSpreadingReconciles

func (l *LifecycleManager) WithSpreadingReconciles() *LifecycleManager

WithSpreadingReconciles sets the LifecycleManager to spread out the reconciles

type RuntimeObject

type RuntimeObject interface {
	runtime.Object
	v1.Object
}

type RuntimeObjectSpreadReconcileStatus

type RuntimeObjectSpreadReconcileStatus interface {
	GetGeneration() int64
	GetObservedGeneration() int64
	SetObservedGeneration(int64)
	GetNextReconcileTime() v1.Time
	SetNextReconcileTime(time v1.Time)
}

type Subroutine

type Subroutine interface {
	Process(ctx context.Context, instance RuntimeObject) (ctrl.Result, errors.OperatorError)
	Finalize(ctx context.Context, instance RuntimeObject) (ctrl.Result, errors.OperatorError)
	GetName() string
	Finalizers() []string
}