job

Documentation

Index

• func CheckJobSucceed(ctx context.Context, cli client.Reader, cluster *appsv1alpha1.Cluster, ...) error
• func CleanJobByName(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) error
• func CleanJobByNameWithDAG(ctx context.Context, cli client.Reader, dag *graph.DAG, ...) error
• func CleanJobWithLabels(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) error
• func GetJobWithLabels(ctx context.Context, cli client.Client, cluster *appsv1alpha1.Cluster, ...) ([]batchv1.Job, error)

Functions

func CheckJobSucceed

func CheckJobSucceed(ctx context.Context,
	cli client.Reader,
	cluster *appsv1alpha1.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 *appsv1alpha1.Cluster,
	jobName string) error

CleanJobByName cleans up the job task by name.

func CleanJobByNameWithDAG

func CleanJobByNameWithDAG(ctx context.Context,
	cli client.Reader,
	dag *graph.DAG,
	cluster *appsv1alpha1.Cluster,
	jobName string) error

CleanJobByNameWithDAG cleans up the job task by name with DAG.

func CleanJobWithLabels

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

CleanJobWithLabels cleans up the job tasks with label.

func GetJobWithLabels

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

GetJobWithLabels gets the job list with the specified labels.