testing

Documentation

Index

• type TFJobWrapper
  • func MakeTFJob(name, ns string) *TFJobWrapper
  • func (j *TFJobWrapper) Clone() *TFJobWrapper
  • func (j *TFJobWrapper) Image(replicaType kftraining.ReplicaType, image string, args []string) *TFJobWrapper
  • func (j *TFJobWrapper) Label(key, value 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) StatusConditions(c kftraining.JobCondition) *TFJobWrapper
  • func (j *TFJobWrapper) Suspend(s bool) *TFJobWrapper
  • func (j *TFJobWrapper) TFReplicaSpecs(replicaSpecs ...TFReplicaSpecRequirement) *TFJobWrapper
  • func (j *TFJobWrapper) TFReplicaSpecsDefault() *TFJobWrapper
  • func (j *TFJobWrapper) UID(uid string) *TFJobWrapper
  • func (j *TFJobWrapper) WorkloadPriorityClass(wpc string) *TFJobWrapper
• type TFReplicaSpecRequirement

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

func (j *TFJobWrapper) Clone() *TFJobWrapper

Clone returns deep copy of the TFJobWrapper.

func (*TFJobWrapper) Image

func (j *TFJobWrapper) Image(replicaType kftraining.ReplicaType, image string, args []string) *TFJobWrapper

func (*TFJobWrapper) Label

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

Label sets the label key and value

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

func (j *TFJobWrapper) StatusConditions(c kftraining.JobCondition) *TFJobWrapper

Condition adds a condition

func (*TFJobWrapper) Suspend

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

Suspend updates the suspend status of the job.

func (*TFJobWrapper) TFReplicaSpecs

func (j *TFJobWrapper) TFReplicaSpecs(replicaSpecs ...TFReplicaSpecRequirement) *TFJobWrapper

func (*TFJobWrapper) TFReplicaSpecsDefault

func (j *TFJobWrapper) TFReplicaSpecsDefault() *TFJobWrapper

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.

type TFReplicaSpecRequirement

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