testing

Documentation

Index

• type TFJobWrapper
  • func MakeTFJob(name, ns string) *TFJobWrapper
  • func (j *TFJobWrapper) Obj() *kftraining.TFJob
  • func (j *TFJobWrapper) Parallelism(workerParallelism, psParallelism int32) *TFJobWrapper
  • func (j *TFJobWrapper) PriorityClass(pc string) *TFJobWrapper
  • func (j *TFJobWrapper) Queue(queue string) *TFJobWrapper
  • func (j *TFJobWrapper) Request(replicaType kftraining.ReplicaType, r corev1.ResourceName, v string) *TFJobWrapper
  • func (j *TFJobWrapper) Suspend(s bool) *TFJobWrapper
  • func (j *TFJobWrapper) UID(uid string) *TFJobWrapper
  • func (j *TFJobWrapper) WorkloadPriorityClass(wpc string) *TFJobWrapper

Types

type TFJobWrapper

type TFJobWrapper struct{ kftraining.TFJob }

TFJobWrapper wraps a Job.

func MakeTFJob

func MakeTFJob(name, ns string) *TFJobWrapper

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

func (*TFJobWrapper) Obj

func (j *TFJobWrapper) Obj() *kftraining.TFJob

Obj returns the inner Job.

func (*TFJobWrapper) Parallelism

func (j *TFJobWrapper) Parallelism(workerParallelism, psParallelism int32) *TFJobWrapper

Parallelism updates job parallelism.

func (*TFJobWrapper) PriorityClass

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

PriorityClass updates job priorityclass.

func (*TFJobWrapper) Queue

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

Queue updates the queue name of the job.

func (*TFJobWrapper) Request

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

Request adds a resource request to the default container.

func (*TFJobWrapper) Suspend

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

Suspend updates the suspend status of the job.

func (*TFJobWrapper) UID

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

UID updates the uid of the job.

func (*TFJobWrapper) WorkloadPriorityClass

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

WorkloadPriorityClass updates job workloadpriorityclass.