pkg/cloudmap/utils.go

package cloudmap

import (
	corev1 "k8s.io/api/core/v1"
)

func ArePodContainersReady(pod *corev1.Pod) bool {
	conditions := (&pod.Status).Conditions
	for i := range conditions {
		if conditions[i].Type == corev1.ContainersReady && conditions[i].Status == corev1.ConditionTrue {
			return true
		}
	}
	return false
}

func ShouldPodBeInEndpoints(pod *corev1.Pod) bool {
	switch pod.Spec.RestartPolicy {
	case corev1.RestartPolicyNever:
		return pod.Status.Phase != corev1.PodFailed && pod.Status.Phase != corev1.PodSucceeded
	case corev1.RestartPolicyOnFailure:
		return pod.Status.Phase != corev1.PodSucceeded
	default:
		return true
	}
}