rayjob

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 16, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 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) Generation added in v0.7.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL