rayjob

func (*JobWrapper) Clone ¶ added in v0.7.0

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) Entrypoint ¶ added in v0.10.3

func (j *JobWrapper) Entrypoint(e string) *JobWrapper

func (*JobWrapper) Env ¶ added in v0.11.0

func (j *JobWrapper) Env(rayType rayv1.RayNodeType, name, value string) *JobWrapper

func (*JobWrapper) Generation ¶ added in v0.7.0

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

Generation sets the generation of the job.

func (*JobWrapper) Image ¶ added in v0.10.3

func (j *JobWrapper) Image(rayType rayv1.RayNodeType, image string, args ...string) *JobWrapper

func (*JobWrapper) JobDeploymentStatus ¶ added in v0.11.0

func (j *JobWrapper) JobDeploymentStatus(ds rayv1.JobDeploymentStatus) *JobWrapper

JobDeploymentStatus sets a deployment status of the job

func (*JobWrapper) JobStatus ¶ added in v0.11.0

func (j *JobWrapper) JobStatus(s rayv1.JobStatus) *JobWrapper

JobStatus sets a status of the job

func (*JobWrapper) Label ¶ added in v0.11.0

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

Label sets the label key and value

func (*JobWrapper) Limit ¶ added in v0.11.0

func (j *JobWrapper) Limit(rayType rayv1.RayNodeType, r corev1.ResourceName, v string) *JobWrapper

Limit adds a resource request to the default container.

func (*JobWrapper) ManagedBy ¶ added in v0.11.0

func (j *JobWrapper) ManagedBy(c string) *JobWrapper

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) RayVersion ¶ added in v0.11.0

func (j *JobWrapper) RayVersion(rv string) *JobWrapper

func (*JobWrapper) Request ¶ added in v0.11.0

func (j *JobWrapper) Request(rayType rayv1.RayNodeType, r corev1.ResourceName, v string) *JobWrapper

Request adds a resource request to the default container.

func (*JobWrapper) RequestAndLimit ¶ added in v0.11.0

func (j *JobWrapper) RequestAndLimit(rayType rayv1.RayNodeType, r corev1.ResourceName, v string) *JobWrapper

RequestAndLimit adds a resource request and limit to the default container.

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) WithSubmissionMode ¶ added in v0.10.0

func (j *JobWrapper) WithSubmissionMode(submissionMode rayv1.JobSubmissionMode) *JobWrapper

func (*JobWrapper) WithSubmitterPodTemplate ¶ added in v0.10.0

func (j *JobWrapper) WithSubmitterPodTemplate(template corev1.PodTemplateSpec) *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 ¶ added in v0.5.0

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

WorkloadPriorityClass updates job workloadpriorityclass.