rayjob

Documentation

Index

• Constants
• Variables
• func GetWorkloadNameForRayJob(jobName string, jobUID types.UID) string
• func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
• func SetupRayJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
• type RayJob
  • func (j *RayJob) Finished() (message string, success, finished bool)
  • func (j *RayJob) GVK() schema.GroupVersionKind
  • func (j *RayJob) IsActive() bool
  • func (j *RayJob) IsSuspended() bool
  • func (j *RayJob) Object() client.Object
  • func (j *RayJob) PodSets() []kueue.PodSet
  • func (j *RayJob) PodsReady() bool
  • func (j *RayJob) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool
  • func (j *RayJob) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error
  • func (j *RayJob) Suspend()
• type RayJobWebhook
  • func (w *RayJobWebhook) Default(ctx context.Context, obj runtime.Object) error
  • func (w *RayJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (w *RayJobWebhook) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)
  • func (w *RayJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

Constants

const (
	FrameworkName = "ray.io/rayjob"
)

Variables

var NewReconciler = jobframework.NewGenericReconcilerFactory(func() jobframework.GenericJob { return &RayJob{} })

Functions

func GetWorkloadNameForRayJob

func GetWorkloadNameForRayJob(jobName string, jobUID types.UID) string

func SetupIndexes

func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error

func SetupRayJobWebhook

func SetupRayJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error

SetupRayJobWebhook configures the webhook for RayJob.

Types

type RayJob

type RayJob rayv1.RayJob

func (*RayJob) Finished

func (j *RayJob) Finished() (message string, success, finished bool)

func (*RayJob) GVK

func (j *RayJob) GVK() schema.GroupVersionKind

func (*RayJob) IsActive

func (j *RayJob) IsActive() bool

func (*RayJob) IsSuspended

func (j *RayJob) IsSuspended() bool

func (*RayJob) Object

func (j *RayJob) Object() client.Object

func (*RayJob) PodSets

func (j *RayJob) PodSets() []kueue.PodSet

func (*RayJob) PodsReady

func (j *RayJob) PodsReady() bool

func (*RayJob) RestorePodSetsInfo

func (j *RayJob) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool

func (*RayJob) RunWithPodSetsInfo

func (j *RayJob) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error

func (*RayJob) Suspend

func (j *RayJob) Suspend()

type RayJobWebhook

type RayJobWebhook struct {
	// contains filtered or unexported fields
}

func (*RayJobWebhook) Default

func (w *RayJobWebhook) Default(ctx context.Context, obj runtime.Object) error

Default implements webhook.CustomDefaulter so a webhook will be registered for the type

func (*RayJobWebhook) ValidateCreate

func (w *RayJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type

func (*RayJobWebhook) ValidateDelete

func (w *RayJobWebhook) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type

func (*RayJobWebhook) ValidateUpdate

func (w *RayJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type