scheduler

Sep 25, 2018

Changes in this version

type Scheduler

+ func (sched *Scheduler) Cache() schedulercache.Cache

Jun 27, 2018

Changes in this version

type Config

+ DisablePreemption bool

Mar 23, 2018

Changes in this version

+ type Binder interface

+ Bind func(binding *v1.Binding) error

+ type Config struct

+ Algorithm algorithm.ScheduleAlgorithm

+ Ecache *core.EquivalenceCache

+ Error func(*v1.Pod, error)

+ GetBinder func(pod *v1.Pod) Binder

+ NextPod func() *v1.Pod

+ NodeLister algorithm.NodeLister

+ PodConditionUpdater PodConditionUpdater

+ PodPreemptor PodPreemptor

+ Recorder record.EventRecorder

+ SchedulerCache schedulercache.Cache

+ StopEverything chan struct{}

+ VolumeBinder *volumebinder.VolumeBinder

+ WaitForCacheSync func() bool

+ type Configurator interface

+ Create func() (*Config, error)

+ CreateFromConfig func(policy schedulerapi.Policy) (*Config, error)

+ CreateFromKeys func(predicateKeys, priorityKeys sets.String, ...) (*Config, error)

+ CreateFromProvider func(providerName string) (*Config, error)

+ GetClient func() clientset.Interface

+ GetHardPodAffinitySymmetricWeight func() int32

+ GetNodeLister func() corelisters.NodeLister

+ GetPredicateMetadataProducer func() (algorithm.PredicateMetadataProducer, error)

+ GetPredicates func(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error)

+ GetPriorityFunctionConfigs func(priorityKeys sets.String) ([]algorithm.PriorityConfig, error)

+ GetPriorityMetadataProducer func() (algorithm.PriorityMetadataProducer, error)

+ GetScheduledPodLister func() corelisters.PodLister

+ GetSchedulerName func() string

+ MakeDefaultErrorFunc func(backoff *util.PodBackoff, podQueue core.SchedulingQueue) func(pod *v1.Pod, err error)

+ type FakeConfigurator struct

+ Config *Config

+ func (fc *FakeConfigurator) Create() (*Config, error)

+ func (fc *FakeConfigurator) CreateFromConfig(policy schedulerapi.Policy) (*Config, error)

+ func (fc *FakeConfigurator) CreateFromKeys(predicateKeys, priorityKeys sets.String, ...) (*Config, error)

+ func (fc *FakeConfigurator) CreateFromProvider(providerName string) (*Config, error)

+ func (fc *FakeConfigurator) GetClient() clientset.Interface

+ func (fc *FakeConfigurator) GetHardPodAffinitySymmetricWeight() int32

+ func (fc *FakeConfigurator) GetNodeLister() corelisters.NodeLister

+ func (fc *FakeConfigurator) GetPredicateMetadataProducer() (algorithm.PredicateMetadataProducer, error)

+ func (fc *FakeConfigurator) GetPredicates(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error)

+ func (fc *FakeConfigurator) GetPriorityFunctionConfigs(priorityKeys sets.String) ([]algorithm.PriorityConfig, error)

+ func (fc *FakeConfigurator) GetPriorityMetadataProducer() (algorithm.PriorityMetadataProducer, error)

+ func (fc *FakeConfigurator) GetScheduledPodLister() corelisters.PodLister

+ func (fc *FakeConfigurator) GetSchedulerName() string

+ func (fc *FakeConfigurator) MakeDefaultErrorFunc(backoff *util.PodBackoff, podQueue core.SchedulingQueue) func(pod *v1.Pod, err error)

+ type PodConditionUpdater interface

+ Update func(pod *v1.Pod, podCondition *v1.PodCondition) error

+ type PodPreemptor interface

+ DeletePod func(pod *v1.Pod) error

+ GetUpdatedPod func(pod *v1.Pod) (*v1.Pod, error)

+ RemoveNominatedNodeName func(pod *v1.Pod) error

+ SetNominatedNodeName func(pod *v1.Pod, nominatedNode string) error

type Scheduler

+ func NewFromConfig(config *Config) *Scheduler

+ func NewFromConfigurator(c Configurator, modifiers ...func(c *Config)) (*Scheduler, error)

+ func (sched *Scheduler) Config() *Config

+ func (sched *Scheduler) Run()

+ func (sched *Scheduler) StopEverything()

Apr 13, 2015

Changes in this version

type HostPriorityList

