job

Documentation

Index

• Constants
• func GetOwnerReference(radixJob *v1.RadixJob) []metav1.OwnerReference
• func GetOwnerReferenceOfJob(radixclient radixclient.Interface, namespace, name string) ([]metav1.OwnerReference, error)
• func IsRadixJobDone(rj *v1.RadixJob) bool
• type Config
• type Job
  • func NewJob(kubeclient kubernetes.Interface, kubeutil *kube.Kube, ...) Job
  • func (job *Job) OnSync() error

Constants

const (

	// ResultContent of the pipeline job, passed via ConfigMap as v1.RadixJobResult structure
	ResultContent = "ResultContent"
)

Functions

func GetOwnerReference

func GetOwnerReference(radixJob *v1.RadixJob) []metav1.OwnerReference

GetOwnerReference Gets owner reference of radix job

func GetOwnerReferenceOfJob

func GetOwnerReferenceOfJob(radixclient radixclient.Interface, namespace, name string) ([]metav1.OwnerReference, error)

GetOwnerReferenceOfJob Gets owner reference of job with name and UUID

func IsRadixJobDone

func IsRadixJobDone(rj *v1.RadixJob) bool

IsRadixJobDone Checks if job is done

Types

type Config

type Config struct {
	PipelineJobsHistoryLimit              int
	DeploymentsHistoryLimitPerEnvironment int
	AppBuilderResourcesLimitsMemory       *resource.Quantity
	AppBuilderResourcesRequestsCPU        *resource.Quantity
	AppBuilderResourcesRequestsMemory     *resource.Quantity
}

Config for pipeline jobs

type Job

type Job struct {
	// contains filtered or unexported fields
}

Job Instance variables

func NewJob

func NewJob(kubeclient kubernetes.Interface, kubeutil *kube.Kube, radixclient radixclient.Interface, radixJob *v1.RadixJob, config *Config) Job

NewJob Constructor

func (*Job) OnSync

func (job *Job) OnSync() error

OnSync compares the actual state with the desired, and attempts to converge the two