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
- Variables
- func IsFitPredicateRegistered(key string) bool
- func IsPriorityFunctionRegistered(key string) bool
- func RegisterAlgorithmProvider(name string, predicateKeys, priorityKeys util.StringSet) string
- func RegisterFitPredicate(key string, predicate algorithm.FitPredicate) string
- func RegisterPriorityFunction(key string, function algorithm.PriorityFunction, weight int) string
- func SetPriorityFunctionWeight(key string, weight int)
- type AlgorithmProviderConfig
- type ConfigFactory
Constants ¶
const (
DefaultProvider = "default"
)
Variables ¶
var ( PodLister = &cache.StoreToPodLister{cache.NewStore()} MinionLister = &cache.StoreToNodeLister{cache.NewStore()} ServiceLister = &cache.StoreToServiceLister{cache.NewStore()} )
Functions ¶
func IsFitPredicateRegistered ¶
IsFitPredicateRegistered check is useful for testing providers.
func IsPriorityFunctionRegistered ¶
IsPriorityFunctionRegistered check is useful for testing providers.
func RegisterAlgorithmProvider ¶
RegisterAlgorithmProvider registers a new algorithm provider with the algorithm registry. This should be called from the init function in a provider plugin.
func RegisterFitPredicate ¶
func RegisterFitPredicate(key string, predicate algorithm.FitPredicate) string
RegisterFitPredicate registers a fit predicate with the algorithm registry. Returns the key, with which the predicate was registered.
func RegisterPriorityFunction ¶
func RegisterPriorityFunction(key string, function algorithm.PriorityFunction, weight int) string
RegisterFitPredicate registers a priority function with the algorithm registry. Returns the key, with which the function was registered.
func SetPriorityFunctionWeight ¶
SetPriorityFunctionWeight sets the weight of an already registered priority function.
Types ¶
type AlgorithmProviderConfig ¶
type AlgorithmProviderConfig struct {
FitPredicateKeys util.StringSet
PriorityFunctionKeys util.StringSet
}
func GetAlgorithmProvider ¶
func GetAlgorithmProvider(name string) (*AlgorithmProviderConfig, error)
GetAlgorithmProvider 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 scheduled pods
PodLister *cache.StoreToPodLister
// a means to list all minions
MinionLister *cache.StoreToNodeLister
// a means to list all services
ServiceLister *cache.StoreToServiceLister
}
ConfigFactory knows how to fill out a scheduler config with its support functions.
func NewConfigFactory ¶
func NewConfigFactory(client *client.Client) *ConfigFactory
NewConfigFactory initializes the factory.
func (*ConfigFactory) Create ¶
func (f *ConfigFactory) Create() (*scheduler.Config, error)
Create creates a scheduler with the default algorithm provider.
func (*ConfigFactory) CreateFromKeys ¶
func (f *ConfigFactory) CreateFromKeys(predicateKeys, priorityKeys util.StringSet) (*scheduler.Config, error)
CreateFromKeys creates a scheduler from a set of registered fit predicate keys and priority keys.
func (*ConfigFactory) CreateFromProvider ¶
func (f *ConfigFactory) CreateFromProvider(providerName string) (*scheduler.Config, error)
CreateFromProvider creates a scheduler from the name of a registered algorithm provider.
Source Files