func()

in deploy/kubernetes/operator/pkg/webhook/inspector/pod.go [104:135]

• 29 lines of code
• 12 McCabe index (conditional complexity)

func (i *inspector) ifShuffleServerCanBeDeleted(rss *unifflev1alpha1.RemoteShuffleService, pod *corev1.Pod) bool {
	if rss.Spec.ShuffleServer.Autoscaler.Enable {
		shuffleServerName := shuffleserver.GenerateName(rss)
		hpa, err := i.hpaLister.HorizontalPodAutoscalers(rss.Namespace).Get(shuffleServerName)
		if err != nil {
			klog.Errorf("failed to get hpa when hpa is enabled: %v", err)
			return false
		}
		var sts *appsv1.StatefulSet
		sts, err = i.stsLister.StatefulSets(rss.Namespace).Get(shuffleServerName)
		if err != nil {
			klog.Errorf("failed to get sts when hpa is enabled: %v", err)
			return false
		}
		// In this case, we have enabled HPA and HPA triggers the StatefulSet shrink, so we should allow deletion.
		if *sts.Spec.Replicas == hpa.Status.DesiredReplicas && *sts.Spec.Replicas < sts.Status.Replicas {
			return true
		}
	}
	// At this moment, the Pod has not been scheduled and can be deleted.
	if pod.Status.Phase == corev1.PodPending && len(pod.Spec.NodeName) == 0 {
		return true
	}
	// At this moment, the Pod has stopped and can be deleted.
	if pod.Status.Phase == corev1.PodFailed || pod.Status.Phase == corev1.PodSucceeded {
		return true
	}
	if rss.Status.Phase != unifflev1alpha1.RSSUpgrading && rss.Status.Phase != unifflev1alpha1.RSSTerminating {
		return false
	}
	return true
}