Versions in this module Expand all Collapse all v1 v1.0.2 May 5, 2022 Changes in this version + func DeleteCollectionJob(client *kubernetes.Clientset, jobList []k8s.JobData) (err error) + func DeleteJob(client *kubernetes.Clientset, namespace, name string) (err error) + func FromCells(cells []dataselect.DataCell) []batch.Job + func ScaleJob(client *kubernetes.Clientset, namespace, name string, scaleNumber *int32) (err error) + func ToCells(std []batch.Job) []dataselect.DataCell + type Job struct + ContainerImages []string + InitContainerImages []string + JobStatus JobStatus + ObjectMeta k8s.ObjectMeta + Parallelism *int32 + PodStatus PodStatus + Pods k8scommon.PodInfo + TypeMeta k8s.TypeMeta + type JobCell batch.Job + func (self JobCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue + type JobDetail struct + Completions *int32 + PodList *PodList + Status []batch.JobCondition + func GetJobDetail(client *kubernetes.Clientset, namespace, name string) (*JobDetail, error) + type JobList struct + Errors []error + Jobs []Job + ListMeta k8s.ListMeta + Status k8scommon.ResourceStatus + func GetJobList(client *kubernetes.Clientset, nsQuery *k8scommon.NamespaceQuery, ...) (*JobList, error) + func GetJobListFromChannels(channels *k8scommon.ResourceChannels, dsQuery *dataselect.DataSelectQuery) (*JobList, error) + func ToJobList(jobs []batch.Job, pods []v1.Pod, events []v1.Event, ...) *JobList + type JobStatus struct + Conditions []k8scommon.Condition + Message string + Status JobStatusType + func GetJobStatus(job *batch.Job) JobStatus + type JobStatusType string + const JobStatusComplete + const JobStatusFailed + const JobStatusRunning + type PodList struct + ListMeta k8s.ListMeta + Pods []pods.Pod + Status k8scommon.ResourceStatus + type PodStatus struct + Active int32 + CompletionTime *meta.Time + Failed int32 + StartTime *meta.Time + Succeeded int32 + func GetPodStatus(job *batch.Job) PodStatus