package controllers

import "sigs.k8s.io/cluster-api/controllers"

Index ¶

• Constants
• Variables
• type ClusterReconciler
• func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
• func (r *ClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MachineDeploymentReconciler
• func (r *MachineDeploymentReconciler) MachineSetToDeployments(o client.Object) []ctrl.Request
• func (r *MachineDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
• func (r *MachineDeploymentReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MachineHealthCheckReconciler
• func (r *MachineHealthCheckReconciler) PatchHealthyTargets(ctx context.Context, logger logr.Logger, healthy []healthCheckTarget, cluster *clusterv1.Cluster, m *clusterv1.MachineHealthCheck) []error
• func (r *MachineHealthCheckReconciler) PatchUnhealthyTargets(ctx context.Context, logger logr.Logger, unhealthy []healthCheckTarget, cluster *clusterv1.Cluster, m *clusterv1.MachineHealthCheck) []error
• func (r *MachineHealthCheckReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
• func (r *MachineHealthCheckReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MachineReconciler
• func (r *MachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
• func (r *MachineReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MachineSetReconciler
• func (r *MachineSetReconciler) MachineToMachineSets(o client.Object) []ctrl.Request
• func (r *MachineSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
• func (r *MachineSetReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

Package Files ¶

cluster_controller.go cluster_controller_phases.go doc.go machine_controller.go machine_controller_node_labels.go machine_controller_noderef.go machine_controller_phases.go machine_helpers.go machinedeployment_controller.go machinedeployment_rolling.go machinedeployment_sync.go machinehealthcheck_controller.go machinehealthcheck_targets.go machineset_controller.go machineset_delete_policy.go

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 (

    // 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")
)

type ClusterReconciler ¶ Uses

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

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile ¶ Uses

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

func (*ClusterReconciler) SetupWithManager ¶ Uses

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

type MachineDeploymentReconciler ¶ Uses

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

MachineDeploymentReconciler reconciles a MachineDeployment object

func (*MachineDeploymentReconciler) MachineSetToDeployments ¶ Uses

func (r *MachineDeploymentReconciler) MachineSetToDeployments(o client.Object) []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 ¶ Uses

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

func (*MachineDeploymentReconciler) SetupWithManager ¶ Uses

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

type MachineHealthCheckReconciler ¶ Uses

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

MachineHealthCheckReconciler reconciles a MachineHealthCheck object

func (*MachineHealthCheckReconciler) PatchHealthyTargets ¶ Uses

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

PatchHealthyTargets patches healthy machines with MachineHealthCheckSuccededCondition.

func (*MachineHealthCheckReconciler) PatchUnhealthyTargets ¶ Uses

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

PatchUnhealthyTargets patches machines with MachineOwnerRemediatedCondition for remediation

func (*MachineHealthCheckReconciler) Reconcile ¶ Uses

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

func (*MachineHealthCheckReconciler) SetupWithManager ¶ Uses

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

type MachineReconciler ¶ Uses

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

MachineReconciler reconciles a Machine object

func (*MachineReconciler) Reconcile ¶ Uses

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

func (*MachineReconciler) SetupWithManager ¶ Uses

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

type MachineSetReconciler ¶ Uses

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

MachineSetReconciler reconciles a MachineSet object

func (*MachineSetReconciler) MachineToMachineSets ¶ Uses

func (r *MachineSetReconciler) MachineToMachineSets(o client.Object) []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 ¶ Uses

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

func (*MachineSetReconciler) SetupWithManager ¶ Uses

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

Directories ¶