util

package

v0.2.3 Latest Latest Go to latest Published: Aug 4, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/G-Research/armada

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateIngress(name string, job *api.Job, pod *v1.Pod, service *v1.Service, ...) *networking.Ingress
func CreateOwnerReference(pod *v1.Pod) metav1.OwnerReference
func CreatePod(job *api.Job, defaults *configuration.PodDefaults, i int) *v1.Pod
func CreateService(job *api.Job, pod *v1.Pod, ports []v1.ServicePort, ingressType api.IngressType) *v1.Service
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 ExtractQueue(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 GenerateIngresses(job *api.Job, pod *v1.Pod, ingressConfig *configuration.IngressConfiguration) ([]*v1.Service, []*networking.Ingress)
func GetExpectedNumberOfAssociatedIngresses(pod *v1.Pod) int
func GetExpectedNumberOfAssociatedServices(pod *v1.Pod) int
func GetManagedPodSelector() labels.Selector
func GetPodContainerStatuses(pod *v1.Pod) []v1.ContainerStatus
func GetServicePorts(ingressConfigs []*api.IngressConfig, podSpec *v1.PodSpec) []v1.ServicePort
func HasCurrentStateBeenReported(pod *v1.Pod) bool
func HasIngress(pod *v1.Pod) bool
func IsInTerminalState(pod *v1.Pod) bool
func IsManagedPod(pod *v1.Pod) bool
func IsMarkedForDeletion(pod *v1.Pod) bool
func IsPodFinishedAndReported(pod *v1.Pod) bool
func IsReportedDone(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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateIngress ¶ added in v0.2.3

func CreateIngress(name string, job *api.Job, pod *v1.Pod, service *v1.Service, executorIngressConfig *configuration.IngressConfiguration, jobConfig *api.IngressConfig) *networking.Ingress

func CreateOwnerReference ¶ added in v0.2.3

func CreateOwnerReference(pod *v1.Pod) metav1.OwnerReference

func CreatePod ¶ added in v0.2.3

func CreatePod(job *api.Job, defaults *configuration.PodDefaults, i int) *v1.Pod

func CreateService ¶ added in v0.2.3

func CreateService(job *api.Job, pod *v1.Pod, ports []v1.ServicePort, ingressType api.IngressType) *v1.Service

func ExtractFailedPodContainerStatuses ¶ added in v0.1.24

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 ¶ added in v0.0.6

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

func ExtractPodFailedCause ¶ added in v0.1.24

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

func ExtractPodFailedReason ¶

func ExtractPodFailedReason(pod *v1.Pod) string

func ExtractPodKey ¶ added in v0.1.23

func ExtractPodKey(pod *v1.Pod) string

func ExtractPodNumber ¶ added in v0.1.23

func ExtractPodNumber(pod *v1.Pod) int

func ExtractPodStuckReason ¶

func ExtractPodStuckReason(pod *v1.Pod) string

func ExtractQueue ¶ added in v0.2.3

func ExtractQueue(pod *v1.Pod) string

func FilterCompletedPods ¶

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

func FilterNonCompletedPods ¶

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

func FilterPods ¶ added in v0.0.11

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 ¶ added in v0.0.11

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

func GenerateIngresses ¶ added in v0.2.3

func GenerateIngresses(job *api.Job, pod *v1.Pod, ingressConfig *configuration.IngressConfiguration) ([]*v1.Service, []*networking.Ingress)

func GetExpectedNumberOfAssociatedIngresses ¶ added in v0.2.3

func GetExpectedNumberOfAssociatedIngresses(pod *v1.Pod) int

func GetExpectedNumberOfAssociatedServices ¶ added in v0.2.3

func GetExpectedNumberOfAssociatedServices(pod *v1.Pod) int

func GetManagedPodSelector ¶

func GetManagedPodSelector() labels.Selector

func GetPodContainerStatuses ¶ added in v0.1.41

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

func GetServicePorts ¶ added in v0.2.3

func GetServicePorts(ingressConfigs []*api.IngressConfig, podSpec *v1.PodSpec) []v1.ServicePort

func HasCurrentStateBeenReported ¶ added in v0.2.3

func HasCurrentStateBeenReported(pod *v1.Pod) bool

func HasIngress ¶ added in v0.1.34

func HasIngress(pod *v1.Pod) bool

func IsInTerminalState ¶

func IsInTerminalState(pod *v1.Pod) bool

func IsManagedPod ¶

func IsManagedPod(pod *v1.Pod) bool

func IsMarkedForDeletion ¶ added in v0.2.3

func IsMarkedForDeletion(pod *v1.Pod) bool

func IsPodFinishedAndReported ¶ added in v0.2.3

func IsPodFinishedAndReported(pod *v1.Pod) bool

func IsReportedDone ¶ added in v0.2.3

func IsReportedDone(pod *v1.Pod) bool

func IsReportingPhaseRequired ¶

func IsReportingPhaseRequired(podPhase v1.PodPhase) bool

func LastStatusChange ¶ added in v0.0.11

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 ¶ added in v0.1.41

type PodStartupStatus int

const (
	Healthy PodStartupStatus = iota
	Unstable
	Unrecoverable
)

func DiagnoseStuckPod ¶ added in v0.1.2

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL