[fix] restore pause handling during pivot (#1063)

* fix: restore pause handling during pivot

* fix: bump Go toolchain to 1.25.9

* Add e2e test to assert cluster.spec.pause will set pause conditions on linode resource. Unpause as well when Cluster is unpaused.

* fix: watch pause annotation updates

Author: komer3

.github/filters.yml

@@ -29,6 +29,9 @@ kubeadm-flatcar:
  - templates/flavors/kubeadm/flatcar/*
  - e2e/capl-cluster-flavors/kubeadm-flatcar-vpcless-capl-cluster/*
 
+cluster-pause:
+  - e2e/cluster-pause/*
+
 #k3s:
 #  - templates/flavors/k3s/default/*
 #  - e2e/capl-cluster-flavors/k3s-capl-cluster/*

.github/workflows/e2e-test.yaml

@@ -24,6 +24,7 @@ on:
         required: true
         options:
           - quick
+          - cluster-pause
           - flavors
           - k3s
           - rke2

api/v1alpha2/linodecluster_types.go

@@ -123,6 +123,20 @@ type LinodeCluster struct {
 	Status LinodeClusterStatus `json:"status,omitempty"`
 }
 
+func (lc *LinodeCluster) GetConditions() []metav1.Condition {
+	for i := range lc.Status.Conditions {
+		if lc.Status.Conditions[i].Reason == "" {
+			lc.Status.Conditions[i].Reason = DefaultConditionReason
+		}
+	}
+
+	return lc.Status.Conditions
+}
+
+func (lc *LinodeCluster) SetConditions(conditions []metav1.Condition) {
+	lc.Status.Conditions = conditions
+}
+
 func (lc *LinodeCluster) SetCondition(cond metav1.Condition) {
 	if cond.LastTransitionTime.IsZero() {
 		cond.LastTransitionTime = metav1.Now()

api/v1alpha2/linodefirewall_types.go

@@ -156,6 +156,20 @@ type LinodeFirewall struct {
 	Status LinodeFirewallStatus `json:"status,omitempty"`
 }
 
+func (lfw *LinodeFirewall) GetConditions() []metav1.Condition {
+	for i := range lfw.Status.Conditions {
+		if lfw.Status.Conditions[i].Reason == "" {
+			lfw.Status.Conditions[i].Reason = DefaultConditionReason
+		}
+	}
+
+	return lfw.Status.Conditions
+}
+
+func (lfw *LinodeFirewall) SetConditions(conditions []metav1.Condition) {
+	lfw.Status.Conditions = conditions
+}
+
 func (lfw *LinodeFirewall) SetCondition(cond metav1.Condition) {
 	if cond.LastTransitionTime.IsZero() {
 		cond.LastTransitionTime = metav1.Now()

api/v1alpha2/linodemachine_types.go

@@ -610,6 +610,20 @@ type LinodeMachine struct {
 	Status LinodeMachineStatus `json:"status,omitempty"`
 }
 
+func (lm *LinodeMachine) GetConditions() []metav1.Condition {
+	for i := range lm.Status.Conditions {
+		if lm.Status.Conditions[i].Reason == "" {
+			lm.Status.Conditions[i].Reason = DefaultConditionReason
+		}
+	}
+
+	return lm.Status.Conditions
+}
+
+func (lm *LinodeMachine) SetConditions(conditions []metav1.Condition) {
+	lm.Status.Conditions = conditions
+}
+
 func (lm *LinodeMachine) SetCondition(cond metav1.Condition) {
 	if cond.LastTransitionTime.IsZero() {
 		cond.LastTransitionTime = metav1.Now()

api/v1alpha2/linodeplacementgroup_types.go

@@ -135,6 +135,20 @@ type LinodePlacementGroup struct {
 	Status LinodePlacementGroupStatus `json:"status,omitempty"`
 }
 
+func (lpg *LinodePlacementGroup) GetConditions() []metav1.Condition {
+	for i := range lpg.Status.Conditions {
+		if lpg.Status.Conditions[i].Reason == "" {
+			lpg.Status.Conditions[i].Reason = DefaultConditionReason
+		}
+	}
+
+	return lpg.Status.Conditions
+}
+
+func (lpg *LinodePlacementGroup) SetConditions(conditions []metav1.Condition) {
+	lpg.Status.Conditions = conditions
+}
+
 func (lpg *LinodePlacementGroup) SetCondition(cond metav1.Condition) {
 	if cond.LastTransitionTime.IsZero() {
 		cond.LastTransitionTime = metav1.Now()

api/v1alpha2/linodevpc_types.go

@@ -217,6 +217,20 @@ type LinodeVPC struct {
 	Status LinodeVPCStatus `json:"status,omitempty"`
 }
 
+func (lv *LinodeVPC) GetConditions() []metav1.Condition {
+	for i := range lv.Status.Conditions {
+		if lv.Status.Conditions[i].Reason == "" {
+			lv.Status.Conditions[i].Reason = DefaultConditionReason
+		}
+	}
+
+	return lv.Status.Conditions
+}
+
+func (lv *LinodeVPC) SetConditions(conditions []metav1.Condition) {
+	lv.Status.Conditions = conditions
+}
+
 func (lv *LinodeVPC) SetCondition(cond metav1.Condition) {
 	if cond.LastTransitionTime.IsZero() {
 		cond.LastTransitionTime = metav1.Now()

e2e/cluster-pause/assert-capi-resources.yaml

@@ -0,0 +1,39 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: capi-controller-manager
+  namespace: capi-system
+status:
+  availableReplicas: 1
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: capl-controller-manager
+  namespace: capl-system
+status:
+  availableReplicas: 1
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: capi-kubeadm-bootstrap-controller-manager
+  namespace: capi-kubeadm-bootstrap-system
+status:
+  availableReplicas: 1
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: capi-kubeadm-control-plane-controller-manager
+  namespace: capi-kubeadm-control-plane-system
+status:
+  availableReplicas: 1
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: caaph-controller-manager
+  namespace: caaph-system
+status:
+  availableReplicas: 1

e2e/cluster-pause/assert-child-cluster-daemonsets.yaml

@@ -0,0 +1,35 @@
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: ccm-linode
+  namespace: kube-system
+status:
+  currentNumberScheduled: 1
+  desiredNumberScheduled: 1
+  numberAvailable: 1
+  numberMisscheduled: 0
+  numberReady: 1
+---
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: cilium
+  namespace: kube-system
+status:
+  currentNumberScheduled: 2
+  desiredNumberScheduled: 2
+  numberAvailable: 2
+  numberMisscheduled: 0
+  numberReady: 2
+---
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: csi-linode-node
+  namespace: kube-system
+status:
+  currentNumberScheduled: 2
+  desiredNumberScheduled: 2
+  numberAvailable: 2
+  numberMisscheduled: 0
+  numberReady: 2

e2e/cluster-pause/assert-child-cluster-deployments.yaml

@@ -0,0 +1,26 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: cilium-operator
+  namespace: kube-system
+status:
+  availableReplicas: 2
+  readyReplicas: 2
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  labels:
+    app.kubernetes.io/part-of: cilium
+  namespace: kube-system
+status:
+  readyReplicas: 1
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: coredns
+  namespace: kube-system
+status:
+  availableReplicas: 2
+  readyReplicas: 2