v1

Documentation

Index

• func CopyJob(ctx context.Context, handlerApiV2 apiv2.Handler, ...) (*modelsv2.RadixBatch, error)
• func GetBatchJob(ctx context.Context, handlerApiV2 apiv2.Handler, batchName, jobName string) (*modelsv1.JobStatus, error)
• func GetJobStatusFromRadixBatchJobsStatus(batchName string, jobStatus modelsv2.RadixBatchJobStatus) modelsv1.JobStatus
• func GetJobStatusFromRadixBatchJobsStatuses(radixBatches ...modelsv2.RadixBatch) []modelsv1.JobStatus
• func GetLabelSelectorForAllRadixBatchesPods(componentName string) string
• func GetLabelSelectorForRadixBatchesPods(componentName, batchName string) string
• func ParseBatchAndJobNameFromScheduledJobName(scheduleJobName string) (batchName, batchJobName string, ok bool)
• func SetBatchJobEventMessageToBatchJobStatus(jobStatus *modelsv1.JobStatus, batchJobPodsMap map[string]corev1.Pod, ...)
• func StopJob(ctx context.Context, handlerApiV2 apiv2.Handler, jobName string) error
• type Handler
  • func (handler *Handler) GetLastEventMessageForPods(ctx context.Context, pods []corev1.Pod) (map[string]string, error)
  • func (handler *Handler) GetPodsForLabelSelector(ctx context.Context, labelSelector string) ([]corev1.Pod, error)
  • func (handler *Handler) GetRadixBatchJobMessagesAndPodMaps(ctx context.Context, selectorForRadixBatchPods string) (map[string]string, map[string]corev1.Pod, error)

Functions

func CopyJob

func CopyJob(ctx context.Context, handlerApiV2 apiv2.Handler, jobName, deploymentName string) (*modelsv2.RadixBatch, error)

CopyJob Copy a job

func GetBatchJob

func GetBatchJob(ctx context.Context, handlerApiV2 apiv2.Handler, batchName, jobName string) (*modelsv1.JobStatus, error)

GetBatchJob Get batch job

func GetJobStatusFromRadixBatchJobsStatus

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

GetJobStatusFromRadixBatchJobsStatus Get Job status from RadixBatchJob

func GetJobStatusFromRadixBatchJobsStatuses

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

GetJobStatusFromRadixBatchJobsStatuses Get JobStatuses from RadixBatch job statuses v2

func GetLabelSelectorForAllRadixBatchesPods

func GetLabelSelectorForAllRadixBatchesPods(componentName string) string

GetLabelSelectorForAllRadixBatchesPods Gets a label selector for all radix batches pods

func GetLabelSelectorForRadixBatchesPods

func GetLabelSelectorForRadixBatchesPods(componentName, batchName string) string

GetLabelSelectorForRadixBatchesPods Gets a label selector for a radix batch pods

func ParseBatchAndJobNameFromScheduledJobName

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

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

func SetBatchJobEventMessageToBatchJobStatus

func SetBatchJobEventMessageToBatchJobStatus(jobStatus *modelsv1.JobStatus, batchJobPodsMap map[string]corev1.Pod, eventMessageForPods map[string]string)

SetBatchJobEventMessageToBatchJobStatus sets the event message for the batch job status

func StopJob

func StopJob(ctx context.Context, 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) GetLastEventMessageForPods

func (handler *Handler) GetLastEventMessageForPods(ctx context.Context, pods []corev1.Pod) (map[string]string, error)

GetLastEventMessageForPods returns the last event message for pods

func (*Handler) GetPodsForLabelSelector

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

func (*Handler) GetRadixBatchJobMessagesAndPodMaps

func (handler *Handler) GetRadixBatchJobMessagesAndPodMaps(ctx context.Context, selectorForRadixBatchPods string) (map[string]string, map[string]corev1.Pod, error)

GetRadixBatchJobMessagesAndPodMaps returns the event messages for the batch job statuses