jobs

func BuildFromTemplate ¶

func BuildFromTemplate(yamlTemplate string, values interface{}) (*batchv1.Job, error)

BuildFromTemplate builds a job definition from a template and set of replacement values.

func CreateFromTemplate ¶

func CreateFromTemplate(yamlTemplate string, values interface{}) (jobName string, err error)

CreateFromTemplate creates a job on the current cluster from a template and set of replacement values.

func CreateOrReplace ¶

func CreateOrReplace(j *batchv1.Job) (jobName string, err error)

func Delete ¶

func Delete(name, namespace string) error

Delete a job.

func Deserialize ¶

func Deserialize(yaml []byte) (*batchv1.Job, error)

Deserialize reads a job definition from yaml.

func SanitizeJobName ¶

func SanitizeJobName(name string) string

SanitizeJobName replaces characters that aren't allowed in a k8s name with dashes.

func WaitUntilComplete ¶

func WaitUntilComplete(done <-chan struct{}, namespace, name string) (<-chan *batchv1.Job, <-chan error)

func WaitUntilDeleted ¶

func WaitUntilDeleted(done <-chan struct{}, namespace, name string) <-chan error