scheduler

Documentation

Index

• Variables
• func UnmarshalSchedulerConf(confStr string) ([]framework.Action, []conf.Tier, []conf.Configuration, map[string]string, ...)
• type Scheduler
  • func NewScheduler(config *rest.Config, opt *options.ServerOption) (*Scheduler, error)
  • func (pc *Scheduler) Run(stopCh <-chan struct{})

Variables

var DefaultSchedulerConf = `` /* 222-byte string literal not displayed */

Functions

func UnmarshalSchedulerConf

func UnmarshalSchedulerConf(confStr string) ([]framework.Action, []conf.Tier, []conf.Configuration, map[string]string, error)

Types

type Scheduler

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

Scheduler represents a "Volcano Scheduler". Scheduler watches for new unscheduled pods(PodGroup) in Volcano. It attempts to find nodes that can accommodate these pods and writes the binding information back to the API server.

func NewScheduler

func NewScheduler(config *rest.Config, opt *options.ServerOption) (*Scheduler, error)

NewScheduler returns a Scheduler

func (*Scheduler) Run

func (pc *Scheduler) Run(stopCh <-chan struct{})

Run initializes and starts the Scheduler. It loads the configuration, initializes the cache, and begins the scheduling process.