Method CheckAndSyncFuseStatus

pkg/ctrl/fuse.go:38–82

(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), fuseDsNamespacedName types.NamespacedName)

)

func (e *Helper) CheckAndSyncFuseStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), fuseDsNamespacedName types.NamespacedName) (ready bool, err error) {
	fuseDs, err := kubeclient.GetDaemonset(e.client, fuseDsNamespacedName.Name, fuseDsNamespacedName.Namespace)
	if err != nil {
		return
	}

	err = retry.RetryOnConflict(retry.DefaultBackoff, func() error {
		runtime, err := getRuntimeFn(e.client)
		if err != nil {
			return err
		}

		oldStatus := runtime.GetStatus().DeepCopy()
		statusToUpdate := runtime.GetStatus()

		statusToUpdate.DesiredFuseNumberScheduled = fuseDs.Status.DesiredNumberScheduled
		statusToUpdate.CurrentFuseNumberScheduled = fuseDs.Status.CurrentNumberScheduled
		statusToUpdate.FuseNumberReady = fuseDs.Status.NumberReady
		statusToUpdate.FuseNumberAvailable = fuseDs.Status.NumberAvailable
		statusToUpdate.FuseNumberUnavailable = fuseDs.Status.NumberUnavailable

		// fluid assumes fuse components are always ready
		statusToUpdate.FusePhase = datav1alpha1.RuntimePhaseReady
		ready = true

		if len(statusToUpdate.Conditions) == 0 {
			statusToUpdate.Conditions = []datav1alpha1.RuntimeCondition{}
		}
		cond := utils.NewRuntimeCondition(datav1alpha1.RuntimeFusesReady, datav1alpha1.RuntimeFusesReadyReason, "The fuses are ready.", corev1.ConditionTrue)
		statusToUpdate.FuseReason = cond.Reason
		statusToUpdate.Conditions = utils.UpdateRuntimeCondition(statusToUpdate.Conditions, cond)

		if !reflect.DeepEqual(oldStatus, statusToUpdate) {
			return e.client.Status().Update(context.TODO(), runtime)
		}

		return nil
	})

	if err != nil {
		return false, errors.Wrapf(err, "failed to update fuse ready status in runtime status")
	}

	return ready, nil
}

// CleanUpFuse will cleanup node label for Fuse.
func (e *Helper) CleanUpFuse() (count int, err error) {