+ func BalancedResourceAllocation(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

Mar 30, 2015

Changes in this version

+ func CheckPodsExceedingCapacity(pods []api.Pod, capacity api.ResourceList) (fitting []api.Pod, notFitting []api.Pod)

+ func PodMatchesNodeLabels(pod *api.Pod, node *api.Node) bool

Mar 3, 2015

Changes in this version

+ type FailedPredicateMap map[string]util.StringSet

+ type FitError struct

+ FailedPredicates FailedPredicateMap

+ Pod api.Pod

+ func (f *FitError) Error() string

Jan 21, 2015

Changes in this version

type FakePodLister

+ func (f FakePodLister) List(s labels.Selector) (selected []api.Pod, err error)

+ type FakeServiceLister []api.Service

+ func (f FakeServiceLister) GetPodServices(pod api.Pod) (services []api.Service, err error)

+ func (f FakeServiceLister) List() (api.ServiceList, error)

type FitPredicate

+ func NewNodeLabelPredicate(info NodeInfo, labels []string, presence bool) FitPredicate

+ func NewServiceAffinityPredicate(podLister PodLister, serviceLister ServiceLister, nodeInfo NodeInfo, ...) FitPredicate

+ type NodeLabelChecker struct

+ func (n *NodeLabelChecker) CheckNodeLabelPresence(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

+ type NodeLabelPrioritizer struct

+ func (n *NodeLabelPrioritizer) CalculateNodeLabelPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

type PodLister

+ List func(labels.Selector) ([]api.Pod, error)

type PriorityFunction

+ func NewNodeLabelPriority(label string, presence bool) PriorityFunction

+ func NewServiceAntiAffinityPriority(serviceLister ServiceLister, label string) PriorityFunction

+ func NewServiceSpreadPriority(serviceLister ServiceLister) PriorityFunction

+ type ServiceAffinity struct

+ func (s *ServiceAffinity) CheckServiceAffinity(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

+ type ServiceAntiAffinity struct

+ func (s *ServiceAntiAffinity) CalculateAntiAffinityPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

+ type ServiceLister interface

+ GetPodServices func(api.Pod) ([]api.Service, error)

+ List func() (api.ServiceList, error)

+ type ServiceSpread struct

+ func (s *ServiceSpread) CalculateSpreadPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

Jan 7, 2015

Changes in this version

+ func PodFitsHost(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

Dec 16, 2014

Changes in this version

+ type PriorityConfig struct

+ Function PriorityFunction

+ Weight int

Nov 18, 2014

Changes in this version

+ func NoDiskConflict(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

type FitPredicate

+ func NewSelectorMatchPredicate(info NodeInfo) FitPredicate

+ type NodeSelector struct

+ func (n *NodeSelector) PodSelectorMatches(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

Oct 17, 2014

Changes in this version

+ func MapPodsToMachines(lister PodLister) (map[string][]api.Pod, error)

+ func PodFitsPorts(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

+ type ClientNodeInfo struct

+ func (nodes ClientNodeInfo) GetNodeInfo(nodeID string) (*api.Minion, error)

+ type FakeMinionLister api.MinionList

+ func (f FakeMinionLister) List() (api.MinionList, error)

+ type FakePodLister []api.Pod

+ func (f FakePodLister) ListPods(s labels.Selector) (selected []api.Pod, err error)

+ type FitPredicate func(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

+ func NewResourceFitPredicate(info NodeInfo) FitPredicate

+ type HostPriority struct

+ type HostPriorityList []HostPriority

+ func CalculateSpreadPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

+ func EqualPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

+ func LeastRequestedPriority(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

+ func (h HostPriorityList) Len() int

+ func (h HostPriorityList) Less(i, j int) bool

+ func (h HostPriorityList) Swap(i, j int)

+ type MinionLister interface

+ List func() (list api.MinionList, err error)

+ type NodeInfo interface

+ GetNodeInfo func(nodeID string) (*api.Minion, error)

+ type PodLister interface

+ ListPods func(labels.Selector) ([]api.Pod, error)

+ type PriorityFunction func(pod api.Pod, podLister PodLister, minionLister MinionLister) (HostPriorityList, error)

+ type ResourceFit struct

+ func (r *ResourceFit) PodFitsResources(pod api.Pod, existingPods []api.Pod, node string) (bool, error)

+ type Scheduler interface

+ Schedule func(api.Pod, MinionLister) (selectedMachine string, err error)

+ func NewGenericScheduler(predicates []FitPredicate, prioritizer PriorityFunction, pods PodLister, ...) Scheduler

+ func NewSpreadingScheduler(podLister PodLister, minionLister MinionLister, predicates []FitPredicate, ...) Scheduler

+ type StaticNodeInfo struct

+ func (nodes StaticNodeInfo) GetNodeInfo(nodeID string) (*api.Minion, error)