rayjob

Documentation

Index

• type JobWrapper
  • func MakeJob(name, ns string) *JobWrapper
  • func (j *JobWrapper) Clone() *JobWrapper
  • func (j *JobWrapper) ClusterSelector(value map[string]string) *JobWrapper
  • func (j *JobWrapper) Generation(num int64) *JobWrapper
  • func (j *JobWrapper) Obj() *rayv1.RayJob
  • func (j *JobWrapper) Queue(queue string) *JobWrapper
  • func (j *JobWrapper) RequestHead(name corev1.ResourceName, quantity string) *JobWrapper
  • func (j *JobWrapper) RequestWorkerGroup(name corev1.ResourceName, quantity string) *JobWrapper
  • func (j *JobWrapper) ShutdownAfterJobFinishes(value bool) *JobWrapper
  • func (j *JobWrapper) Suspend(s bool) *JobWrapper
  • func (j *JobWrapper) WithEnableAutoscaling(value *bool) *JobWrapper
  • func (j *JobWrapper) WithHeadGroupSpec(value rayv1.HeadGroupSpec) *JobWrapper
  • func (j *JobWrapper) WithPriorityClassName(value string) *JobWrapper
  • func (j *JobWrapper) WithWorkerGroups(workers ...rayv1.WorkerGroupSpec) *JobWrapper
  • func (j *JobWrapper) WithWorkerPriorityClassName(value string) *JobWrapper
  • func (j *JobWrapper) WorkloadPriorityClass(wpc string) *JobWrapper

Types

type JobWrapper

type JobWrapper struct{ rayv1.RayJob }

JobWrapper wraps a RayJob.

func MakeJob

func MakeJob(name, ns string) *JobWrapper

MakeJob creates a wrapper for a suspended rayJob

func (*JobWrapper) Clone

func (j *JobWrapper) Clone() *JobWrapper

Clone returns a deep copy of the job.

func (*JobWrapper) ClusterSelector

func (j *JobWrapper) ClusterSelector(value map[string]string) *JobWrapper

func (*JobWrapper) Generation

func (j *JobWrapper) Generation(num int64) *JobWrapper

Generation sets the generation of the job.

func (*JobWrapper) Obj

func (j *JobWrapper) Obj() *rayv1.RayJob

Obj returns the inner Job.

func (*JobWrapper) Queue

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

Queue updates the queue name of the job

func (*JobWrapper) RequestHead

func (j *JobWrapper) RequestHead(name corev1.ResourceName, quantity string) *JobWrapper

func (*JobWrapper) RequestWorkerGroup

func (j *JobWrapper) RequestWorkerGroup(name corev1.ResourceName, quantity string) *JobWrapper

func (*JobWrapper) ShutdownAfterJobFinishes

func (j *JobWrapper) ShutdownAfterJobFinishes(value bool) *JobWrapper

func (*JobWrapper) Suspend

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

Suspend updates the suspend status of the job

func (*JobWrapper) WithEnableAutoscaling

func (j *JobWrapper) WithEnableAutoscaling(value *bool) *JobWrapper

func (*JobWrapper) WithHeadGroupSpec

func (j *JobWrapper) WithHeadGroupSpec(value rayv1.HeadGroupSpec) *JobWrapper

func (*JobWrapper) WithPriorityClassName

func (j *JobWrapper) WithPriorityClassName(value string) *JobWrapper

func (*JobWrapper) WithWorkerGroups

func (j *JobWrapper) WithWorkerGroups(workers ...rayv1.WorkerGroupSpec) *JobWrapper

func (*JobWrapper) WithWorkerPriorityClassName

func (j *JobWrapper) WithWorkerPriorityClassName(value string) *JobWrapper

func (*JobWrapper) WorkloadPriorityClass

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

WorkloadPriorityClass updates job workloadpriorityclass.