Documentation
¶
Index ¶
- Constants
- func AddBind(router *httprouter.Router, bind bind.Bind)
- func AddGetNodeCache(router *httprouter.Router, ctx *algorithm.SchedulingContext)
- func AddMetrics(router *httprouter.Router, ctx *algorithm.SchedulingContext)
- func AddPredicate(router *httprouter.Router, predicate predicates.Predicate)
- func AddPreemption(router *httprouter.Router, preemption preemptions.Preemption)
- func AddPrioritize(router *httprouter.Router, prioritize priorities.Prioritize)
- func AddSchedulingApis(router *httprouter.Router, ctx *algorithm.SchedulingContext)
- func AddVersion(router *httprouter.Router)
- func BindRoute(bind bind.Bind) httprouter.Handle
- func DebugLogging(h httprouter.Handle, path string) httprouter.Handle
- func PredicateRoute(predicate predicates.Predicate) httprouter.Handle
- func PreemptionRoute(preemption preemptions.Preemption) httprouter.Handle
- func PrioritizeRoute(prioritize priorities.Prioritize) httprouter.Handle
- func SchedulingPVCWrap(ctx *algorithm.SchedulingContext) httprouter.Handle
- func VersionRoute(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
- type ExtenderServer
Constants ¶
View Source
const (
MaxConcurrentWorkingRoutines = 5
)
Variables ¶
This section is empty.
Functions ¶
func AddGetNodeCache ¶
func AddGetNodeCache(router *httprouter.Router, ctx *algorithm.SchedulingContext)
func AddMetrics ¶
func AddMetrics(router *httprouter.Router, ctx *algorithm.SchedulingContext)
func AddPredicate ¶
func AddPredicate(router *httprouter.Router, predicate predicates.Predicate)
func AddPreemption ¶
func AddPreemption(router *httprouter.Router, preemption preemptions.Preemption)
func AddPrioritize ¶
func AddPrioritize(router *httprouter.Router, prioritize priorities.Prioritize)
func AddSchedulingApis ¶
func AddSchedulingApis(router *httprouter.Router, ctx *algorithm.SchedulingContext)
func AddVersion ¶
func AddVersion(router *httprouter.Router)
func DebugLogging ¶
func DebugLogging(h httprouter.Handle, path string) httprouter.Handle
func PredicateRoute ¶
func PredicateRoute(predicate predicates.Predicate) httprouter.Handle
func PreemptionRoute ¶
func PreemptionRoute(preemption preemptions.Preemption) httprouter.Handle
func PrioritizeRoute ¶
func PrioritizeRoute(prioritize priorities.Prioritize) httprouter.Handle
func SchedulingPVCWrap ¶
func SchedulingPVCWrap(ctx *algorithm.SchedulingContext) httprouter.Handle
SchedulingPVCWrap handles the request during volume provisioning
func VersionRoute ¶
func VersionRoute(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
Types ¶
type ExtenderServer ¶
type ExtenderServer struct {
Ctx *algorithm.SchedulingContext
// contains filtered or unexported fields
}
func NewExtenderServer ¶
func NewExtenderServer( kubeClient kubernetes.Interface, localclient clientset.Interface, snapClient volumesnapshot.Interface, kubeInformerFactory kubeinformers.SharedInformerFactory, localStorageInformerFactory informers.SharedInformerFactory, volumesnapshotInformerFactory volumesnapshotinformers.SharedInformerFactory, port int32, weights *pkg.NodeAntiAffinityWeight, ) *ExtenderServer
func (*ExtenderServer) InitRouter ¶
func (e *ExtenderServer) InitRouter()
func (*ExtenderServer) Start ¶
func (e *ExtenderServer) Start(stopCh <-chan struct{})
func (*ExtenderServer) TriggerPendingPodReschedule ¶
func (e *ExtenderServer) TriggerPendingPodReschedule(stopCh <-chan struct{})
func (*ExtenderServer) WaitForCacheSync ¶
func (e *ExtenderServer) WaitForCacheSync(stopCh <-chan struct{})
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.