testing

Documentation

Index

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

Types

type XGBoostJobWrapper

type XGBoostJobWrapper struct{ kftraining.XGBoostJob }

XGBoostJobWrapper wraps a Job.

func MakeXGBoostJob

func MakeXGBoostJob(name, ns string) *XGBoostJobWrapper

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

func (*XGBoostJobWrapper) Active

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

Active updates the replicaStatus for Active of job.

func (*XGBoostJobWrapper) Args

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

Args updates args of the job.

func (*XGBoostJobWrapper) Image

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

Image updates images of the job.

func (*XGBoostJobWrapper) NodeSelector

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

NodeSelector updates the nodeSelector of job.

func (*XGBoostJobWrapper) Obj

func (j *XGBoostJobWrapper) Obj() *kftraining.XGBoostJob

Obj returns the inner Job.

func (*XGBoostJobWrapper) Parallelism

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

Parallelism updates job parallelism.

func (*XGBoostJobWrapper) PriorityClass

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

PriorityClass updates job priorityclass.

func (*XGBoostJobWrapper) Queue

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

Queue updates the queue name of the job.

func (*XGBoostJobWrapper) Request

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

Request updates a resource request to the default container.

func (*XGBoostJobWrapper) Suspend

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

Suspend updates the suspend status of the job.

func (*XGBoostJobWrapper) UID

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

UID updates the uid of the job.