jobset

Documentation

Index

• Variables
• type JobSetWrapper
  • func MakeJobSet(name, ns string) *JobSetWrapper
  • func (j *JobSetWrapper) Condition(c metav1.Condition) *JobSetWrapper
  • func (j *JobSetWrapper) DeepCopy() *JobSetWrapper
  • func (j *JobSetWrapper) JobsStatus(statuses ...jobsetapi.ReplicatedJobStatus) *JobSetWrapper
  • func (j *JobSetWrapper) Label(k, v string) *JobSetWrapper
  • func (j *JobSetWrapper) Obj() *jobsetapi.JobSet
  • func (j *JobSetWrapper) PriorityClass(pc string) *JobSetWrapper
  • func (j *JobSetWrapper) Queue(queue string) *JobSetWrapper
  • func (j *JobSetWrapper) ReplicatedJobs(replicatedJobs ...ReplicatedJobRequirements) *JobSetWrapper
  • func (j *JobSetWrapper) Request(replicatedJobName string, r corev1.ResourceName, v string) *JobSetWrapper
  • func (j *JobSetWrapper) Suspend(s bool) *JobSetWrapper
  • func (j *JobSetWrapper) WorkloadPriorityClass(wpc string) *JobSetWrapper
• type ReplicatedJobRequirements

Variables

var TestPodSpec = corev1.PodSpec{
	RestartPolicy: corev1.RestartPolicyNever,
	Containers: []corev1.Container{
		{
			Name:  "test-container",
			Image: "busybox:latest",
		},
	},
}

TestPodSpec is the default pod spec used for testing.

Types

type JobSetWrapper

type JobSetWrapper struct{ jobsetapi.JobSet }

JobSetWrapper wraps a JobSet.

func MakeJobSet

func MakeJobSet(name, ns string) *JobSetWrapper

MakeJobSet creates a wrapper for a suspended JobSet

func (*JobSetWrapper) Condition

func (j *JobSetWrapper) Condition(c metav1.Condition) *JobSetWrapper

Condition adds a condition

func (*JobSetWrapper) DeepCopy

func (j *JobSetWrapper) DeepCopy() *JobSetWrapper

DeepCopy returns a DeepCopy of j.

func (*JobSetWrapper) JobsStatus

func (j *JobSetWrapper) JobsStatus(statuses ...jobsetapi.ReplicatedJobStatus) *JobSetWrapper

JobsStatus updates JobSet status.

func (*JobSetWrapper) Label

func (j *JobSetWrapper) Label(k, v string) *JobSetWrapper

Label sets a label to the JobSet.

func (*JobSetWrapper) Obj

func (j *JobSetWrapper) Obj() *jobsetapi.JobSet

Obj returns the inner JobSet.

func (*JobSetWrapper) PriorityClass

func (j *JobSetWrapper) PriorityClass(pc string) *JobSetWrapper

PriorityClass updates JobSet priorityclass.

func (*JobSetWrapper) Queue

func (j *JobSetWrapper) Queue(queue string) *JobSetWrapper

Queue updates the queue name of the JobSet.

func (*JobSetWrapper) ReplicatedJobs

func (j *JobSetWrapper) ReplicatedJobs(replicatedJobs ...ReplicatedJobRequirements) *JobSetWrapper

ReplicatedJobs sets a new set of ReplicatedJobs in the inner JobSet.

func (*JobSetWrapper) Request

func (j *JobSetWrapper) Request(replicatedJobName string, r corev1.ResourceName, v string) *JobSetWrapper

Request adds a resource request to the first container of the target replicatedJob.

func (*JobSetWrapper) Suspend

func (j *JobSetWrapper) Suspend(s bool) *JobSetWrapper

Suspend updates the suspend status of the JobSet.

func (*JobSetWrapper) WorkloadPriorityClass

func (j *JobSetWrapper) WorkloadPriorityClass(wpc string) *JobSetWrapper

WorkloadPriorityClass updates JobSet workloadpriorityclass.

type ReplicatedJobRequirements

type ReplicatedJobRequirements struct {
	Name        string
	Replicas    int32
	Parallelism int32
	Completions int32
	Annotations map[string]string
	Image       string
	Args        []string
}