controllers

Documentation

Index

• Variables
• type CK8sControlPlaneReconciler
  • func (r *CK8sControlPlaneReconciler) ClusterToCK8sControlPlane(ctx context.Context, log *logr.Logger) handler.MapFunc
  • func (r *CK8sControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CK8sControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, log *logr.Logger) error
• type MachineReconciler
  • func (r *MachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MachineReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, log *logr.Logger) error
• type OrchestratedInPlaceUpgradeController
  • func (r *OrchestratedInPlaceUpgradeController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OrchestratedInPlaceUpgradeController) SetupWithManager(mgr ctrl.Manager) error
• type OrchestratedInPlaceUpgradeScope
• type RemediationData
  • func RemediationDataFromAnnotation(value string) (*RemediationData, error)
  • func (r *RemediationData) Marshal() (string, error)
  • func (r *RemediationData) ToStatus() *controlplanev1.LastRemediationStatus

Variables

var ErrPreConditionFailed = errors.New("precondition check failed")

Types

type CK8sControlPlaneReconciler

type CK8sControlPlaneReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	K8sdDialTimeout time.Duration
	// contains filtered or unexported fields
}

CK8sControlPlaneReconciler reconciles a CK8sControlPlane object.

func (*CK8sControlPlaneReconciler) ClusterToCK8sControlPlane

func (r *CK8sControlPlaneReconciler) ClusterToCK8sControlPlane(ctx context.Context, log *logr.Logger) handler.MapFunc

ClusterToCK8sControlPlane is a handler.ToRequestsFunc to be used to enqueue requests for reconciliation for CK8sControlPlane based on updates to a Cluster.

func (*CK8sControlPlaneReconciler) Reconcile

func (r *CK8sControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*CK8sControlPlaneReconciler) SetupWithManager

func (r *CK8sControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, log *logr.Logger) error

type MachineReconciler

type MachineReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	K8sdDialTimeout time.Duration
	// contains filtered or unexported fields
}

MachineReconciler reconciles a Machine object.

func (*MachineReconciler) Reconcile

func (r *MachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MachineReconciler) SetupWithManager

func (r *MachineReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, log *logr.Logger) error

type OrchestratedInPlaceUpgradeController

type OrchestratedInPlaceUpgradeController struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

OrchestratedInPlaceUpgradeController reconciles a CK8sControlPlane object and manages the in-place upgrades.

func (*OrchestratedInPlaceUpgradeController) Reconcile

func (r *OrchestratedInPlaceUpgradeController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles the reconciliation of a CK8sControlPlane object.

func (*OrchestratedInPlaceUpgradeController) SetupWithManager

func (r *OrchestratedInPlaceUpgradeController) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type OrchestratedInPlaceUpgradeScope

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

OrchestratedInPlaceUpgradeScope is a struct that holds the context of the upgrade process.

type RemediationData

type RemediationData struct {
	// Machine is the machine name of the latest machine being remediated.
	Machine string `json:"machine"`

	// Timestamp is when last remediation happened. It is represented in RFC3339 form and is in UTC.
	Timestamp metav1.Time `json:"timestamp"`

	// RetryCount used to keep track of remediation retry for the last remediated machine.
	// A retry happens when a machine that was created as a replacement for an unhealthy machine also fails.
	RetryCount int `json:"retryCount"`
}

RemediationData struct is used to keep track of information stored in the RemediationInProgressAnnotation in KCP during remediation and then into the RemediationForAnnotation on the replacement machine once it is created.

func RemediationDataFromAnnotation

func RemediationDataFromAnnotation(value string) (*RemediationData, error)

RemediationDataFromAnnotation gets RemediationData from an annotation value.

func (*RemediationData) Marshal

func (r *RemediationData) Marshal() (string, error)

Marshal an RemediationData into an annotation value.

func (*RemediationData) ToStatus

func (r *RemediationData) ToStatus() *controlplanev1.LastRemediationStatus

ToStatus converts a RemediationData into a LastRemediationStatus struct.