wip

Signed-off-by: 玖宇 <guotongyu.gty@alibaba-inc.com>

Author: 玖宇

pkg/ddc/thin/health_check.go

@@ -17,14 +17,6 @@
 package thin
 
 import (
-	"context"
-	"fmt"
-	"reflect"
-
-	data "github.com/fluid-cloudnative/fluid/api/v1alpha1"
-	"github.com/fluid-cloudnative/fluid/pkg/utils"
-	"github.com/fluid-cloudnative/fluid/pkg/utils/kubeclient"
-	v1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/util/retry"
 )
 
@@ -39,86 +31,6 @@ func (t ThinEngine) CheckRuntimeHealthy() (err error) {
 	return
 }
 
-// checkWorkersHealthy check workers number changed
-func (t *ThinEngine) checkWorkersHealthy() (err error) {
-	workerName := t.getWorkerName()
-
-	// Check the status of workers
-	workers, err := kubeclient.GetStatefulSet(t.Client, workerName, t.namespace)
-	if err != nil {
-		return err
-	}
-
-	healthy := false
-	err = retry.RetryOnConflict(retry.DefaultBackoff, func() error {
-
-		runtime, err := t.getRuntime()
-		if err != nil {
-			return err
-		}
-
-		runtimeToUpdate := runtime.DeepCopy()
-		if workers.Status.ReadyReplicas == 0 && *workers.Spec.Replicas > 0 {
-			if len(runtimeToUpdate.Status.Conditions) == 0 {
-				runtimeToUpdate.Status.Conditions = []data.RuntimeCondition{}
-			}
-			cond := utils.NewRuntimeCondition(data.RuntimeWorkersReady, "The workers are not ready.",
-				fmt.Sprintf("The statefulset %s in %s are not ready, the Unavailable number is %d, please fix it.",
-					workers.Name,
-					workers.Namespace,
-					*workers.Spec.Replicas-workers.Status.ReadyReplicas), v1.ConditionFalse)
-
-			_, oldCond := utils.GetRuntimeCondition(runtimeToUpdate.Status.Conditions, cond.Type)
-
-			if oldCond == nil || oldCond.Type != cond.Type {
-				runtimeToUpdate.Status.Conditions =
-					utils.UpdateRuntimeCondition(runtimeToUpdate.Status.Conditions,
-						cond)
-			}
-
-			runtimeToUpdate.Status.WorkerPhase = data.RuntimePhaseNotReady
-
-			t.Log.Error(err, "the workers are not ready")
-		} else {
-			healthy = true
-			cond := utils.NewRuntimeCondition(data.RuntimeWorkersReady, "The workers are ready.",
-				"The workers are ready", v1.ConditionTrue)
-
-			_, oldCond := utils.GetRuntimeCondition(runtimeToUpdate.Status.Conditions, cond.Type)
-
-			if oldCond == nil || oldCond.Type != cond.Type {
-				runtimeToUpdate.Status.Conditions =
-					utils.UpdateRuntimeCondition(runtimeToUpdate.Status.Conditions,
-						cond)
-			}
-		}
-		runtimeToUpdate.Status.WorkerNumberReady = workers.Status.ReadyReplicas
-		runtimeToUpdate.Status.WorkerNumberAvailable = workers.Status.CurrentReplicas
-		if !reflect.DeepEqual(runtime.Status, runtimeToUpdate.Status) {
-			updateErr := t.Client.Status().Update(context.TODO(), runtimeToUpdate)
-			if updateErr != nil {
-				return updateErr
-			}
-		}
-
-		return err
-	})
-
-	if err != nil {
-		t.Log.Error(err, "Failed update runtime")
-		return err
-	}
-
-	if !healthy {
-		err = fmt.Errorf("the workers %s in %s are not ready, the unhealthy number %d",
-			workers.Name,
-			workers.Namespace,
-			*workers.Spec.Replicas-workers.Status.ReadyReplicas)
-	}
-
-	return err
-}
-
 // checkFuseHealthy check fuses number changed
 func (t *ThinEngine) checkFuseHealthy() error {
 	return retry.RetryOnConflict(retry.DefaultBackoff, func() (err error) {

pkg/ddc/thin/util.go

@@ -65,10 +65,6 @@ func (t *ThinEngine) getFuseName() (dsName string) {
 	return t.name + "-fuse"
 }
 
-func (t *ThinEngine) getWorkerName() (dsName string) {
-	return t.name + "-worker"
-}
-
 func (t *ThinEngine) getTargetPath() (targetPath string) {
 	mountRoot := getMountRoot()
 	t.Log.Info("mountRoot", "path", mountRoot)