util

Documentation

Index

• func ExtractFailedPodContainerStatuses(pod *v1.Pod) []*api.ContainerStatus
• func ExtractJobId(pod *v1.Pod) string
• func ExtractJobIds(pods []*v1.Pod) []string
• func ExtractNames(pods []*v1.Pod) []string
• func ExtractPodExitCodes(pod *v1.Pod) map[string]int32
• func ExtractPodFailedCause(pod *v1.Pod) api.Cause
• func ExtractPodFailedReason(pod *v1.Pod) string
• func ExtractPodKey(pod *v1.Pod) string
• func ExtractPodNumber(pod *v1.Pod) int
• func ExtractPodStuckReason(pod *v1.Pod) string
• func FilterCompletedPods(pods []*v1.Pod) []*v1.Pod
• func FilterNonCompletedPods(pods []*v1.Pod) []*v1.Pod
• func FilterPods(pods []*v1.Pod, filter func(*v1.Pod) bool) []*v1.Pod
• func FilterPodsWithPhase(pods []*v1.Pod, podPhase v1.PodPhase) []*v1.Pod
• func FindLastContainerStartTime(pod *v1.Pod) time.Time
• func GetManagedPodSelector() labels.Selector
• func GetPodContainerStatuses(pod *v1.Pod) []v1.ContainerStatus
• func HasIngress(pod *v1.Pod) bool
• func IsInTerminalState(pod *v1.Pod) bool
• func IsManagedPod(pod *v1.Pod) bool
• func IsReportingPhaseRequired(podPhase v1.PodPhase) bool
• func LastStatusChange(pod *v1.Pod) (time.Time, error)
• func MergePodList(list1 []*v1.Pod, list2 []*v1.Pod) []*v1.Pod
• type PodCache
  • func NewTimeExpiringPodCache(expiry time.Duration, cleanUpInterval time.Duration, metricName string) PodCache
• type PodStartupStatus
  • func DiagnoseStuckPod(pod *v1.Pod, podEvents []*v1.Event) (status PodStartupStatus, message string)

Functions

func ExtractFailedPodContainerStatuses

func ExtractFailedPodContainerStatuses(pod *v1.Pod) []*api.ContainerStatus

func ExtractJobId

func ExtractJobId(pod *v1.Pod) string

func ExtractJobIds

func ExtractJobIds(pods []*v1.Pod) []string

func ExtractNames

func ExtractNames(pods []*v1.Pod) []string

func ExtractPodExitCodes

func ExtractPodExitCodes(pod *v1.Pod) map[string]int32

func ExtractPodFailedCause

func ExtractPodFailedCause(pod *v1.Pod) api.Cause

func ExtractPodFailedReason

func ExtractPodFailedReason(pod *v1.Pod) string

func ExtractPodKey

func ExtractPodKey(pod *v1.Pod) string

func ExtractPodNumber

func ExtractPodNumber(pod *v1.Pod) int

func ExtractPodStuckReason

func ExtractPodStuckReason(pod *v1.Pod) string

func FilterCompletedPods

func FilterCompletedPods(pods []*v1.Pod) []*v1.Pod

func FilterNonCompletedPods

func FilterNonCompletedPods(pods []*v1.Pod) []*v1.Pod

func FilterPods

func FilterPods(pods []*v1.Pod, filter func(*v1.Pod) bool) []*v1.Pod

func FilterPodsWithPhase

func FilterPodsWithPhase(pods []*v1.Pod, podPhase v1.PodPhase) []*v1.Pod

func FindLastContainerStartTime

func FindLastContainerStartTime(pod *v1.Pod) time.Time

func GetManagedPodSelector

func GetManagedPodSelector() labels.Selector

func GetPodContainerStatuses

func GetPodContainerStatuses(pod *v1.Pod) []v1.ContainerStatus

func HasIngress

func HasIngress(pod *v1.Pod) bool

func IsInTerminalState

func IsInTerminalState(pod *v1.Pod) bool

func IsManagedPod

func IsManagedPod(pod *v1.Pod) bool

func IsReportingPhaseRequired

func IsReportingPhaseRequired(podPhase v1.PodPhase) bool

func LastStatusChange

func LastStatusChange(pod *v1.Pod) (time.Time, error)

func MergePodList

func MergePodList(list1 []*v1.Pod, list2 []*v1.Pod) []*v1.Pod

Types

type PodCache

type PodCache interface {
	Add(pod *v1.Pod)
	AddIfNotExists(pod *v1.Pod) bool
	Update(key string, pod *v1.Pod) bool
	Delete(podId string)
	Get(podId string) *v1.Pod
	GetAll() []*v1.Pod
}

func NewTimeExpiringPodCache

func NewTimeExpiringPodCache(expiry time.Duration, cleanUpInterval time.Duration, metricName string) PodCache

type PodStartupStatus

type PodStartupStatus int

const (
	Healthy PodStartupStatus = iota
	Unstable
	Unrecoverable
)

func DiagnoseStuckPod

func DiagnoseStuckPod(pod *v1.Pod, podEvents []*v1.Event) (status PodStartupStatus, message string)