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 GetLabelSelectorForBatches(componentName string) string
• func GetLabelSelectorForRadixBatchesPods(componentName, batchName string) string
• func GetPodsToJobNameMap(pods []corev1.Pod) map[string][]corev1.Pod
• 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) DeleteSecret(ctx context.Context, secret *corev1.Secret) error
  • func (handler *Handler) DeleteService(ctx context.Context, service *corev1.Service) error
  • func (handler *Handler) GetBatch(ctx context.Context, batchName string) (*batchv1.Job, error)
  • 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)
  • func (handler *Handler) GetSecretsForJob(ctx context.Context, jobName string) (*corev1.SecretList, error)
  • func (handler *Handler) GetServiceForJob(ctx context.Context, jobName string) (*corev1.ServiceList, 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 GetLabelSelectorForBatches

func GetLabelSelectorForBatches(componentName string) string

GetLabelSelectorForBatches Gets a label selector for a batch scheduler job

func GetLabelSelectorForRadixBatchesPods

func GetLabelSelectorForRadixBatchesPods(componentName, batchName string) string

GetLabelSelectorForRadixBatchesPods Gets a label selector for a radix batch pods

func GetPodsToJobNameMap

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

GetPodsToJobNameMap Gets a map of pods to K8sJobNameLabel label as keys

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) DeleteSecret

func (handler *Handler) DeleteSecret(ctx context.Context, secret *corev1.Secret) error

DeleteSecret Delete the service for the job

func (*Handler) DeleteService

func (handler *Handler) DeleteService(ctx context.Context, service *corev1.Service) error

DeleteService Deletes a service

func (*Handler) GetBatch

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

GetBatch Gets a job, running a batch

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

func (*Handler) GetSecretsForJob

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

GetSecretsForJob Get secrets for the job

func (*Handler) GetServiceForJob

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

GetServiceForJob Get the service for the job