jobs

Documentation

Index

• func GetJobStatusFromJob(ctx context.Context, kubeClient kubernetes.Interface, job *v1.Job, ...) *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(ctx context.Context, 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(ctx context.Context) ([]modelsv1.JobStatus, error)
	// GetJob Get status of a job
	GetJob(ctx context.Context, jobName string) (*modelsv1.JobStatus, error)
	// CreateJob Create a job with parameters
	CreateJob(ctx context.Context, jobScheduleDescription *common.JobScheduleDescription) (*modelsv1.JobStatus, error)
	// CopyJob creates a copy of an existing job with deploymentName as value for radixDeploymentJobRef.name
	CopyJob(ctx context.Context, jobName string, deploymentName string) (*modelsv1.JobStatus, error)
	// MaintainHistoryLimit Delete outdated jobs
	MaintainHistoryLimit(ctx context.Context) error
	// DeleteJob Delete a job
	DeleteJob(ctx context.Context, jobName string) error
	// StopJob Stop a job
	StopJob(ctx context.Context, jobName string) error
}

func New

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

New Constructor for job handler