job

package

v0.25.1-rc.1 Latest Latest Go to latest Published: Nov 7, 2018 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func AreAllJobsCompleted(jobPrefix, namespace string) (bool, error)

AreAllJobsCompleted will return true if all jobs with a common prefix in a given namespace are in a Completed State

func WaitOnReady(jobPrefix, namespace string, sleep, duration time.Duration) (bool, error)

WaitOnReady is used when you dont have a handle on a job but want to wait until its in a Succeeded state.

type Job struct {
	Metadata pod.Metadata `json:"metadata"`
	Spec     Spec         `json:"spec"`
	Status   Status       `json:"status"`
}

Job is used to parse data from kubectl get jobs

func CreateJobFromFile(filename, name, namespace string) (*Job, error)

CreateJobFromFile will create a Job from file with a name

func Get(jobName, namespace string) (*Job, error)

Get will return a job with a given name and namespace

func (j *Job) Delete(retries int) error

Delete will delete a Job in a given namespace

func (j *Job) WaitOnReady(sleep, duration time.Duration) (bool, error)

WaitOnReady will call the static method WaitOnReady passing in p.Metadata.Name and p.Metadata.Namespace

type List struct {
	Jobs []Job `json:"items"`
}

List is a container that holds all jobs returned from doing a kubectl get jobs

func GetAll(namespace string) (*List, error)

GetAll will return all jobs in a given namespace

type Spec struct {
	Completions int `json:"completions"`
	Parallelism int `json:"parallelism"`
}

Spec holds job spec metadata

type Status struct {
	Active    int `json:"active"`
	Succeeded int `json:"succeeded"`
}

Status holds job status information