testing

Documentation

Index

• type XGBReplicaSpecRequirement
• 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) Clone() *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) Image(image string) *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) Label(key, value 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) StatusConditions(conditions ...kftraining.JobCondition) *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) Suspend(s bool) *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) UID(uid string) *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) XGBReplicaSpecs(replicaSpecs ...XGBReplicaSpecRequirement) *XGBoostJobWrapper
  • func (j *XGBoostJobWrapper) XGBReplicaSpecsDefault() *XGBoostJobWrapper

Types

type XGBReplicaSpecRequirement

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

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

func (j *XGBoostJobWrapper) Clone() *XGBoostJobWrapper

Clone returns deep copy of the XGBoostJobWrapper.

func (*XGBoostJobWrapper) Image

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

Image updates images of the job.

func (*XGBoostJobWrapper) Label

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

Label sets the label key and value

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

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

StatusConditions updates status conditions of the XGBoostJob.

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.

func (*XGBoostJobWrapper) XGBReplicaSpecs

func (j *XGBoostJobWrapper) XGBReplicaSpecs(replicaSpecs ...XGBReplicaSpecRequirement) *XGBoostJobWrapper

func (*XGBoostJobWrapper) XGBReplicaSpecsDefault

func (j *XGBoostJobWrapper) XGBReplicaSpecsDefault() *XGBoostJobWrapper