jobs

Documentation

Index

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

Functions

func GetJobStatusFromJob

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

GetJobStatusFromJob Gets job from a k8s job

func GetSingleJobStatusFromRadixBatchJob

func GetSingleJobStatusFromRadixBatchJob(radixBatch *modelsv2.RadixBatch) (*modelsv1.JobStatus, error)

GetSingleJobStatusFromRadixBatchJob Gets job status from RadixBatch

Types

type JobHandler

type JobHandler interface {
	//GetJobs Get status of all jobs
	GetJobs() ([]modelsv1.JobStatus, error)
	//GetJob Get status of a job
	GetJob(string) (*modelsv1.JobStatus, error)
	//CreateJob Create a job with parameters
	CreateJob(*common.JobScheduleDescription) (*modelsv1.JobStatus, error)
	//MaintainHistoryLimit Delete outdated jobs
	MaintainHistoryLimit() error
	//DeleteJob Delete a job
	DeleteJob(string) error
	//StopJob Stop a job
	StopJob(string) error
}

func New

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

New Constructor for job handler