schedulerplugins

Documentation

Index

• func GetPluginName() string
• type KubeScheduler
  • func (k *KubeScheduler) AddMetadataToPod(_ context.Context, app *rayv1.RayCluster, _ string, pod *corev1.Pod)
  • func (k *KubeScheduler) DoBatchSchedulingOnSubmission(ctx context.Context, app *rayv1.RayCluster) error
  • func (k *KubeScheduler) Name() string
• type KubeSchedulerFactory
  • func (kf *KubeSchedulerFactory) AddToScheme(sche *runtime.Scheme)
  • func (kf *KubeSchedulerFactory) ConfigureReconciler(b *builder.Builder) *builder.Builder
  • func (kf *KubeSchedulerFactory) New(ctx context.Context, c *rest.Config) (schedulerinterface.BatchScheduler, error)

Functions

func GetPluginName

func GetPluginName() string

Types

type KubeScheduler

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

func (*KubeScheduler) AddMetadataToPod

func (k *KubeScheduler) AddMetadataToPod(_ context.Context, app *rayv1.RayCluster, _ string, pod *corev1.Pod)

AddMetadataToPod adds essential labels and annotations to the Ray pods the scheduler needs these labels and annotations in order to do the scheduling properly

func (*KubeScheduler) DoBatchSchedulingOnSubmission

func (k *KubeScheduler) DoBatchSchedulingOnSubmission(ctx context.Context, app *rayv1.RayCluster) error

func (*KubeScheduler) Name

func (k *KubeScheduler) Name() string

type KubeSchedulerFactory

type KubeSchedulerFactory struct{}

func (*KubeSchedulerFactory) AddToScheme

func (kf *KubeSchedulerFactory) AddToScheme(sche *runtime.Scheme)

func (*KubeSchedulerFactory) ConfigureReconciler

func (kf *KubeSchedulerFactory) ConfigureReconciler(b *builder.Builder) *builder.Builder

func (*KubeSchedulerFactory) New

func (kf *KubeSchedulerFactory) New(ctx context.Context, c *rest.Config) (schedulerinterface.BatchScheduler, error)