api

Documentation

Index

• func GetJobOwnerReference(job *batchv1.Job) metav1.OwnerReference
• func GetLabelSelectorForBatches(componentName string) string
• func GetPodsToJobNameMap(pods []corev1.Pod) map[string][]corev1.Pod
• type Handler
  • func (handler *Handler) CreateBatchScheduleDescriptionSecret(appName, batchName, jobComponentName string, ...) (*corev1.Secret, error)
  • func (handler *Handler) CreateJob(namespace string, job *batchv1.Job) (*batchv1.Job, error)
  • func (handler *Handler) CreatePayloadSecret(appName, jobName string, jobComponent *v1.RadixDeployJobComponent, ...) (*corev1.Secret, error)
  • func (handler *Handler) CreateService(appName, jobName string, jobComponent *v1.RadixDeployJobComponent) (..., error)
  • func (handler *Handler) DeleteConfigMaps(configMap *corev1.ConfigMap) error
  • 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)
  • func (handler *Handler) UpdateOwnerReferenceOfConfigMaps(namespace string, ownerReference metav1.OwnerReference, ...) error
  • func (handler *Handler) UpdateOwnerReferenceOfSecret(namespace string, ownerReference metav1.OwnerReference, ...) error
  • func (handler *Handler) UpdateOwnerReferenceOfService(namespace string, ownerReference metav1.OwnerReference, ...) error

Functions

func GetJobOwnerReference

func GetJobOwnerReference(job *batchv1.Job) metav1.OwnerReference

GetJobOwnerReference Gets job as an OwnerReference

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

Types

type Handler

type Handler struct {
	Kube                   *kube.Kube
	Env                    *models.Env
	KubeClient             kubernetes.Interface
	RadixClient            versioned.Interface
	SecurityContextBuilder deployment.SecurityContextBuilder
}

func (*Handler) CreateBatchScheduleDescriptionSecret

func (handler *Handler) CreateBatchScheduleDescriptionSecret(appName, batchName, jobComponentName string,
	batchScheduleDescription *models.BatchScheduleDescription) (*corev1.Secret, error)

CreateBatchScheduleDescriptionSecret Create a secret for the batch schedule description

func (*Handler) CreateJob

func (handler *Handler) CreateJob(namespace string, job *batchv1.Job) (*batchv1.Job, error)

CreateJob Create a job

func (*Handler) CreatePayloadSecret

func (handler *Handler) CreatePayloadSecret(appName, jobName string, jobComponent *v1.RadixDeployJobComponent,
	jobScheduleDescription *models.JobScheduleDescription) (*corev1.Secret, error)

CreatePayloadSecret Create a secret for the job payload

func (*Handler) CreateService

func (handler *Handler) CreateService(appName, jobName string, jobComponent *v1.RadixDeployJobComponent) (*corev1.
	Service, error)

CreateService Create a service for the job API

func (*Handler) DeleteConfigMaps

func (handler *Handler) DeleteConfigMaps(configMap *corev1.ConfigMap) error

DeleteConfigMaps Deletes a configmap in a namespace

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 Delete the service for the job

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

func (*Handler) UpdateOwnerReferenceOfConfigMaps

func (handler *Handler) UpdateOwnerReferenceOfConfigMaps(namespace string, ownerReference metav1.OwnerReference, configMaps ...*corev1.ConfigMap) error

UpdateOwnerReferenceOfConfigMaps Update owner reference of a config-map

func (*Handler) UpdateOwnerReferenceOfSecret

func (handler *Handler) UpdateOwnerReferenceOfSecret(namespace string, ownerReference metav1.OwnerReference, secrets ...*corev1.Secret) error

UpdateOwnerReferenceOfSecret Update owner reference of secrets

func (*Handler) UpdateOwnerReferenceOfService

func (handler *Handler) UpdateOwnerReferenceOfService(namespace string, ownerReference metav1.OwnerReference,
	services ...*corev1.Service) error

UpdateOwnerReferenceOfService Update owner reference of services