k8s_scheduler_extender

Documentation

Index

• func AddBind(router *httprouter.Router, bind Bind)
• func AddPredicate(router *httprouter.Router, predicate Predicate)
• func AddPreemption(router *httprouter.Router, preemption Preemption)
• func AddPrioritize(router *httprouter.Router, prioritize Prioritize)
• func AddVersion(router *httprouter.Router)
• func BindRoute(bind Bind) httprouter.Handle
• func DebugLogging(h httprouter.Handle, path string) httprouter.Handle
• func PredicateRoute(predicate Predicate) httprouter.Handle
• func PreemptionRoute(preemption Preemption) httprouter.Handle
• func PrioritizeRoute(prioritize Prioritize) httprouter.Handle
• func StringToLevel(levelStr string) colog.Level
• func VersionRoute(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
• type Bind
  • func (b Bind) Handler(args schedulerapi.ExtenderBindingArgs) *schedulerapi.ExtenderBindingResult
• type Predicate
  • func (p Predicate) Handler(args schedulerapi.ExtenderArgs) *schedulerapi.ExtenderFilterResult
• type Preemption
  • func (b Preemption) Handler(args schedulerapi.ExtenderPreemptionArgs) *schedulerapi.ExtenderPreemptionResult
• type Prioritize
  • func (p Prioritize) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.HostPriorityList, error)

Functions

func AddBind

func AddBind(router *httprouter.Router, bind Bind)

func AddPredicate

func AddPredicate(router *httprouter.Router, predicate Predicate)

func AddPreemption

func AddPreemption(router *httprouter.Router, preemption Preemption)

func AddPrioritize

func AddPrioritize(router *httprouter.Router, prioritize Prioritize)

func AddVersion

func AddVersion(router *httprouter.Router)

func BindRoute

func BindRoute(bind Bind) httprouter.Handle

func DebugLogging

func DebugLogging(h httprouter.Handle, path string) httprouter.Handle

func PredicateRoute

func PredicateRoute(predicate Predicate) httprouter.Handle

func PreemptionRoute

func PreemptionRoute(preemption Preemption) httprouter.Handle

func PrioritizeRoute

func PrioritizeRoute(prioritize Prioritize) httprouter.Handle

func StringToLevel

func StringToLevel(levelStr string) colog.Level

func VersionRoute

func VersionRoute(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

Types

type Bind

type Bind struct {
	Func func(podName string, podNamespace string, podUID types.UID, node string) error
}

func (Bind) Handler

func (b Bind) Handler(args schedulerapi.ExtenderBindingArgs) *schedulerapi.ExtenderBindingResult

type Predicate

type Predicate struct {
	Name string
	Func func(pod v1.Pod, node v1.Node) (bool, error)
}

func (Predicate) Handler

func (p Predicate) Handler(args schedulerapi.ExtenderArgs) *schedulerapi.ExtenderFilterResult

type Preemption

type Preemption struct {
	Func func(
		pod v1.Pod,
		nodeNameToVictims map[string]*schedulerapi.Victims,
		nodeNameToMetaVictims map[string]*schedulerapi.MetaVictims,
	) map[string]*schedulerapi.MetaVictims
}

func (Preemption) Handler

func (b Preemption) Handler(
	args schedulerapi.ExtenderPreemptionArgs,
) *schedulerapi.ExtenderPreemptionResult

type Prioritize

type Prioritize struct {
	Name string
	Func func(pod v1.Pod, nodes []v1.Node) (*schedulerapi.HostPriorityList, error)
}

func (Prioritize) Handler

func (p Prioritize) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.HostPriorityList, error)