util

Documentation

Index

• func ContainersAreRetryable(pod *v1.Pod) bool
• func DiagnoseStuckPod(pod *v1.Pod, podEvents []*v1.Event) (retryable bool, message string)
• 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 ExtractPodFailedReason(pod *v1.Pod) string
• 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 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

Functions

func ContainersAreRetryable

func ContainersAreRetryable(pod *v1.Pod) bool

func DiagnoseStuckPod

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

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 ExtractPodFailedReason

func ExtractPodFailedReason(pod *v1.Pod) string

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 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(jobId string)
	Get(jobId string) *v1.Pod
	GetAll() []*v1.Pod
}

func NewTimeExpiringPodCache

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