testing

Documentation

Index

• type MPIJobWrapper
  • func MakeMPIJob(name, ns string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Obj() *kubeflow.MPIJob
  • func (j *MPIJobWrapper) OriginalNodeSelectorsAnnotation(content string) *MPIJobWrapper
  • func (j *MPIJobWrapper) Parallelism(p int32) *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

Types

type MPIJobWrapper

type MPIJobWrapper struct{ kubeflow.MPIJob }

JobWrapper wraps a Job.

func MakeMPIJob

func MakeMPIJob(name, ns string) *MPIJobWrapper

MakeJob 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) OriginalNodeSelectorsAnnotation

func (j *MPIJobWrapper) OriginalNodeSelectorsAnnotation(content string) *MPIJobWrapper

OriginalNodeSelectorsAnnotation updates the original node selectors annotation

func (*MPIJobWrapper) Parallelism

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

Parallelism updates job parallelism.

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