extender

Documentation

Index

• Constants
• func OverrideExtendersCfgToSimulator(cfg *configv1.KubeSchedulerConfiguration, simulatorPort int)
• type Extender
• type Service
  • func New(client clientset.Interface, extenderCfgs []configv1.Extender, ...) (*Service, error)
  • 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

const (
	// DefaultExtenderTimeout defines the default extender timeout in second.
	DefaultExtenderTimeout = 5 * time.Second
)

const ResultStoreKey = "ExtenderResultStoreKey"

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.