Documentation
¶
Index ¶
- Constants
- func OverrideExtendersCfgToSimulator(cfg *configv1.KubeSchedulerConfiguration, simulatorPort int)
- type Extender
- type Service
- func (s *Service) Bind(id int, args extenderv1.ExtenderBindingArgs) (*extenderv1.ExtenderBindingResult, error)
- func (s *Service) Filter(id int, args extenderv1.ExtenderArgs) (*extenderv1.ExtenderFilterResult, error)
- func (s *Service) Preempt(id int, args extenderv1.ExtenderPreemptionArgs) (*extenderv1.ExtenderPreemptionResult, error)
- func (s *Service) Prioritize(id int, args extenderv1.ExtenderArgs) (*extenderv1.HostPriorityList, error)
Constants ¶
View Source
const ( // DefaultExtenderTimeout defines the default extender timeout in second. DefaultExtenderTimeout = 5 * time.Second )
View Source
const ResultStoreKey = "ExtenderResultStoreKey"
Variables ¶
This section is empty.
Functions ¶
func OverrideExtendersCfgToSimulator ¶
func OverrideExtendersCfgToSimulator(cfg *configv1.KubeSchedulerConfiguration, simulatorPort int)
OverrideExtendersCfgToSimulator rewrites the scheduler config so that the extenders requests go through the simulator server.
Types ¶
type Extender ¶
type Extender interface {
Name() string
Filter(args extenderv1.ExtenderArgs) (*extenderv1.ExtenderFilterResult, error)
Prioritize(args extenderv1.ExtenderArgs) (*extenderv1.HostPriorityList, error)
Preempt(args extenderv1.ExtenderPreemptionArgs) (*extenderv1.ExtenderPreemptionResult, error)
Bind(args extenderv1.ExtenderBindingArgs) (*extenderv1.ExtenderBindingResult, error)
}
Extender provides methods to call the actual extender's endpoint set by user.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service manages Extenders and the result.
func New ¶
func New(client clientset.Interface, extenderCfgs []configv1.Extender, storeReflector storereflector.Reflector) (*Service, error)
New initializes Service. `extenderCfgs` expect to receive an untouched config file(set by user).
func (*Service) Bind ¶
func (s *Service) Bind(id int, args extenderv1.ExtenderBindingArgs) (*extenderv1.ExtenderBindingResult, error)
Bind returns the result of the specified bind extender and store it.
func (*Service) Filter ¶
func (s *Service) Filter(id int, args extenderv1.ExtenderArgs) (*extenderv1.ExtenderFilterResult, error)
Filter returns the result of the specified filter extender and store it.
func (*Service) Preempt ¶
func (s *Service) Preempt(id int, args extenderv1.ExtenderPreemptionArgs) (*extenderv1.ExtenderPreemptionResult, error)
Preempt returns the result of the specified preempt extender and store it.
func (*Service) Prioritize ¶
func (s *Service) Prioritize(id int, args extenderv1.ExtenderArgs) (*extenderv1.HostPriorityList, error)
Prioritize returns the result of the specified prioritize extender and store it.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mock_extender is a generated GoMock package.
|
Package mock_extender is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.