func()

in controllers/dsmaster_controller.go [302:321]

• 19 lines of code
• 5 McCabe index (conditional complexity)

func (r *DSMasterReconciler) ensureUpgraded(ctx context.Context, cluster *dsv1alpha1.DSMaster) (bool, error) {
	ms, err := r.podMemberSet(ctx, cluster)
	if err != nil {
		return false, err
	}

	masterLogger.Info("cluster.Spec.Version", "cluster.Spec.Version", cluster.Spec.Version)
	for _, memset := range ms {
		if r.predicateUpdate(memset, cluster) {
			pod := &corev1.Pod{}
			pod.SetName(memset.Name)
			pod.SetNamespace(memset.Namespace)
			if err := r.deletePod(ctx, pod); err != nil {
				return false, err
			}
			return true, nil
		}
	}
	return false, nil
}