Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { // It is expected that changes made via SchedulerCache will be observed // by NodeLister and Algorithm. SchedulerCache schedulercache.Cache NodeLister algorithm.NodeLister Algorithm algorithm.ScheduleAlgorithm Binder Binder // PodConditionUpdater is used only in case of scheduling errors. If we succeed // with scheduling, PodScheduled condition will be updated in apiserver in /bind // handler so that binding and setting PodCondition it is atomic. PodConditionUpdater PodConditionUpdater // NextPod should be a function that blocks until the next pod // is available. We don't use a channel for this, because scheduling // a pod may take some amount of time and we don't want pods to get // stale while they sit in a channel. NextPod func() *v1.Pod // Error is called if there is an error. It is passed the pod in // question, and the error Error func(*v1.Pod, error) // Recorder is the EventRecorder to use Recorder record.EventRecorder // Close this to shut down the scheduler. StopEverything chan struct{} }
TODO over time we should make this struct a hidden implementation detail of the scheduler.
type Configurator ¶ added in v1.6.0
type Configurator interface { GetPriorityFunctionConfigs(priorityKeys sets.String) ([]algorithm.PriorityConfig, error) GetPriorityMetadataProducer() (algorithm.MetadataProducer, error) GetPredicateMetadataProducer() (algorithm.MetadataProducer, error) GetPredicates(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error) GetHardPodAffinitySymmetricWeight() int GetSchedulerName() string MakeDefaultErrorFunc(backoff *util.PodBackoff, podQueue *cache.FIFO) func(pod *v1.Pod, err error) // Probably doesn't need to be public. But exposed for now in case. ResponsibleForPod(pod *v1.Pod) bool // Needs to be exposed for things like integration tests where we want to make fake nodes. GetNodeStore() cache.Store GetClient() clientset.Interface GetScheduledPodListerIndexer() cache.Indexer Run() Create() (*Config, error) CreateFromProvider(providerName string) (*Config, error) CreateFromConfig(policy schedulerapi.Policy) (*Config, error) CreateFromKeys(predicateKeys, priorityKeys sets.String, extenders []algorithm.SchedulerExtender) (*Config, error) }
These are the functions which need to be provided in order to build a Scheduler configuration. An implementation of this can be seen in factory.go.
type PodConditionUpdater ¶
type PodConditionUpdater interface {
Update(pod *v1.Pod, podCondition *v1.PodCondition) error
}
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler watches for new unscheduled pods. It attempts to find nodes that they fit on and writes bindings back to the api server.
func NewFromConfigurator ¶ added in v1.6.0
func NewFromConfigurator(c Configurator, modifiers ...func(c *Config)) (*Scheduler, error)
NewFromConfigurator returns a new scheduler that is created entirely by the Configurator. Assumes Create() is implemented. Supports intermediate Config mutation for now if you provide modifier functions which will run after Config is created.
func (*Scheduler) Run ¶
func (s *Scheduler) Run()
Run begins watching and scheduling. It starts a goroutine and returns immediately.
func (*Scheduler) StopEverything ¶ added in v1.6.0
func (sched *Scheduler) StopEverything()
Directories ¶
Path | Synopsis |
---|---|
Package scheduler contains a generic Scheduler interface and several implementations.
|
Package scheduler contains a generic Scheduler interface and several implementations. |
This package is used to register algorithm provider plugins.
|
This package is used to register algorithm provider plugins. |
defaults
This is the default algorithm provider for the scheduler.
|
This is the default algorithm provider for the scheduler. |
Package factory can set up a scheduler.
|
Package factory can set up a scheduler. |