jobset

Documentation

Index

• Variables
• type JobSetWrapper
  • func MakeJobSet(name, ns string) *JobSetWrapper
  • func (j *JobSetWrapper) Annotations(annotations map[string]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) ManagedBy(c 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) Annotations

func (j *JobSetWrapper) Annotations(annotations map[string]string) *JobSetWrapper

Annotations sets annotations to the 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) ManagedBy

func (j *JobSetWrapper) ManagedBy(c string) *JobSetWrapper

ManagedBy adds a managedby.

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
	PodAnnotations map[string]string
	Image          string
	Args           []string
}