Skip to content

Commit debaad5

Browse files
committed
Fix review findings
1 parent dc9d019 commit debaad5

File tree

2 files changed

+26
-22
lines changed

2 files changed

+26
-22
lines changed

controlplane/kubeadm/internal/controllers/controller.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -641,7 +641,7 @@ func (r *KubeadmControlPlaneReconciler) reconcileDelete(ctx context.Context, con
641641
conditions.MarkFalse(controlPlane.KCP, controlplanev1.ResizedCondition, clusterv1.DeletingReason, clusterv1.ConditionSeverityInfo, "Waiting for worker nodes to be deleted first")
642642

643643
controlPlane.DeletingReason = controlplanev1.KubeadmControlPlaneDeletingWaitingForWorkersDeletionV1Beta2Reason
644-
controlPlane.DeletingMessage = objectsPendingDeleteNames(allMachines, allMachinePools, controlPlane.Cluster)
644+
controlPlane.DeletingMessage = fmt.Sprintf("KCP deletion blocked because %s still exist", objectsPendingDeleteNames(allMachines, allMachinePools, controlPlane.Cluster))
645645
return ctrl.Result{RequeueAfter: deleteRequeueAfter}, nil
646646
}
647647

@@ -727,7 +727,7 @@ func objectsPendingDeleteNames(allMachines collections.Machines, allMachinePools
727727
}
728728
if len(workerMachineNames) > 0 {
729729
sort.Strings(workerMachineNames)
730-
descendants = append(descendants, "Worker Machines: "+clog.StringListToString(workerMachineNames))
730+
descendants = append(descendants, "worker Machines: "+clog.StringListToString(workerMachineNames))
731731
}
732732
return strings.Join(descendants, "; ")
733733
}

controlplane/kubeadm/internal/controllers/controller_test.go

Lines changed: 24 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -3079,18 +3079,20 @@ func TestKubeadmControlPlaneReconciler_reconcileDelete(t *testing.T) {
30793079
cluster, kcp, _ := createClusterWithControlPlane(metav1.NamespaceDefault)
30803080
controllerutil.AddFinalizer(kcp, controlplanev1.KubeadmControlPlaneFinalizer)
30813081

3082-
workerMachine := &clusterv1.Machine{
3083-
ObjectMeta: metav1.ObjectMeta{
3084-
Name: "worker",
3085-
Namespace: cluster.Namespace,
3086-
Labels: map[string]string{
3087-
clusterv1.ClusterNameLabel: cluster.Name,
3082+
initObjs := []client.Object{cluster.DeepCopy(), kcp.DeepCopy()}
3083+
3084+
for i := range 10 {
3085+
initObjs = append(initObjs, &clusterv1.Machine{
3086+
ObjectMeta: metav1.ObjectMeta{
3087+
Name: fmt.Sprintf("worker-%d", i),
3088+
Namespace: cluster.Namespace,
3089+
Labels: map[string]string{
3090+
clusterv1.ClusterNameLabel: cluster.Name,
3091+
},
30883092
},
3089-
},
3093+
})
30903094
}
30913095

3092-
initObjs := []client.Object{cluster.DeepCopy(), kcp.DeepCopy(), workerMachine.DeepCopy()}
3093-
30943096
machines := collections.New()
30953097
for i := range 3 {
30963098
m, _ := createMachineNodePair(fmt.Sprintf("test-%d", i), cluster, kcp, true)
@@ -3121,7 +3123,7 @@ func TestKubeadmControlPlaneReconciler_reconcileDelete(t *testing.T) {
31213123
g.Expect(err).ToNot(HaveOccurred())
31223124
g.Expect(kcp.Finalizers).To(ContainElement(controlplanev1.KubeadmControlPlaneFinalizer))
31233125
g.Expect(controlPlane.DeletingReason).To(Equal(controlplanev1.KubeadmControlPlaneDeletingWaitingForWorkersDeletionV1Beta2Reason))
3124-
g.Expect(controlPlane.DeletingMessage).To(Equal("Worker Machines: worker"))
3126+
g.Expect(controlPlane.DeletingMessage).To(Equal("KCP deletion blocked because worker Machines: worker-0, worker-1, worker-2, worker-3, worker-4, ... (5 more) still exist"))
31253127

31263128
controlPlaneMachines := clusterv1.MachineList{}
31273129
labels := map[string]string{
@@ -3138,18 +3140,20 @@ func TestKubeadmControlPlaneReconciler_reconcileDelete(t *testing.T) {
31383140
cluster, kcp, _ := createClusterWithControlPlane(metav1.NamespaceDefault)
31393141
controllerutil.AddFinalizer(kcp, controlplanev1.KubeadmControlPlaneFinalizer)
31403142

3141-
workerMachinePool := &expv1.MachinePool{
3142-
ObjectMeta: metav1.ObjectMeta{
3143-
Name: "worker",
3144-
Namespace: cluster.Namespace,
3145-
Labels: map[string]string{
3146-
clusterv1.ClusterNameLabel: cluster.Name,
3143+
initObjs := []client.Object{cluster.DeepCopy(), kcp.DeepCopy()}
3144+
3145+
for i := range 10 {
3146+
initObjs = append(initObjs, &expv1.MachinePool{
3147+
ObjectMeta: metav1.ObjectMeta{
3148+
Name: fmt.Sprintf("mp-%d", i),
3149+
Namespace: cluster.Namespace,
3150+
Labels: map[string]string{
3151+
clusterv1.ClusterNameLabel: cluster.Name,
3152+
},
31473153
},
3148-
},
3154+
})
31493155
}
31503156

3151-
initObjs := []client.Object{cluster.DeepCopy(), kcp.DeepCopy(), workerMachinePool.DeepCopy()}
3152-
31533157
machines := collections.New()
31543158
for i := range 3 {
31553159
m, _ := createMachineNodePair(fmt.Sprintf("test-%d", i), cluster, kcp, true)
@@ -3180,7 +3184,7 @@ func TestKubeadmControlPlaneReconciler_reconcileDelete(t *testing.T) {
31803184
g.Expect(err).ToNot(HaveOccurred())
31813185
g.Expect(kcp.Finalizers).To(ContainElement(controlplanev1.KubeadmControlPlaneFinalizer))
31823186
g.Expect(controlPlane.DeletingReason).To(Equal(controlplanev1.KubeadmControlPlaneDeletingWaitingForWorkersDeletionV1Beta2Reason))
3183-
g.Expect(controlPlane.DeletingMessage).To(Equal("MachinePools: worker"))
3187+
g.Expect(controlPlane.DeletingMessage).To(Equal("KCP deletion blocked because MachinePools: mp-0, mp-1, mp-2, mp-3, mp-4, ... (5 more) still exist"))
31843188

31853189
controlPlaneMachines := clusterv1.MachineList{}
31863190
labels := map[string]string{

0 commit comments

Comments
 (0)