jobs

Documentation

Index

• func GetJobStatusFromJob(kubeClient kubernetes.Interface, job *v1.Job, jobPods []corev1.Pod) *models.JobStatus
• type JobHandler
  • func New(env *models.Env, kube *kube.Kube) JobHandler

Functions

func GetJobStatusFromJob

func GetJobStatusFromJob(kubeClient kubernetes.Interface, job *v1.Job, jobPods []corev1.Pod) *models.JobStatus

GetJobStatusFromJob Gets job from a k8s job

Types

type JobHandler

type JobHandler interface {
	//GetJobs Get status of all jobs
	GetJobs() ([]models.JobStatus, error)
	//GetJob Get status of a job
	GetJob(name string) (*models.JobStatus, error)
	//CreateJob Create a job with parameters. `batchName` is optional.
	CreateJob(jobScheduleDescription *models.JobScheduleDescription, batchName string) (*models.JobStatus, error)
	//MaintainHistoryLimit Delete outdated jobs
	MaintainHistoryLimit() error
	//DeleteJob Delete a job
	DeleteJob(jobName string) error
}

func New

func New(env *models.Env, kube *kube.Kube) JobHandler

New Constructor for job handler