raycluster

Documentation

Index

• type ClusterWrapper
  • func MakeCluster(name, ns string) *ClusterWrapper
  • func (j *ClusterWrapper) Clone() *ClusterWrapper
  • func (j *ClusterWrapper) NodeSelectorHeadGroup(k, v string) *ClusterWrapper
  • func (j *ClusterWrapper) Obj() *rayv1.RayCluster
  • func (j *ClusterWrapper) Queue(queue string) *ClusterWrapper
  • func (j *ClusterWrapper) RequestHead(name corev1.ResourceName, quantity string) *ClusterWrapper
  • func (j *ClusterWrapper) RequestWorkerGroup(name corev1.ResourceName, quantity string) *ClusterWrapper
  • func (j *ClusterWrapper) Suspend(s bool) *ClusterWrapper
  • func (j *ClusterWrapper) WithEnableAutoscaling(value *bool) *ClusterWrapper
  • func (j *ClusterWrapper) WithHeadGroupSpec(value rayv1.HeadGroupSpec) *ClusterWrapper
  • func (j *ClusterWrapper) WithPriorityClassName(value string) *ClusterWrapper
  • func (j *ClusterWrapper) WithWorkerGroups(workers ...rayv1.WorkerGroupSpec) *ClusterWrapper
  • func (j *ClusterWrapper) WithWorkerPriorityClassName(value string) *ClusterWrapper
  • func (j *ClusterWrapper) WorkloadPriorityClass(wpc string) *ClusterWrapper

Types

type ClusterWrapper

type ClusterWrapper struct{ rayv1.RayCluster }

ClusterWrapper wraps a RayCluster.

func MakeCluster

func MakeCluster(name, ns string) *ClusterWrapper

MakeCluster creates a wrapper for rayCluster

func (*ClusterWrapper) Clone

func (j *ClusterWrapper) Clone() *ClusterWrapper

Clone returns deep copy of the Job.

func (*ClusterWrapper) NodeSelectorHeadGroup

func (j *ClusterWrapper) NodeSelectorHeadGroup(k, v string) *ClusterWrapper

NodeSelector adds a node selector to the job's head.

func (*ClusterWrapper) Obj

func (j *ClusterWrapper) Obj() *rayv1.RayCluster

Obj returns the inner Job.

func (*ClusterWrapper) Queue

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

Queue updates the queue name of the job

func (*ClusterWrapper) RequestHead

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

func (*ClusterWrapper) RequestWorkerGroup

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

func (*ClusterWrapper) Suspend

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

Suspend updates the suspend status of the job

func (*ClusterWrapper) WithEnableAutoscaling

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

func (*ClusterWrapper) WithHeadGroupSpec

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

func (*ClusterWrapper) WithPriorityClassName

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

func (*ClusterWrapper) WithWorkerGroups

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

func (*ClusterWrapper) WithWorkerPriorityClassName

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

func (*ClusterWrapper) WorkloadPriorityClass

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

WorkloadPriorityClass updates job workloadpriorityclass.