Remediate unhealthy MachinePool machines

Author: AndiDog

Makefile

@@ -603,6 +603,7 @@ generate-e2e-templates-v1.11: $(KUSTOMIZE)
 generate-e2e-templates-main: $(KUSTOMIZE)
 	$(KUSTOMIZE) build $(DOCKER_TEMPLATES)/main/cluster-template --load-restrictor LoadRestrictionsNone > $(DOCKER_TEMPLATES)/main/cluster-template.yaml
 	$(KUSTOMIZE) build $(DOCKER_TEMPLATES)/main/cluster-template-md-remediation --load-restrictor LoadRestrictionsNone > $(DOCKER_TEMPLATES)/main/cluster-template-md-remediation.yaml
+	$(KUSTOMIZE) build $(DOCKER_TEMPLATES)/main/cluster-template-mp-remediation --load-restrictor LoadRestrictionsNone > $(DOCKER_TEMPLATES)/main/cluster-template-mp-remediation.yaml
 	$(KUSTOMIZE) build $(DOCKER_TEMPLATES)/main/cluster-template-kcp-remediation --load-restrictor LoadRestrictionsNone > $(DOCKER_TEMPLATES)/main/cluster-template-kcp-remediation.yaml
 	$(KUSTOMIZE) build $(DOCKER_TEMPLATES)/main/cluster-template-kcp-adoption/step1 --load-restrictor LoadRestrictionsNone > $(DOCKER_TEMPLATES)/main/cluster-template-kcp-adoption.yaml
 	echo "---" >> $(DOCKER_TEMPLATES)/main/cluster-template-kcp-adoption.yaml

api/core/v1beta1/conversion.go

@@ -1877,6 +1877,10 @@ func Convert_v1beta1_MachinePoolSpec_To_v1beta2_MachinePoolSpec(in *MachinePoolS
 	return autoConvert_v1beta1_MachinePoolSpec_To_v1beta2_MachinePoolSpec(in, out, s)
 }
 
+func Convert_v1beta2_MachinePoolSpec_To_v1beta1_MachinePoolSpec(in *clusterv1.MachinePoolSpec, out *MachinePoolSpec, s apimachineryconversion.Scope) error {
+	return autoConvert_v1beta2_MachinePoolSpec_To_v1beta1_MachinePoolSpec(in, out, s)
+}
+
 func Convert_v1beta1_ClusterClassStatusVariableDefinition_To_v1beta2_ClusterClassStatusVariableDefinition(in *ClusterClassStatusVariableDefinition, out *clusterv1.ClusterClassStatusVariableDefinition, s apimachineryconversion.Scope) error {
 	if err := autoConvert_v1beta1_ClusterClassStatusVariableDefinition_To_v1beta2_ClusterClassStatusVariableDefinition(in, out, s); err != nil {
 		return err

api/core/v1beta1/conversion_test.go

@@ -784,6 +784,7 @@ func spokeObjectReference(in *corev1.ObjectReference, c randfill.Continue) {
 
 func MachinePoolFuzzFuncs(_ runtimeserializer.CodecFactory) []interface{} {
 	return []interface{}{
+		hubMachinePoolSpec,
 		hubMachinePoolStatus,
 		hubMachineSpec,
 		spokeMachinePool,
@@ -792,6 +793,13 @@ func MachinePoolFuzzFuncs(_ runtimeserializer.CodecFactory) []interface{} {
 	}
 }
 
+func hubMachinePoolSpec(in *clusterv1.MachinePoolSpec, c randfill.Continue) {
+	c.FillNoCustom(in)
+
+	// Readded in v1beta2 with different type than in v1alpha's, no conversion possible
+	in.Remediation = clusterv1.MachinePoolRemediationSpec{}
+}
+
 func hubMachinePoolStatus(in *clusterv1.MachinePoolStatus, c randfill.Continue) {
 	c.FillNoCustom(in)
 	// Always create struct with at least one mandatory fields.

api/core/v1beta1/machinepool_types.go

@@ -104,6 +104,17 @@ type MachinePoolSpec struct {
 	FailureDomains []string `json:"failureDomains,omitempty"`
 }
 
+// MachinePoolStrategy describes how to replace existing machines
+// with new ones.
+type MachinePoolStrategy struct {
+	// remediation controls the strategy of remediating unhealthy machines
+	// as marked by a MachineHealthCheck. This only applies to infrastructure
+	// providers supporting "MachinePool Machines". For other providers,
+	// no remediation is done.
+	// +optional
+	Remediation *RemediationStrategy `json:"remediation,omitempty"`
+}
+
 // MachinePoolStatus defines the observed state of MachinePool.
 type MachinePoolStatus struct {
 	// nodeRefs will point to the corresponding Nodes if it they exist.

api/core/v1beta1/zz_generated.conversion.go

@@ -19,6 +19,7 @@ package v1beta2
 import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/intstr"
 
 	capierrors "sigs.k8s.io/cluster-api/errors"
 )
@@ -97,6 +98,29 @@ type MachinePoolSpec struct {
 	// +kubebuilder:validation:items:MinLength=1
 	// +kubebuilder:validation:items:MaxLength=256
 	FailureDomains []string `json:"failureDomains,omitempty"`
+
+	// remediation controls how unhealthy Machines are remediated (through a MachineHealthCheck).
+	// This only applies to infrastructure providers supporting and enabling the
+	// "MachinePool Machines" feature. For other setups, no remediation is done.
+	// +optional
+	Remediation MachinePoolRemediationSpec `json:"remediation,omitempty,omitzero"`
+}
+
+// MachinePoolRemediationSpec controls how unhealthy Machines are remediated (through a MachineHealthCheck).
+// This only applies to infrastructure providers supporting and enabling the
+// "MachinePool Machines" feature. For other setups, no remediation is done.
+// +kubebuilder:validation:MinProperties=1
+type MachinePoolRemediationSpec struct {
+	// maxInFlight determines how many in flight remediations should happen at the same time.
+	//
+	// MaxInFlight can be set to a fixed number or a percentage.
+	// Example: when this is set to 20%, the MachinePool controller deletes at most 20% of
+	// the desired replicas.
+	//
+	// If not set, remediation is limited to all machines under the active MachinePool's management.
+	//
+	// +optional
+	MaxInFlight *intstr.IntOrString `json:"maxInFlight,omitempty"`
 }
 
 // MachinePoolStatus defines the observed state of MachinePool.