Documentation ¶
Overview ¶
Package factory can set up a scheduler. This code is here instead of plugin/cmd/scheduler for both testability and reuse.
Index ¶
- Constants
- func IsFitPredicateRegistered(name string) bool
- func IsPriorityFunctionRegistered(name string) bool
- func ListAlgorithmProviders() string
- func RegisterAlgorithmProvider(name string, predicateKeys, priorityKeys util.StringSet) string
- func RegisterCustomFitPredicate(policy schedulerapi.PredicatePolicy) string
- func RegisterCustomPriorityFunction(policy schedulerapi.PriorityPolicy) string
- func RegisterFitPredicate(name string, predicate algorithm.FitPredicate) string
- func RegisterFitPredicateFactory(name string, predicateFactory FitPredicateFactory) string
- func RegisterPriorityConfigFactory(name string, pcf PriorityConfigFactory) string
- func RegisterPriorityFunction(name string, function algorithm.PriorityFunction, weight int) string
- type AlgorithmProviderConfig
- type ConfigFactory
- func (f *ConfigFactory) Create() (*scheduler.Config, error)
- func (f *ConfigFactory) CreateFromConfig(policy schedulerapi.Policy) (*scheduler.Config, error)
- func (f *ConfigFactory) CreateFromKeys(predicateKeys, priorityKeys util.StringSet) (*scheduler.Config, error)
- func (f *ConfigFactory) CreateFromProvider(providerName string) (*scheduler.Config, error)
- type FitPredicateFactory
- type PluginFactoryArgs
- type PriorityConfigFactory
- type PriorityFunctionFactory
Constants ¶
const (
DefaultProvider = "DefaultProvider"
)
Variables ¶
This section is empty.
Functions ¶
func IsFitPredicateRegistered ¶ added in v0.2.1
This check is useful for testing providers.
func IsPriorityFunctionRegistered ¶ added in v0.2.1
This check is useful for testing providers.
func ListAlgorithmProviders ¶ added in v0.5.1
func ListAlgorithmProviders() string
ListAlgorithmProviders is called when listing all available algortihm providers in `kube-scheduler --help`
func RegisterAlgorithmProvider ¶ added in v0.2.1
Registers a new algorithm provider with the algorithm registry. This should be called from the init function in a provider plugin.
func RegisterCustomFitPredicate ¶ added in v0.4.2
func RegisterCustomFitPredicate(policy schedulerapi.PredicatePolicy) string
Registers a custom fit predicate with the algorithm registry. Returns the name, with which the predicate was registered.
func RegisterCustomPriorityFunction ¶ added in v0.4.2
func RegisterCustomPriorityFunction(policy schedulerapi.PriorityPolicy) string
Registers a custom priority function with the algorithm registry. Returns the name, with which the priority function was registered.
func RegisterFitPredicate ¶ added in v0.2.1
func RegisterFitPredicate(name string, predicate algorithm.FitPredicate) string
RegisterFitPredicate registers a fit predicate with the algorithm registry. Returns the name with which the predicate was registered.
func RegisterFitPredicateFactory ¶ added in v0.4.2
func RegisterFitPredicateFactory(name string, predicateFactory FitPredicateFactory) string
RegisterFitPredicateFactory registers a fit predicate factory with the algorithm registry. Returns the name with which the predicate was registered.
func RegisterPriorityConfigFactory ¶ added in v0.4.2
func RegisterPriorityConfigFactory(name string, pcf PriorityConfigFactory) string
func RegisterPriorityFunction ¶ added in v0.2.1
func RegisterPriorityFunction(name string, function algorithm.PriorityFunction, weight int) string
Registers a priority function with the algorithm registry. Returns the name, with which the function was registered.
Types ¶
type AlgorithmProviderConfig ¶ added in v0.2.1
type AlgorithmProviderConfig struct { FitPredicateKeys util.StringSet PriorityFunctionKeys util.StringSet }
func GetAlgorithmProvider ¶ added in v0.2.1
func GetAlgorithmProvider(name string) (*AlgorithmProviderConfig, error)
This function should not be used to modify providers. It is publicly visible for testing.
type ConfigFactory ¶
type ConfigFactory struct { Client *client.Client // queue for pods that need scheduling PodQueue *cache.FIFO // a means to list all known scheduled pods. ScheduledPodLister *cache.StoreToPodLister // a means to list all known scheduled pods and pods assumed to have been scheduled. PodLister algorithm.PodLister // a means to list all minions NodeLister *cache.StoreToNodeLister // a means to list all services ServiceLister *cache.StoreToServiceLister // Close this to stop all reflectors StopEverything chan struct{} // contains filtered or unexported fields }
ConfigFactory knows how to fill out a scheduler config with its support functions.
func NewConfigFactory ¶ added in v0.2.1
func NewConfigFactory(client *client.Client) *ConfigFactory
Initializes the factory.
func (*ConfigFactory) Create ¶
func (f *ConfigFactory) Create() (*scheduler.Config, error)
Create creates a scheduler with the default algorithm provider.
func (*ConfigFactory) CreateFromConfig ¶ added in v0.4.2
func (f *ConfigFactory) CreateFromConfig(policy schedulerapi.Policy) (*scheduler.Config, error)
Creates a scheduler from the configuration file
func (*ConfigFactory) CreateFromKeys ¶ added in v0.2.1
func (f *ConfigFactory) CreateFromKeys(predicateKeys, priorityKeys util.StringSet) (*scheduler.Config, error)
Creates a scheduler from a set of registered fit predicate keys and priority keys.
func (*ConfigFactory) CreateFromProvider ¶ added in v0.2.1
func (f *ConfigFactory) CreateFromProvider(providerName string) (*scheduler.Config, error)
Creates a scheduler from the name of a registered algorithm provider.
type FitPredicateFactory ¶ added in v0.4.2
type FitPredicateFactory func(PluginFactoryArgs) algorithm.FitPredicate
A FitPredicateFactory produces a FitPredicate from the given args.
type PluginFactoryArgs ¶ added in v0.4.2
type PluginFactoryArgs struct { algorithm.PodLister algorithm.ServiceLister NodeLister algorithm.MinionLister NodeInfo predicates.NodeInfo }
PluginFactoryArgs are passed to all plugin factory functions.
type PriorityConfigFactory ¶ added in v0.4.2
type PriorityConfigFactory struct { Function PriorityFunctionFactory Weight int }
A PriorityConfigFactory produces a PriorityConfig from the given function and weight
type PriorityFunctionFactory ¶ added in v0.4.3
type PriorityFunctionFactory func(PluginFactoryArgs) algorithm.PriorityFunction
A PriorityFunctionFactory produces a PriorityConfig from the given args.