batches

Documentation

Index

• func GetBatchStatusFromJob(kubeClient kubernetes.Interface, job *v1.Job, jobPods []corev1.Pod) (*models.BatchStatus, error)
• type BatchHandler
  • func New(env *models.Env, kube *kube.Kube, kubeClient kubernetes.Interface, ...) BatchHandler

Functions

func GetBatchStatusFromJob

func GetBatchStatusFromJob(kubeClient kubernetes.Interface, job *v1.Job, jobPods []corev1.Pod) (*models.BatchStatus, error)

GetBatchStatusFromJob Gets job from a k8s jobs for the batch

Types

type BatchHandler

type BatchHandler interface {
	//GetBatches Get status of all batches
	GetBatches() ([]models.BatchStatus, error)
	//GetBatch Get status of a batch
	GetBatch(batchName string) (*models.BatchStatus, error)
	//CreateBatch Create a batch with parameters
	CreateBatch(batchScheduleDescription *models.BatchScheduleDescription) (*models.BatchStatus, error)
	//MaintainHistoryLimit Delete outdated batches
	MaintainHistoryLimit() error
	//DeleteBatch Delete a batch
	DeleteBatch(batchName string) error
}

func New

func New(env *models.Env, kube *kube.Kube, kubeClient kubernetes.Interface, radixClient radixclient.Interface) BatchHandler

New Constructor of the batch handler