multicluster

Documentation

Index

• type ClusterGetter
• type LifecycleManager
  • func NewLifecycleManager(subroutines []subroutine.Subroutine, operatorName string, ...) *LifecycleManager
  • func (l *LifecycleManager) ConditionsManager() api.ConditionManager
  • func (l *LifecycleManager) Config() api.Config
  • func (l *LifecycleManager) Log() *logger.Logger
  • func (l *LifecycleManager) PrepareContextFunc() api.PrepareContextFunc
  • func (l *LifecycleManager) Reconcile(ctx context.Context, req mcreconcile.Request, ...) (ctrl.Result, error)
  • func (l *LifecycleManager) SetupWithManager(mgr mcmanager.Manager, maxReconciles int, reconcilerName string, ...) error
  • func (l *LifecycleManager) SetupWithManagerBuilder(mgr mcmanager.Manager, maxReconciles int, reconcilerName string, ...) (*mcbuilder.Builder, error)
  • func (l *LifecycleManager) Spreader() api.SpreadManager
  • func (l *LifecycleManager) Subroutines() []subroutine.Subroutine
  • func (l *LifecycleManager) WithConditionManagement() api.Lifecycle
  • func (l *LifecycleManager) WithPrepareContextFunc(prepareFunction api.PrepareContextFunc) *LifecycleManager
  • func (l *LifecycleManager) WithReadOnly() *LifecycleManager
  • func (l *LifecycleManager) WithSpreadingReconciles() api.Lifecycle

Types

type ClusterGetter

type ClusterGetter interface {
	GetCluster(ctx context.Context, clusterName string) (cluster.Cluster, error)
}

type LifecycleManager

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

func NewLifecycleManager

func NewLifecycleManager(subroutines []subroutine.Subroutine, operatorName string, controllerName string, mgr ClusterGetter, log *logger.Logger) *LifecycleManager

func (*LifecycleManager) ConditionsManager

func (l *LifecycleManager) ConditionsManager() api.ConditionManager

func (*LifecycleManager) Config

func (l *LifecycleManager) Config() api.Config

func (*LifecycleManager) Log

func (l *LifecycleManager) Log() *logger.Logger

func (*LifecycleManager) PrepareContextFunc

func (l *LifecycleManager) PrepareContextFunc() api.PrepareContextFunc

func (*LifecycleManager) Reconcile

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

func (*LifecycleManager) SetupWithManager

func (l *LifecycleManager) SetupWithManager(mgr mcmanager.Manager, maxReconciles int, reconcilerName string, instance runtimeobject.RuntimeObject, debugLabelValue string, r mcreconcile.Reconciler, log *logger.Logger, eventPredicates ...predicate.Predicate) error

func (*LifecycleManager) SetupWithManagerBuilder

func (l *LifecycleManager) SetupWithManagerBuilder(mgr mcmanager.Manager, maxReconciles int, reconcilerName string, instance runtimeobject.RuntimeObject, debugLabelValue string, log *logger.Logger, eventPredicates ...predicate.Predicate) (*mcbuilder.Builder, error)

func (*LifecycleManager) Spreader

func (l *LifecycleManager) Spreader() api.SpreadManager

func (*LifecycleManager) Subroutines

func (l *LifecycleManager) Subroutines() []subroutine.Subroutine

func (*LifecycleManager) WithConditionManagement

func (l *LifecycleManager) WithConditionManagement() api.Lifecycle

func (*LifecycleManager) WithPrepareContextFunc

func (l *LifecycleManager) WithPrepareContextFunc(prepareFunction api.PrepareContextFunc) *LifecycleManager

WithPrepareContextFunc allows to set a function that prepares the context before each reconciliation This can be used to add additional information to the context that is needed by the subroutines You need to return a new context and an OperatorError in case of an error

func (*LifecycleManager) WithReadOnly

func (l *LifecycleManager) WithReadOnly() *LifecycleManager

WithReadOnly allows to set the controller to read-only mode In read-only mode, the controller will not update the status of the instance

func (*LifecycleManager) WithSpreadingReconciles

func (l *LifecycleManager) WithSpreadingReconciles() api.Lifecycle

WithSpreadingReconciles sets the LifecycleManager to spread out the reconciles