paddlejob

Documentation

Index

• type PaddleJobWrapper
  • func MakePaddleJob(name, ns string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Active(rType kftraining.ReplicaType, c int32) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Args(args []string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Image(image string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) NodeSelector(k, v string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Obj() *kftraining.PaddleJob
  • func (j *PaddleJobWrapper) Parallelism(p int32) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) PriorityClass(pc string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Queue(queue string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Request(replicaType kftraining.ReplicaType, r corev1.ResourceName, v string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Suspend(s bool) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) UID(uid string) *PaddleJobWrapper

Types

type PaddleJobWrapper

type PaddleJobWrapper struct{ kftraining.PaddleJob }

PaddleJobWrapper wraps a Job.

func MakePaddleJob

func MakePaddleJob(name, ns string) *PaddleJobWrapper

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

func (*PaddleJobWrapper) Active

func (j *PaddleJobWrapper) Active(rType kftraining.ReplicaType, c int32) *PaddleJobWrapper

Active updates the replicaStatus for Active of job.

func (*PaddleJobWrapper) Args

func (j *PaddleJobWrapper) Args(args []string) *PaddleJobWrapper

Args updates args of the job.

func (*PaddleJobWrapper) Image

func (j *PaddleJobWrapper) Image(image string) *PaddleJobWrapper

Image updates images of the job.

func (*PaddleJobWrapper) NodeSelector

func (j *PaddleJobWrapper) NodeSelector(k, v string) *PaddleJobWrapper

NodeSelector updates the nodeSelector of job.

func (*PaddleJobWrapper) Obj

func (j *PaddleJobWrapper) Obj() *kftraining.PaddleJob

Obj returns the inner Job.

func (*PaddleJobWrapper) Parallelism

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

Parallelism updates job parallelism.

func (*PaddleJobWrapper) PriorityClass

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

PriorityClass updates job priorityclass.

func (*PaddleJobWrapper) Queue

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

Queue updates the queue name of the job.

func (*PaddleJobWrapper) Request

func (j *PaddleJobWrapper) Request(replicaType kftraining.ReplicaType, r corev1.ResourceName, v string) *PaddleJobWrapper

Request adds a resource request to the default container.

func (*PaddleJobWrapper) Suspend

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

Suspend updates the suspend status of the job.

func (*PaddleJobWrapper) UID

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

UID updates the uid of the job.