Versions in this module Expand all Collapse all v0 v0.4.7 Apr 25, 2023 Changes in this version + func CalculatePodSliceSize(pods []*v1.Pod, replicas int) int + func CalculateServiceSliceSize(services []*v1.Service, replicas int) int + func FilterPodsForReplicaType(pods []*v1.Pod, replicaType string) ([]*v1.Pod, error) + func FilterServicesForReplicaType(services []*v1.Service, replicaType string) ([]*v1.Service, error) + func GenGeneralName(jobName string, rtype string, index string) string + func GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod + func GetPortsFromJob(spec *apiv1.ReplicaSpec, defaultContainerName string) (map[string]int32, error) + func GetServiceSlices(services []*v1.Service, replicas int, logger *log.Entry) [][]*v1.Service + func InitializeReplicaStatuses(jobStatus *apiv1.JobStatus, rtype apiv1.ReplicaType) + func MaxInt(x, y int) int + func PastActiveDeadline(runPolicy *apiv1.RunPolicy, jobStatus apiv1.JobStatus) bool + func PastBackoffLimit(jobName string, runPolicy *apiv1.RunPolicy, ...) (bool, error) + func RecordAbnormalPods(activePods []*v1.Pod, object runtime.Object, recorder record.EventRecorder) + func SetRestartPolicy(podTemplateSpec *v1.PodTemplateSpec, spec *apiv1.ReplicaSpec) + func UpdateJobReplicaStatuses(jobStatus *apiv1.JobStatus, rtype apiv1.ReplicaType, pod *corev1.Pod)