testing

Documentation

Index

• type MPIJobReplicaSpecRequirement
• type MPIJobWrapper
  • func MakeMPIJob(name, ns string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Clone() *MPIJobWrapper
  • func (j *MPIJobWrapper) Generation(num int64) *MPIJobWrapper
  • func (j *MPIJobWrapper) GenericLauncherAndWorker() *MPIJobWrapper
  • func (j *MPIJobWrapper) Image(replicaType kfmpi.MPIReplicaType, image string, args []string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Label(key, value string) *MPIJobWrapper
  • func (j *MPIJobWrapper) MPIJobReplicaSpecs(replicaSpecs ...MPIJobReplicaSpecRequirement) *MPIJobWrapper
  • func (j *MPIJobWrapper) ManagedBy(c string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Obj() *kfmpi.MPIJob
  • func (j *MPIJobWrapper) Parallelism(p int32) *MPIJobWrapper
  • func (j *MPIJobWrapper) PodAnnotation(replicaType kfmpi.MPIReplicaType, k, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) PodLabel(replicaType kfmpi.MPIReplicaType, k, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) PriorityClass(pc string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Queue(queue string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Request(replicaType kfmpi.MPIReplicaType, r corev1.ResourceName, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) StatusConditions(c kfmpi.JobCondition) *MPIJobWrapper
  • func (j *MPIJobWrapper) Suspend(s bool) *MPIJobWrapper
  • func (j *MPIJobWrapper) UID(uid string) *MPIJobWrapper
  • func (j *MPIJobWrapper) WorkloadPriorityClass(wpc string) *MPIJobWrapper

Types

type MPIJobReplicaSpecRequirement

type MPIJobReplicaSpecRequirement struct {
	ReplicaType   kfmpi.MPIReplicaType
	ReplicaCount  int32
	Annotations   map[string]string
	RestartPolicy corev1.RestartPolicy
}

type MPIJobWrapper

type MPIJobWrapper struct{ kfmpi.MPIJob }

MPIJobWrapper wraps a Job.

func MakeMPIJob

func MakeMPIJob(name, ns string) *MPIJobWrapper

MakeMPIJob creates a wrapper for a suspended job with a single container and parallelism=1.

func (*MPIJobWrapper) Clone

func (j *MPIJobWrapper) Clone() *MPIJobWrapper

Clone returns deep copy of the MPIJobWrapper.

func (*MPIJobWrapper) Generation

func (j *MPIJobWrapper) Generation(num int64) *MPIJobWrapper

Generation sets the generation of the job.

func (*MPIJobWrapper) GenericLauncherAndWorker

func (j *MPIJobWrapper) GenericLauncherAndWorker() *MPIJobWrapper

func (*MPIJobWrapper) Image

func (j *MPIJobWrapper) Image(replicaType kfmpi.MPIReplicaType, image string, args []string) *MPIJobWrapper

func (*MPIJobWrapper) Label

func (j *MPIJobWrapper) Label(key, value string) *MPIJobWrapper

Label sets the label key and value

func (*MPIJobWrapper) MPIJobReplicaSpecs

func (j *MPIJobWrapper) MPIJobReplicaSpecs(replicaSpecs ...MPIJobReplicaSpecRequirement) *MPIJobWrapper

func (*MPIJobWrapper) ManagedBy

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

ManagedBy adds a managedby.

func (*MPIJobWrapper) Obj

func (j *MPIJobWrapper) Obj() *kfmpi.MPIJob

Obj returns the inner Job.

func (*MPIJobWrapper) Parallelism

func (j *MPIJobWrapper) Parallelism(p int32) *MPIJobWrapper

Parallelism updates job parallelism.

func (*MPIJobWrapper) PodAnnotation

func (j *MPIJobWrapper) PodAnnotation(replicaType kfmpi.MPIReplicaType, k, v string) *MPIJobWrapper

PodAnnotation sets annotation at the pod template level

func (*MPIJobWrapper) PodLabel

func (j *MPIJobWrapper) PodLabel(replicaType kfmpi.MPIReplicaType, k, v string) *MPIJobWrapper

PodLabel sets label at the pod template level

func (*MPIJobWrapper) PriorityClass

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

PriorityClass updates job priorityclass.

func (*MPIJobWrapper) Queue

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

Queue updates the queue name of the job.

func (*MPIJobWrapper) Request

func (j *MPIJobWrapper) Request(replicaType kfmpi.MPIReplicaType, r corev1.ResourceName, v string) *MPIJobWrapper

Request adds a resource request to the default container.

func (*MPIJobWrapper) StatusConditions

func (j *MPIJobWrapper) StatusConditions(c kfmpi.JobCondition) *MPIJobWrapper

StatusConditions adds a condition

func (*MPIJobWrapper) Suspend

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

Suspend updates the suspend status of the job.

func (*MPIJobWrapper) UID

func (j *MPIJobWrapper) UID(uid string) *MPIJobWrapper

UID updates the uid of the job.

func (*MPIJobWrapper) WorkloadPriorityClass

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

WorkloadPriorityClass updates job workloadpriorityclass.