job

func BuildJobTolerations ¶

func BuildJobTolerations(cluster *appsv1.Cluster, job *batchv1.Job) error

func CheckJobSucceed ¶

func CheckJobSucceed(ctx context.Context,
	cli client.Reader,
	cluster *appsv1.Cluster,
	jobName string) error

CheckJobSucceed checks the result of job execution. Returns: - bool: whether job exist, true exist - error: any error that occurred during the handling

func CleanJobByName ¶

func CleanJobByName(ctx context.Context,
	cli client.Client,
	cluster *appsv1.Cluster,
	jobName string) error

CleanJobByName cleans up the job task by name.

func CleanJobWithLabels ¶

func CleanJobWithLabels(ctx context.Context,
	cli client.Client,
	cluster *appsv1.Cluster,
	matchLabels client.MatchingLabels) error

CleanJobWithLabels cleans up the job tasks with label.

func GetJobWithLabels ¶

func GetJobWithLabels(ctx context.Context,
	cli client.Client,
	cluster *appsv1.Cluster,
	matchLabels client.MatchingLabels) ([]batchv1.Job, error)

GetJobWithLabels gets the job list with the specified labels.