testing

Documentation

Index

• type MPIJobWrapper
  • func MakeMPIJob(name, ns string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Obj() *kubeflow.MPIJob
  • func (j *MPIJobWrapper) Parallelism(p int32) *MPIJobWrapper
  • func (j *MPIJobWrapper) PodAnnotation(replicaType kubeflow.MPIReplicaType, k, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) PodLabel(replicaType kubeflow.MPIReplicaType, k, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) PriorityClass(pc string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Queue(queue string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Request(replicaType kubeflow.MPIReplicaType, r corev1.ResourceName, v string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Suspend(s bool) *MPIJobWrapper
  • func (j *MPIJobWrapper) UID(uid string) *MPIJobWrapper
  • func (j *MPIJobWrapper) WorkloadPriorityClass(wpc string) *MPIJobWrapper

Types

type MPIJobWrapper

type MPIJobWrapper struct{ kubeflow.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) Obj

func (j *MPIJobWrapper) Obj() *kubeflow.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 kubeflow.MPIReplicaType, k, v string) *MPIJobWrapper

PodAnnotation sets annotation at the pod template level

func (*MPIJobWrapper) PodLabel

func (j *MPIJobWrapper) PodLabel(replicaType kubeflow.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 kubeflow.MPIReplicaType, r corev1.ResourceName, v string) *MPIJobWrapper

Request adds a resource request to the default container.

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.