job

Documentation

Index

• Constants
• func GetOwnerReference(radixJob *v1.RadixJob) []metav1.OwnerReference
• func GetOwnerReferenceOfJob(ctx context.Context, radixclient radixclient.Interface, namespace, name string) ([]metav1.OwnerReference, error)
• func IsRadixJobDone(rj *v1.RadixJob) bool
• type History
  • func NewHistory(radixClient radixclient.Interface, kubeUtil *kube.Kube, historyLimit int, ...) History
• type Job
  • func NewJob(kubeclient kubernetes.Interface, kubeutil *kube.Kube, ...) Job
  • func (job *Job) OnSync(ctx context.Context) 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(ctx context.Context, 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 History

type History interface {
	// Cleanup the pipeline job history for the Radix application
	Cleanup(ctx context.Context, appName string) error
}

History Interface for job History

func NewHistory

func NewHistory(radixClient radixclient.Interface, kubeUtil *kube.Kube, historyLimit int, historyPeriodLimit time.Duration) History

NewHistory Constructor for job History

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 *apiconfig.Config) Job

NewJob Constructor

func (*Job) OnSync

func (job *Job) OnSync(ctx context.Context) error

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