controller

Documentation

Index

• func CapiClusterObjectKey(cluster *anywherev1.Cluster) client.ObjectKey
• func GetCAPICluster(ctx context.Context, client client.Client, cluster *anywherev1.Cluster) (*clusterv1.Cluster, error)
• type Phase
• type PhaseRunner
  • func NewPhaseRunner() PhaseRunner
  • func (r PhaseRunner) Register(phases ...Phase) PhaseRunner
  • func (r PhaseRunner) Run(ctx context.Context, log logr.Logger, clusterSpec *cluster.Spec) (Result, error)
• type Result
  • func ResultWithRequeue(after time.Duration) Result
  • func ResultWithReturn() Result
  • func (r *Result) Return() bool
  • func (r Result) ToCtrlResult() ctrl.Result

Functions

func CapiClusterObjectKey

func CapiClusterObjectKey(cluster *anywherev1.Cluster) client.ObjectKey

CapiClusterObjectKey generates an ObjectKey for the CAPI cluster owned by the provided eks-a cluster.

func GetCAPICluster

func GetCAPICluster(ctx context.Context, client client.Client, cluster *anywherev1.Cluster) (*clusterv1.Cluster, error)

GetCAPICluster reads a cluster-api Cluster for an eks-a cluster using a kube client If the CAPI cluster is not found, the method returns (nil, nil).

Types

type Phase

type Phase func(ctx context.Context, log logr.Logger, clusterSpec *cluster.Spec) (Result, error)

Phase represents a generic reconciliation phase for a cluster spec.

type PhaseRunner

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

PhaseRunner allows to execute Phases in order.

func NewPhaseRunner

func NewPhaseRunner() PhaseRunner

NewPhaseRunner creates a new PhaseRunner without any Phases.

func (PhaseRunner) Register

func (r PhaseRunner) Register(phases ...Phase) PhaseRunner

Register adds a phase to the runnner.

func (PhaseRunner) Run

func (r PhaseRunner) Run(ctx context.Context, log logr.Logger, clusterSpec *cluster.Spec) (Result, error)

Run will execute phases in the order they were registered until a phase returns an error or a Result that requests to an interruption.

type Result

type Result struct {
	Result *ctrl.Result
}

Result represents the result of a reconciliation It allows to express intent for a reconciliation interruption without necessarily requeueing the request.

func ResultWithRequeue

func ResultWithRequeue(after time.Duration) Result

ResultWithReturn creates a new Result that requeues the request after the provided duration.

func ResultWithReturn

func ResultWithReturn() Result

ResultWithReturn creates a new Result that interrupts the reconciliation without requeueing.

func (*Result) Return

func (r *Result) Return() bool

Return evaluates the intent of a Result to interrupt the reconciliation process or not.

func (Result) ToCtrlResult

func (r Result) ToCtrlResult() ctrl.Result

ToCtrlResult converts Result to a controller-runtime result.