Documentation
¶
Index ¶
- Constants
- Variables
- func EqualPriorityMap(_ *api.Pod, _ interface{}, nodeInfo *schedulercache.NodeInfo) (schedulerapi.HostPriority, error)
- func NewGenericScheduler(cache schedulercache.Cache, predicates map[string]algorithm.FitPredicate, ...) algorithm.ScheduleAlgorithm
- func NewHTTPExtender(config *schedulerapi.ExtenderConfig, apiVersion string) (algorithm.SchedulerExtender, error)
- func PrioritizeNodes(pod *api.Pod, nodeNameToInfo map[string]*schedulercache.NodeInfo, ...) (schedulerapi.HostPriorityList, error)
- type AlgorithmCache
- type Binder
- type Config
- type EquivalenceCache
- func (ec *EquivalenceCache) AddPodPredicatesCache(pod *api.Pod, fitNodeList []*api.Node, failedPredicates *FailedPredicateMap)
- func (ec *EquivalenceCache) GetCachedPredicates(pod *api.Pod, nodes []*api.Node) ([]*api.Node, FailedPredicateMap, []*api.Node)
- func (ec *EquivalenceCache) SendClearAllCacheReq()
- func (ec *EquivalenceCache) SendInvalidAlgorithmCacheReq(nodeName string)
- type FailedPredicateMap
- type FitError
- type HTTPExtender
- type HostPredicate
- type PodConditionUpdater
- type Scheduler
Constants ¶
const (
DefaultExtenderTimeout = 5 * time.Second
)
Variables ¶
var ErrNoNodesAvailable = fmt.Errorf("no nodes available to schedule pods")
Functions ¶
func EqualPriorityMap ¶ added in v1.5.1
func EqualPriorityMap(_ *api.Pod, _ interface{}, nodeInfo *schedulercache.NodeInfo) (schedulerapi.HostPriority, error)
EqualPriority is a prioritizer function that gives an equal weight of one to all nodes
func NewGenericScheduler ¶ added in v0.18.2
func NewGenericScheduler( cache schedulercache.Cache, predicates map[string]algorithm.FitPredicate, predicateMetaProducer algorithm.MetadataProducer, prioritizers []algorithm.PriorityConfig, priorityMetaProducer algorithm.MetadataProducer, extenders []algorithm.SchedulerExtender) algorithm.ScheduleAlgorithm
func NewHTTPExtender ¶ added in v1.2.3
func NewHTTPExtender(config *schedulerapi.ExtenderConfig, apiVersion string) (algorithm.SchedulerExtender, error)
func PrioritizeNodes ¶ added in v0.21.1
func PrioritizeNodes( pod *api.Pod, nodeNameToInfo map[string]*schedulercache.NodeInfo, meta interface{}, priorityConfigs []algorithm.PriorityConfig, nodes []*api.Node, extenders []algorithm.SchedulerExtender, ) (schedulerapi.HostPriorityList, error)
Prioritizes the nodes by running the individual priority functions in parallel. Each priority function is expected to set a score of 0-10 0 is the lowest priority score (least preferred node) and 10 is the highest Each priority function can also have its own weight The node scores returned by the priority function are multiplied by the weights to get weighted scores All scores are finally combined (added) to get the total weighted scores of all nodes
Types ¶
type AlgorithmCache ¶ added in v1.5.1
type AlgorithmCache struct {
// contains filtered or unexported fields
}
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() *api.Pod // Error is called if there is an error. It is passed the pod in // question, and the error Error func(*api.Pod, error) // Recorder is the EventRecorder to use Recorder record.EventRecorder // Close this to shut down the scheduler. StopEverything chan struct{} }
type EquivalenceCache ¶ added in v1.5.1
Store a map of predicate cache with maxsize
func NewEquivalenceCache ¶ added in v1.5.1
func NewEquivalenceCache(getEquivalencePodFunc algorithm.GetEquivalencePodFunc) *EquivalenceCache
func (*EquivalenceCache) AddPodPredicatesCache ¶ added in v1.5.1
func (ec *EquivalenceCache) AddPodPredicatesCache(pod *api.Pod, fitNodeList []*api.Node, failedPredicates *FailedPredicateMap)
AddPodPredicatesCache cache pod predicate for equivalence class
func (*EquivalenceCache) GetCachedPredicates ¶ added in v1.5.1
func (ec *EquivalenceCache) GetCachedPredicates(pod *api.Pod, nodes []*api.Node) ([]*api.Node, FailedPredicateMap, []*api.Node)
GetCachedPredicates gets cached predicates for equivalence class
func (*EquivalenceCache) SendClearAllCacheReq ¶ added in v1.5.1
func (ec *EquivalenceCache) SendClearAllCacheReq()
SendClearAllCacheReq marks all cached item as invalid
func (*EquivalenceCache) SendInvalidAlgorithmCacheReq ¶ added in v1.5.1
func (ec *EquivalenceCache) SendInvalidAlgorithmCacheReq(nodeName string)
SendInvalidAlgorithmCacheReq marks AlgorithmCache item as invalid
type FailedPredicateMap ¶ added in v0.18.2
type FailedPredicateMap map[string][]algorithm.PredicateFailureReason
type FitError ¶ added in v0.18.2
type FitError struct { Pod *api.Pod FailedPredicates FailedPredicateMap }
type HTTPExtender ¶ added in v1.2.3
type HTTPExtender struct {
// contains filtered or unexported fields
}
HTTPExtender implements the algorithm.SchedulerExtender interface.
func (*HTTPExtender) Filter ¶ added in v1.2.3
func (h *HTTPExtender) Filter(pod *api.Pod, nodes []*api.Node) ([]*api.Node, schedulerapi.FailedNodesMap, error)
Filter based on extender implemented predicate functions. The filtered list is expected to be a subset of the supplied list. failedNodesMap optionally contains the list of failed nodes and failure reasons.
func (*HTTPExtender) Prioritize ¶ added in v1.2.3
func (h *HTTPExtender) Prioritize(pod *api.Pod, nodes []*api.Node) (*schedulerapi.HostPriorityList, int, error)
Prioritize based on extender implemented priority functions. Weight*priority is added up for each such priority function. The returned score is added to the score computed by Kubernetes scheduler. The total score is used to do the host selection.
type HostPredicate ¶ added in v1.5.1
type HostPredicate struct { Fit bool FailReasons []algorithm.PredicateFailureReason }
type PodConditionUpdater ¶ added in v1.3.0
type PodConditionUpdater interface {
Update(pod *api.Pod, podCondition *api.PodCondition) error
}
Source Files
¶
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. |