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) Clone() *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Image(image string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Label(key, value string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) NodeSelector(k, v string) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Obj() *kftraining.PaddleJob
  • func (j *PaddleJobWrapper) PaddleReplicaSpecs(replicaSpecs ...PaddleReplicaSpecRequirement) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) PaddleReplicaSpecsDefault() *PaddleJobWrapper
  • 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) StatusConditions(conditions ...kftraining.JobCondition) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) Suspend(s bool) *PaddleJobWrapper
  • func (j *PaddleJobWrapper) UID(uid string) *PaddleJobWrapper
• type PaddleReplicaSpecRequirement

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) Clone

func (j *PaddleJobWrapper) Clone() *PaddleJobWrapper

Clone returns deep copy of the PaddleJobWrapper.

func (*PaddleJobWrapper) Image

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

Image updates images of the job.

func (*PaddleJobWrapper) Label

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

Label sets the label key and value

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) PaddleReplicaSpecs

func (j *PaddleJobWrapper) PaddleReplicaSpecs(replicaSpecs ...PaddleReplicaSpecRequirement) *PaddleJobWrapper

func (*PaddleJobWrapper) PaddleReplicaSpecsDefault

func (j *PaddleJobWrapper) PaddleReplicaSpecsDefault() *PaddleJobWrapper

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) StatusConditions

func (j *PaddleJobWrapper) StatusConditions(conditions ...kftraining.JobCondition) *PaddleJobWrapper

StatusConditions updates status conditions of the PaddleJob.

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.

type PaddleReplicaSpecRequirement

type PaddleReplicaSpecRequirement struct {
	ReplicaType   kftraining.ReplicaType
	Name          string
	ReplicaCount  int32
	Annotations   map[string]string
	RestartPolicy kftraining.RestartPolicy
}