jobs

Documentation

Index

• func BuildFromTemplate(yamlTemplate string, values interface{}) (*batchv1.Job, error)
• func CreateFromTemplate(yamlTemplate string, values interface{}) (jobName string, err error)
• func CreateOrReplace(j *batchv1.Job) (jobName string, err error)
• func Delete(name, namespace string) error
• func Deserialize(yaml []byte) (*batchv1.Job, error)
• func SanitizeJobName(name string) string
• func WaitUntilComplete(done <-chan struct{}, namespace, name string) (<-chan *batchv1.Job, <-chan error)
• func WaitUntilDeleted(done <-chan struct{}, namespace, name string) <-chan error

Functions

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