kubernetes: k8s.io/kubernetes/pkg/scheduler/core Index | Files

package core

import "k8s.io/kubernetes/pkg/scheduler/core"


Package Files

extender.go generic_scheduler.go


const (
    // DefaultExtenderTimeout defines the default extender timeout in second.
    DefaultExtenderTimeout = 5 * time.Second
const (
    // NoNodeAvailableMsg is used to format message when no nodes available.
    NoNodeAvailableMsg = "0/%v nodes are available"


var ErrNoNodesAvailable = fmt.Errorf("no nodes available to schedule pods")

ErrNoNodesAvailable is used to describe the error that no nodes available to schedule pods.

func Equal Uses

func Equal(e1, e2 *HTTPExtender) bool

Equal is used to check if two extenders are equal ignoring the client field, exported for testing

func EqualPriorityMap Uses

func EqualPriorityMap(_ *v1.Pod, _ interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error)

EqualPriorityMap is a prioritizer function that gives an equal weight of one to all nodes

func NewHTTPExtender Uses

func NewHTTPExtender(config *schedulerapi.ExtenderConfig) (algorithm.SchedulerExtender, error)

NewHTTPExtender creates an HTTPExtender object.

func PrioritizeNodes Uses

func PrioritizeNodes(
    pod *v1.Pod,
    nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo,
    meta interface{},
    priorityConfigs []priorities.PriorityConfig,
    nodes []*v1.Node,
    extenders []algorithm.SchedulerExtender,
    framework framework.Framework,
    pluginContext *framework.PluginContext) (schedulerapi.HostPriorityList, error)

PrioritizeNodes 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

type FailedPredicateMap Uses

type FailedPredicateMap map[string][]predicates.PredicateFailureReason

FailedPredicateMap declares a map[string][]algorithm.PredicateFailureReason type.

type FitError Uses

type FitError struct {
    Pod                   *v1.Pod
    NumAllNodes           int
    FailedPredicates      FailedPredicateMap
    FilteredNodesStatuses framework.NodeToStatusMap

FitError describes a fit error of a pod.

func (*FitError) Error Uses

func (f *FitError) Error() string

Error returns detailed information of why the pod failed to fit on each node

type HTTPExtender Uses

type HTTPExtender struct {
    // contains filtered or unexported fields

HTTPExtender implements the algorithm.SchedulerExtender interface.

func (*HTTPExtender) Bind Uses

func (h *HTTPExtender) Bind(binding *v1.Binding) error

Bind delegates the action of binding a pod to a node to the extender.

func (*HTTPExtender) Filter Uses

func (h *HTTPExtender) Filter(
    pod *v1.Pod,
    nodes []*v1.Node, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo,
) ([]*v1.Node, schedulerapi.FailedNodesMap, error)

Filter based on extender implemented predicate functions. The filtered list is expected to be a subset of the supplied list; otherwise the function returns an error. failedNodesMap optionally contains the list of failed nodes and failure reasons.

func (*HTTPExtender) IsBinder Uses

func (h *HTTPExtender) IsBinder() bool

IsBinder returns whether this extender is configured for the Bind method.

func (*HTTPExtender) IsIgnorable Uses

func (h *HTTPExtender) IsIgnorable() bool

IsIgnorable returns true indicates scheduling should not fail when this extender is unavailable

func (*HTTPExtender) IsInterested Uses

func (h *HTTPExtender) IsInterested(pod *v1.Pod) bool

IsInterested returns true if at least one extended resource requested by this pod is managed by this extender.

func (*HTTPExtender) Name Uses

func (h *HTTPExtender) Name() string

Name returns extenderURL to identify the extender.

func (*HTTPExtender) Prioritize Uses

func (h *HTTPExtender) Prioritize(pod *v1.Pod, nodes []*v1.Node) (*schedulerapi.HostPriorityList, int64, 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.

func (*HTTPExtender) ProcessPreemption Uses

func (h *HTTPExtender) ProcessPreemption(
    pod *v1.Pod,
    nodeToVictims map[*v1.Node]*schedulerapi.Victims,
    nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo,
) (map[*v1.Node]*schedulerapi.Victims, error)

ProcessPreemption returns filtered candidate nodes and victims after running preemption logic in extender.

func (*HTTPExtender) SupportsPreemption Uses

func (h *HTTPExtender) SupportsPreemption() bool

SupportsPreemption returns true if an extender supports preemption. An extender should have preempt verb defined and enabled its own node cache.

type ScheduleAlgorithm Uses

type ScheduleAlgorithm interface {
    Schedule(*framework.PluginContext, *v1.Pod) (scheduleResult ScheduleResult, err error)
    // Preempt receives scheduling errors for a pod and tries to create room for
    // the pod by preempting lower priority pods if possible.
    // It returns the node where preemption happened, a list of preempted pods, a
    // list of pods whose nominated node name should be removed, and error if any.
    Preempt(*framework.PluginContext, *v1.Pod, error) (selectedNode *v1.Node, preemptedPods []*v1.Pod, cleanupNominatedPods []*v1.Pod, err error)
    // Predicates() returns a pointer to a map of predicate functions. This is
    // exposed for testing.
    Predicates() map[string]predicates.FitPredicate
    // Prioritizers returns a slice of priority config. This is exposed for
    // testing.
    Prioritizers() []priorities.PriorityConfig
    // Extenders returns a slice of extender config. This is exposed for
    // testing.
    Extenders() []algorithm.SchedulerExtender

ScheduleAlgorithm is an interface implemented by things that know how to schedule pods onto machines. TODO: Rename this type.

func NewGenericScheduler Uses

func NewGenericScheduler(
    cache internalcache.Cache,
    podQueue internalqueue.SchedulingQueue,
    predicates map[string]predicates.FitPredicate,
    predicateMetaProducer predicates.PredicateMetadataProducer,
    prioritizers []priorities.PriorityConfig,
    priorityMetaProducer priorities.PriorityMetadataProducer,
    framework framework.Framework,
    extenders []algorithm.SchedulerExtender,
    volumeBinder *volumebinder.VolumeBinder,
    pvcLister corelisters.PersistentVolumeClaimLister,
    pdbLister algorithm.PDBLister,
    alwaysCheckAllPredicates bool,
    disablePreemption bool,
    percentageOfNodesToScore int32,
    enableNonPreempting bool,
) ScheduleAlgorithm

NewGenericScheduler creates a genericScheduler object.

type ScheduleResult Uses

type ScheduleResult struct {
    // Name of the scheduler suggest host
    SuggestedHost string
    // Number of nodes scheduler evaluated on one pod scheduled
    EvaluatedNodes int
    // Number of feasible nodes on one pod scheduled
    FeasibleNodes int

ScheduleResult represents the result of one pod scheduled. It will contain the final selected Node, along with the selected intermediate information.

Package core imports 35 packages (graph) and is imported by 97 packages. Updated 2019-09-21. Refresh now. Tools for package owners.