v1

Documentation

Index

• func GetBatchJobStatusFromRadixBatchJobsStatuses(radixBatches ...modelsv2.RadixBatch) []modelsv1.JobStatus
• func GetJobStatusFromRadixBatchJobsStatus(batchName string, jobStatus modelsv2.RadixBatchJobStatus) modelsv1.JobStatus
• func GetLabelSelectorForBatches(componentName string) string
• func GetPodsToJobNameMap(pods []corev1.Pod) map[string][]corev1.Pod
• func GetSingleJobStatusFromRadixBatchJobsStatuses(radixBatches ...modelsv2.RadixBatch) []modelsv1.JobStatus
• func ParseBatchAndJobNameFromScheduledJobName(scheduleJobName string) (batchName, batchJobName string, ok bool)
• func StopJob(handlerApiV2 apiv2.Handler, jobName string) error
• type Handler
  • func (handler *Handler) DeleteSecret(secret *corev1.Secret) error
  • func (handler *Handler) DeleteService(service *corev1.Service) error
  • func (handler *Handler) GetBatch(batchName string) (*batchv1.Job, error)
  • func (handler *Handler) GetPodsForLabelSelector(labelSelector string) ([]corev1.Pod, error)
  • func (handler *Handler) GetSecretsForJob(jobName string) (*corev1.SecretList, error)
  • func (handler *Handler) GetServiceForJob(jobName string) (*corev1.ServiceList, error)

Functions

func GetBatchJobStatusFromRadixBatchJobsStatuses

func GetBatchJobStatusFromRadixBatchJobsStatuses(radixBatches ...modelsv2.RadixBatch) []modelsv1.JobStatus

GetBatchJobStatusFromRadixBatchJobsStatuses Get JobStatuses from RadixBatch job statuses v2 for batch jobs

func GetJobStatusFromRadixBatchJobsStatus

func GetJobStatusFromRadixBatchJobsStatus(batchName string, jobStatus modelsv2.RadixBatchJobStatus) modelsv1.JobStatus

GetJobStatusFromRadixBatchJobsStatus Get Job status from RadixBatchJob

func GetLabelSelectorForBatches

func GetLabelSelectorForBatches(componentName string) string

GetLabelSelectorForBatches Gets a label selector for a batch scheduler job

func GetPodsToJobNameMap

func GetPodsToJobNameMap(pods []corev1.Pod) map[string][]corev1.Pod

GetPodsToJobNameMap Gets a map of pods to K8sJobNameLabel label as keys

func GetSingleJobStatusFromRadixBatchJobsStatuses

func GetSingleJobStatusFromRadixBatchJobsStatuses(radixBatches ...modelsv2.RadixBatch) []modelsv1.JobStatus

GetSingleJobStatusFromRadixBatchJobsStatuses Get JobStatuses from RadixBatch job statuses v2 for single jobs

func ParseBatchAndJobNameFromScheduledJobName

func ParseBatchAndJobNameFromScheduledJobName(scheduleJobName string) (batchName, batchJobName string, ok bool)

ParseBatchAndJobNameFromScheduledJobName Decompose V2 batch name and jobs name from V1 job-name

func StopJob

func StopJob(handlerApiV2 apiv2.Handler, jobName string) error

StopJob Stop a job

Types

type Handler

type Handler struct {
	Kube         *kube.Kube
	Env          *models.Env
	HandlerApiV2 apiv2.Handler
}

func (*Handler) DeleteSecret

func (handler *Handler) DeleteSecret(secret *corev1.Secret) error

DeleteSecret Delete the service for the job

func (*Handler) DeleteService

func (handler *Handler) DeleteService(service *corev1.Service) error

DeleteService Deletes a service

func (*Handler) GetBatch

func (handler *Handler) GetBatch(batchName string) (*batchv1.Job, error)

GetBatch Gets a job, running a batch

func (*Handler) GetPodsForLabelSelector

func (handler *Handler) GetPodsForLabelSelector(labelSelector string) ([]corev1.Pod, error)

func (*Handler) GetSecretsForJob

func (handler *Handler) GetSecretsForJob(jobName string) (*corev1.SecretList, error)

GetSecretsForJob Get secrets for the job

func (*Handler) GetServiceForJob

func (handler *Handler) GetServiceForJob(jobName string) (*corev1.ServiceList, error)

GetServiceForJob Get the service for the job