controllers

Documentation

Overview

Package controllers implements the Kubeadm controllers.

Index

• type KubeadmControlPlaneReconciler
  • func (r *KubeadmControlPlaneReconciler) ClusterToKubeadmControlPlane(_ context.Context, o client.Object) []ctrl.Request
  • func (r *KubeadmControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, reterr error)
  • func (r *KubeadmControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type RemediationData
  • func RemediationDataFromAnnotation(value string) (*RemediationData, error)
  • func (r *RemediationData) Marshal() (string, error)
  • func (r *RemediationData) ToStatus() *controlplanev1.LastRemediationStatus

Types

type KubeadmControlPlaneReconciler

type KubeadmControlPlaneReconciler struct {
	Client              client.Client
	SecretCachingClient client.Client

	Tracker *remote.ClusterCacheTracker

	EtcdDialTimeout time.Duration
	EtcdCallTimeout time.Duration

	// WatchFilterValue is the label value used to filter events prior to reconciliation.
	WatchFilterValue string
	// contains filtered or unexported fields
}

KubeadmControlPlaneReconciler reconciles a KubeadmControlPlane object.

func (*KubeadmControlPlaneReconciler) ClusterToKubeadmControlPlane

func (r *KubeadmControlPlaneReconciler) ClusterToKubeadmControlPlane(_ context.Context, o client.Object) []ctrl.Request

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

func (*KubeadmControlPlaneReconciler) Reconcile

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

func (*KubeadmControlPlaneReconciler) SetupWithManager

func (r *KubeadmControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

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.