From 20bd43dbc26568b986892502d56fc4c9cac1f6f9 Mon Sep 17 00:00:00 2001 From: mgianluc Date: Wed, 13 Mar 2024 12:00:45 +0100 Subject: [PATCH] Detect cluster down If cluster is down, do not try to get the cluster version. --- controllers/sveltoscluster_controller.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/controllers/sveltoscluster_controller.go b/controllers/sveltoscluster_controller.go index 301bb56..64958dd 100644 --- a/controllers/sveltoscluster_controller.go +++ b/controllers/sveltoscluster_controller.go @@ -174,16 +174,16 @@ func (r *SveltosClusterReconciler) reconcileNormal( logger.V(logs.LogInfo).Info(fmt.Sprintf("failed to get projectsveltos namespace: %v", err)) sveltosClusterScope.SveltosCluster.Status.Ready = false sveltosClusterScope.SveltosCluster.Status.FailureMessage = &errorMessage - } - - currentVersion, err := utils.GetKubernetesVersion(ctx, config, logger) - if err != nil { - logger.V(logs.LogInfo).Info(fmt.Sprintf("failed to get cluster kubernetes version %v", err)) - errorMessage := err.Error() - sveltosClusterScope.SveltosCluster.Status.FailureMessage = &errorMessage } else { - sveltosClusterScope.SveltosCluster.Status.Version = currentVersion - logger.V(logs.LogDebug).Info(fmt.Sprintf("cluster version %s", currentVersion)) + currentVersion, err := utils.GetKubernetesVersion(ctx, config, logger) + if err != nil { + logger.V(logs.LogInfo).Info(fmt.Sprintf("failed to get cluster kubernetes version %v", err)) + errorMessage := err.Error() + sveltosClusterScope.SveltosCluster.Status.FailureMessage = &errorMessage + } else { + sveltosClusterScope.SveltosCluster.Status.Version = currentVersion + logger.V(logs.LogDebug).Info(fmt.Sprintf("cluster version %s", currentVersion)) + } } }