controllers

Documentation

Index

• Constants
• Variables
• func MatchMachineHealthCheckStatus(expected *clusterv1.MachineHealthCheckStatus) types.GomegaMatcher
• type ClusterReconciler
  • func (r *ClusterReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type MachineDeploymentReconciler
  • func (r *MachineDeploymentReconciler) MachineSetToDeployments(o handler.MapObject) []ctrl.Request
  • func (r *MachineDeploymentReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *MachineDeploymentReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type MachineHealthCheckReconciler
  • func (r *MachineHealthCheckReconciler) PatchHealthyTargets(ctx context.Context, healthy []healthCheckTarget, cluster *clusterv1.Cluster, ...) []error
  • func (r *MachineHealthCheckReconciler) PatchUnhealthyTargets(ctx context.Context, unhealthy []healthCheckTarget, cluster *clusterv1.Cluster, ...) []error
  • func (r *MachineHealthCheckReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *MachineHealthCheckReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type MachineReconciler
  • func (r *MachineReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *MachineReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type MachineSetReconciler
  • func (r *MachineSetReconciler) MachineToMachineSets(o handler.MapObject) []ctrl.Request
  • func (r *MachineSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *MachineSetReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

Constants

const (

	// EventSkippedControlPlane is emitted in case an unhealthy node (or a machine
	// associated with the node) has the `control-plane` role
	// Deprecated: no longer in use
	EventSkippedControlPlane string = "SkippedControlPlane"
	// EventMachineDeletionFailed is emitted in case remediation of a machine
	// is required but deletion of its Machine object failed
	// Deprecated: no longer in use
	EventMachineDeletionFailed string = "MachineDeletionFailed"
	// EventMachineDeleted is emitted when machine was successfully remediated
	// by deleting its Machine object
	// Deprecated: no longer in use
	EventMachineDeleted string = "MachineDeleted"
	// EventMachineMarkedUnhealthy is emitted when machine was successfully marked as unhealthy
	EventMachineMarkedUnhealthy string = "MachineMarkedUnhealthy"
	// EventDetectedUnhealthy is emitted in case a node associated with a
	// machine was detected unhealthy
	EventDetectedUnhealthy string = "DetectedUnhealthy"
)

const (
	// DeleteNodeAnnotation marks nodes that will be given priority for deletion
	// when a machineset scales down. This annotation is given top priority on all delete policies.
	// Deprecated: Please use DeleteMachineAnnotation instead.
	DeleteNodeAnnotation = "cluster.k8s.io/delete-machine"
	// DeleteMachineAnnotation marks nodes that will be given priority for deletion
	// when a machineset scales down. This annotation is given top priority on all delete policies.
	DeleteMachineAnnotation = "cluster.x-k8s.io/delete-machine"
)

const (

	// EventRemediationRestricted is emitted in case when machine remediation
	// is restricted by remediation circuit shorting logic
	EventRemediationRestricted string = "RemediationRestricted"
)

Variables

var (
	ErrNodeNotFound = errors.New("cannot find node with matching ProviderID")
)

Functions

func MatchMachineHealthCheckStatus

func MatchMachineHealthCheckStatus(expected *clusterv1.MachineHealthCheckStatus) types.GomegaMatcher

MatchMachineHealthCheckStatus returns a custom matcher to check equality of clusterv1.MachineHealthCheckStatus

Types

type ClusterReconciler

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

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile

func (r *ClusterReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*ClusterReconciler) SetupWithManager

func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

type MachineDeploymentReconciler

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

MachineDeploymentReconciler reconciles a MachineDeployment object

func (*MachineDeploymentReconciler) MachineSetToDeployments

func (r *MachineDeploymentReconciler) MachineSetToDeployments(o handler.MapObject) []ctrl.Request

MachineSetTodeployments is a handler.ToRequestsFunc to be used to enqeue requests for reconciliation for MachineDeployments that might adopt an orphaned MachineSet.

func (*MachineDeploymentReconciler) Reconcile

func (r *MachineDeploymentReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*MachineDeploymentReconciler) SetupWithManager

func (r *MachineDeploymentReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

type MachineHealthCheckReconciler

type MachineHealthCheckReconciler struct {
	Client  client.Client
	Log     logr.Logger
	Tracker *remote.ClusterCacheTracker
	// contains filtered or unexported fields
}

MachineHealthCheckReconciler reconciles a MachineHealthCheck object

func (*MachineHealthCheckReconciler) PatchHealthyTargets

func (r *MachineHealthCheckReconciler) PatchHealthyTargets(ctx context.Context, healthy []healthCheckTarget, cluster *clusterv1.Cluster, m *clusterv1.MachineHealthCheck) []error

PatchHealthyTargets patches healthy machines with MachineHealthCheckSuccededCondition.

func (*MachineHealthCheckReconciler) PatchUnhealthyTargets

func (r *MachineHealthCheckReconciler) PatchUnhealthyTargets(ctx context.Context, unhealthy []healthCheckTarget, cluster *clusterv1.Cluster, m *clusterv1.MachineHealthCheck) []error

PatchUnhealthyTargets patches machines with MachineOwnerRemediatedCondition for remediation

func (*MachineHealthCheckReconciler) Reconcile

func (r *MachineHealthCheckReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*MachineHealthCheckReconciler) SetupWithManager

func (r *MachineHealthCheckReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

type MachineReconciler

type MachineReconciler struct {
	Client  client.Client
	Log     logr.Logger
	Tracker *remote.ClusterCacheTracker
	// contains filtered or unexported fields
}

MachineReconciler reconciles a Machine object

func (*MachineReconciler) Reconcile

func (r *MachineReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*MachineReconciler) SetupWithManager

func (r *MachineReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

type MachineSetReconciler

type MachineSetReconciler struct {
	Client  client.Client
	Log     logr.Logger
	Tracker *remote.ClusterCacheTracker
	// contains filtered or unexported fields
}

MachineSetReconciler reconciles a MachineSet object

func (*MachineSetReconciler) MachineToMachineSets

func (r *MachineSetReconciler) MachineToMachineSets(o handler.MapObject) []ctrl.Request

MachineToMachineSets is a handler.ToRequestsFunc to be used to enqeue requests for reconciliation for MachineSets that might adopt an orphaned Machine.

func (*MachineSetReconciler) Reconcile

func (r *MachineSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*MachineSetReconciler) SetupWithManager

func (r *MachineSetReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error