server

Documentation

Index

• Constants
• func AddBind(router *httprouter.Router, bind bind.Bind)
• func AddGetNodeCache(router *httprouter.Router, ctx *algorithm.SchedulingContext)
• func AddMetrics(router *httprouter.Router)
• 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 SchedulingExpandWrap(ctx *algorithm.SchedulingContext) httprouter.Handle
• func SchedulingPVCWrap(ctx *algorithm.SchedulingContext) httprouter.Handle
• func VersionRoute(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
• type ExtenderServer
  • func NewExtenderServer(kubeClient kubernetes.Interface, lss clientset.Interface, ...) *ExtenderServer
  • func (e *ExtenderServer) InitRouter()
  • func (e *ExtenderServer) Start(stopCh <-chan struct{})
  • func (e *ExtenderServer) TriggerPendingPodReschedule(stopCh <-chan struct{})
  • func (e *ExtenderServer) WaitForCacheSync(stopCh <-chan struct{})

Constants

const (
	MaxConcurrentWorkingRoutines = 5
)

Functions

func AddBind

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

func AddGetNodeCache

func AddGetNodeCache(router *httprouter.Router, ctx *algorithm.SchedulingContext)

func AddMetrics

func AddMetrics(router *httprouter.Router)

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 BindRoute

func BindRoute(bind bind.Bind) httprouter.Handle

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 SchedulingExpandWrap

func SchedulingExpandWrap(ctx *algorithm.SchedulingContext) httprouter.Handle

SchedulingExpandWrap handles the request from volume expansion for the open-local controller

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,
	lss 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{})