internal

Documentation

Index

• func CreateJobName() string
• func GarbageCollectPayloadSecrets(ctx context.Context, kubeUtil *kube.Kube, namespace, radixComponentName string) error
• func GenerateBatchName(jobComponentName string) string
• func GetJobComponentPayloadSecretRefNames(ctx context.Context, radixClient radixclient.Interface, ...) (map[string]bool, error)
• func GetRadixBatch(ctx context.Context, radixClient radixclient.Interface, ...) (*radixv1.RadixBatch, error)
• func GetRadixBatchJobsStatusesMap(radixBatchJobStatuses []radixv1.RadixBatchJobStatus) map[string]radixv1.RadixBatchJobStatus
• func GetRadixBatches(ctx context.Context, namespace string, radixClient radixclient.Interface, ...) ([]*radixv1.RadixBatch, error)
• func IsRadixBatchJobFailed(jobStatus radixv1.RadixBatchJobStatus) bool
• func IsRadixBatchJobSucceeded(jobStatus radixv1.RadixBatchJobStatus) bool
• func IsRadixBatchNotSucceeded(batch *radixv1.RadixBatch) bool
• func IsRadixBatchSucceeded(batch *radixv1.RadixBatch) bool
• func ParseBatchAndJobNameFromScheduledJobName(scheduleJobName string) (batchName, batchJobName string, ok bool)

Functions

func CreateJobName

func CreateJobName() string

CreateJobName create a job name

func GarbageCollectPayloadSecrets

func GarbageCollectPayloadSecrets(ctx context.Context, kubeUtil *kube.Kube, namespace, radixComponentName string) error

GarbageCollectPayloadSecrets Delete orphaned payload secrets

func GenerateBatchName

func GenerateBatchName(jobComponentName string) string

GenerateBatchName Generate batch name

func GetJobComponentPayloadSecretRefNames

func GetJobComponentPayloadSecretRefNames(ctx context.Context, radixClient radixclient.Interface, namespace, radixComponentName string) (map[string]bool, error)

GetJobComponentPayloadSecretRefNames Get the payload secret ref names for the job components

func GetRadixBatch

func GetRadixBatch(ctx context.Context, radixClient radixclient.Interface, namespace, batchName string) (*radixv1.RadixBatch, error)

GetRadixBatch Get Radix batch

func GetRadixBatchJobsStatusesMap

func GetRadixBatchJobsStatusesMap(radixBatchJobStatuses []radixv1.RadixBatchJobStatus) map[string]radixv1.RadixBatchJobStatus

GetRadixBatchJobsStatusesMap Get map of RadixBatchJobStatuses

func GetRadixBatches

func GetRadixBatches(ctx context.Context, namespace string, radixClient radixclient.Interface, labels ...map[string]string) ([]*radixv1.RadixBatch, error)

GetRadixBatches Get Radix batches

func IsRadixBatchJobFailed

func IsRadixBatchJobFailed(jobStatus radixv1.RadixBatchJobStatus) bool

IsRadixBatchJobFailed Check if Radix batch job is failed

func IsRadixBatchJobSucceeded

func IsRadixBatchJobSucceeded(jobStatus radixv1.RadixBatchJobStatus) bool

IsRadixBatchJobSucceeded Check if Radix batch job is succeeded

func IsRadixBatchNotSucceeded

func IsRadixBatchNotSucceeded(batch *radixv1.RadixBatch) bool

IsRadixBatchNotSucceeded Check if Radix batch is not succeeded

func IsRadixBatchSucceeded

func IsRadixBatchSucceeded(batch *radixv1.RadixBatch) bool

IsRadixBatchSucceeded Check if Radix batch is succeeded

func ParseBatchAndJobNameFromScheduledJobName

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

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