Improve Cluster RemoteConnectionProbe condition

Signed-off-by: Stefan Büringer [email protected]
kubernetes-sigs · Nov 13, 2024 · aa55734 · aa55734
1 parent 1cd1543
commit aa55734
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 40 deletions.
diff --git a/api/v1beta1/cluster_types.go b/api/v1beta1/cluster_types.go
@@ -228,10 +228,10 @@ const (
 	ClusterRemoteConnectionProbeV1Beta2Condition = "RemoteConnectionProbe"
 
 	// ClusterRemoteConnectionProbeFailedV1Beta2Reason surfaces issues with the connection to the workload cluster.
-	ClusterRemoteConnectionProbeFailedV1Beta2Reason = "RemoteConnectionProbeFailed"
+	ClusterRemoteConnectionProbeFailedV1Beta2Reason = "ProbeFailed"
 
 	// ClusterRemoteConnectionProbeSucceededV1Beta2Reason is used to report a working connection with the workload cluster.
-	ClusterRemoteConnectionProbeSucceededV1Beta2Reason = "RemoteConnectionProbeSucceeded"
+	ClusterRemoteConnectionProbeSucceededV1Beta2Reason = "ProbeSucceeded"
 )
 
 // Cluster's ScalingUp condition and corresponding reasons that will be used in v1Beta2 API version.

diff --git a/internal/controllers/cluster/cluster_controller.go b/internal/controllers/cluster/cluster_controller.go
@@ -193,10 +193,9 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (retRes ct
 		})
 	} else {
 		v1beta2conditions.Set(cluster, metav1.Condition{
-			Type:    clusterv1.ClusterRemoteConnectionProbeV1Beta2Condition,
-			Status:  metav1.ConditionTrue,
-			Reason:  clusterv1.ClusterRemoteConnectionProbeSucceededV1Beta2Reason,
-			Message: remoteConnectionProbeSucceededMessage,
+			Type:   clusterv1.ClusterRemoteConnectionProbeV1Beta2Condition,
+			Status: metav1.ConditionTrue,
+			Reason: clusterv1.ClusterRemoteConnectionProbeSucceededV1Beta2Reason,
 		})
 	}
 

diff --git a/internal/controllers/cluster/cluster_controller_status.go b/internal/controllers/cluster/cluster_controller_status.go
@@ -901,10 +901,6 @@ func setAvailableCondition(ctx context.Context, cluster *clusterv1.Cluster) {
 		overrideConditions = append(overrideConditions, *controlPlaneAvailableCondition)
 	}
 
-	if remoteConnectionProbeCondition := calculateRemoteConnectionProbeForSummary(cluster); remoteConnectionProbeCondition != nil {
-		overrideConditions = append(overrideConditions, *remoteConnectionProbeCondition)
-	}
-
 	if len(overrideConditions) > 0 {
 		summaryOpts = append(summaryOpts, overrideConditions)
 	}
@@ -985,31 +981,6 @@ func calculateControlPlaneAvailableForSummary(cluster *clusterv1.Cluster) *v1bet
 	}
 }
 
-func calculateRemoteConnectionProbeForSummary(cluster *clusterv1.Cluster) *v1beta2conditions.ConditionWithOwnerInfo {
-	remoteConnectionProbeCondition := v1beta2conditions.Get(cluster, clusterv1.ClusterRemoteConnectionProbeV1Beta2Condition)
-	if remoteConnectionProbeCondition == nil {
-		return nil
-	}
-
-	message := remoteConnectionProbeCondition.Message
-	if remoteConnectionProbeCondition.Status == metav1.ConditionTrue && remoteConnectionProbeCondition.Message == remoteConnectionProbeSucceededMessage {
-		message = ""
-	}
-
-	return &v1beta2conditions.ConditionWithOwnerInfo{
-		OwnerResource: v1beta2conditions.ConditionOwnerInfo{
-			Kind: "Cluster",
-			Name: cluster.Name,
-		},
-		Condition: metav1.Condition{
-			Type:    remoteConnectionProbeCondition.Type,
-			Status:  remoteConnectionProbeCondition.Status,
-			Reason:  remoteConnectionProbeCondition.Reason,
-			Message: message,
-		},
-	}
-}
-
 func aggregateUnhealthyMachines(machines collections.Machines) string {
 	if len(machines) == 0 {
 		return ""

diff --git a/internal/controllers/cluster/cluster_controller_status_test.go b/internal/controllers/cluster/cluster_controller_status_test.go
@@ -1890,7 +1890,7 @@ func TestSetAvailableCondition(t *testing.T) {
 			},
 		},
 		{
-			name: "Drops messages from InfraCluster and ControlPlane when using fallback to fields; drop message from RemoteConnectionProbe when true",
+			name: "Drops messages from InfraCluster and ControlPlane when using fallback to fields",
 			cluster: &clusterv1.Cluster{
 				ObjectMeta: metav1.ObjectMeta{
 					Name:      "machine-test",
@@ -1923,10 +1923,9 @@ func TestSetAvailableCondition(t *testing.T) {
 								Reason: "Foo",
 							},
 							{
-								Type:    clusterv1.ClusterRemoteConnectionProbeV1Beta2Condition,
-								Status:  metav1.ConditionTrue,
-								Reason:  clusterv1.ClusterRemoteConnectionProbeSucceededV1Beta2Reason,
-								Message: remoteConnectionProbeSucceededMessage,
+								Type:   clusterv1.ClusterRemoteConnectionProbeV1Beta2Condition,
+								Status: metav1.ConditionTrue,
+								Reason: clusterv1.ClusterRemoteConnectionProbeSucceededV1Beta2Reason,
 							},
 							{
 								Type:   clusterv1.ClusterDeletingV1Beta2Condition,