batchscheduler

Documentation

Index

• type SchedulerManager
  • func NewSchedulerManager(rayConfigs configapi.Configuration, config *rest.Config) (*SchedulerManager, error)
  • func (batch *SchedulerManager) AddToScheme(scheme *runtime.Scheme)
  • func (batch *SchedulerManager) ConfigureReconciler(b *builder.Builder) *builder.Builder
  • func (batch *SchedulerManager) GetSchedulerForCluster(app *rayv1.RayCluster) (schedulerinterface.BatchScheduler, error)

Types

type SchedulerManager

type SchedulerManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSchedulerManager

func NewSchedulerManager(rayConfigs configapi.Configuration, config *rest.Config) (*SchedulerManager, error)

NewSchedulerManager maintains a specific scheduler plugin based on config

func (*SchedulerManager) AddToScheme

func (batch *SchedulerManager) AddToScheme(scheme *runtime.Scheme)

func (*SchedulerManager) ConfigureReconciler

func (batch *SchedulerManager) ConfigureReconciler(b *builder.Builder) *builder.Builder

func (*SchedulerManager) GetSchedulerForCluster

func (batch *SchedulerManager) GetSchedulerForCluster(app *rayv1.RayCluster) (schedulerinterface.BatchScheduler, error)