util

Documentation

Index

• 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 FilterPodsWithPhase(pods []*v1.Pod, podPhase v1.PodPhase) []*v1.Pod
• func GetManagedPodSelector() labels.Selector
• func IsInTerminalState(pod *v1.Pod) bool
• func IsManagedPod(pod *v1.Pod) bool
• func IsReportingPhaseRequired(podPhase v1.PodPhase) bool
• func IsRetryable(pod *v1.Pod) bool
• 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 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 FilterPodsWithPhase

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

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 IsRetryable

func IsRetryable(pod *v1.Pod) bool

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