Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const MaxNodeScore + const MinNodeScore + const NotFound + func DecodeInto(configuration *runtime.Unknown, into interface{}) error + type BindPlugin interface + Bind func(pc *PluginContext, p *v1.Pod, nodeName string) *Status + type Code int + const Error + const Skip + const Success + const Unschedulable + const UnschedulableAndUnresolvable + const Wait + type ContextData interface + type ContextKey string + type FilterPlugin interface + Filter func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + type Framework interface + QueueSortFunc func() LessFunc + RunBindPlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + RunFilterPlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + RunPermitPlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + RunPostBindPlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) + RunPostFilterPlugins func(pc *PluginContext, pod *v1.Pod, nodes []*v1.Node, ...) *Status + RunPreBindPlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + RunPreFilterPlugins func(pc *PluginContext, pod *v1.Pod) *Status + RunReservePlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) *Status + RunScorePlugins func(pc *PluginContext, pod *v1.Pod, nodes []*v1.Node) (PluginToNodeScores, *Status) + RunUnreservePlugins func(pc *PluginContext, pod *v1.Pod, nodeName string) + func NewFramework(r Registry, plugins *config.Plugins, args []config.PluginConfig) (Framework, error) + type FrameworkHandle interface + GetWaitingPod func(uid types.UID) WaitingPod + IterateOverWaitingPods func(callback func(WaitingPod)) + NodeInfoSnapshot func() *schedulernodeinfo.Snapshot + type LessFunc func(podInfo1, podInfo2 *PodInfo) bool + type NodeScore struct + Name string + Score int + type NodeScoreList []NodeScore + type NodeToStatusMap map[string]*Status + type PermitPlugin interface + Permit func(pc *PluginContext, p *v1.Pod, nodeName string) (*Status, time.Duration) + type Plugin interface + Name func() string + type PluginContext struct + func NewPluginContext() *PluginContext + func (c *PluginContext) Delete(key ContextKey) + func (c *PluginContext) Lock() + func (c *PluginContext) RLock() + func (c *PluginContext) RUnlock() + func (c *PluginContext) Read(key ContextKey) (ContextData, error) + func (c *PluginContext) Unlock() + func (c *PluginContext) Write(key ContextKey, val ContextData) + type PluginFactory = func(configuration *runtime.Unknown, f FrameworkHandle) (Plugin, error) + type PluginToNodeScores map[string]NodeScoreList + type PodInfo struct + Pod *v1.Pod + Timestamp time.Time + type PostBindPlugin interface + PostBind func(pc *PluginContext, p *v1.Pod, nodeName string) + type PostFilterPlugin interface + PostFilter func(pc *PluginContext, pod *v1.Pod, nodes []*v1.Node, ...) *Status + type PreBindPlugin interface + PreBind func(pc *PluginContext, p *v1.Pod, nodeName string) *Status + type PreFilterPlugin interface + PreFilter func(pc *PluginContext, p *v1.Pod) *Status + type QueueSortPlugin interface + Less func(*PodInfo, *PodInfo) bool + type Registry map[string]PluginFactory + func NewRegistry() Registry + func (r Registry) Register(name string, factory PluginFactory) error + func (r Registry) Unregister(name string) error + type ReservePlugin interface + Reserve func(pc *PluginContext, p *v1.Pod, nodeName string) *Status + type ScorePlugin interface + Score func(pc *PluginContext, p *v1.Pod, nodeName string) (int, *Status) + type ScoreWithNormalizePlugin interface + NormalizeScore func(pc *PluginContext, p *v1.Pod, scores NodeScoreList) *Status + type Status struct + func NewStatus(code Code, msg string) *Status + func (s *Status) AsError() error + func (s *Status) Code() Code + func (s *Status) IsSuccess() bool + func (s *Status) IsUnschedulable() bool + func (s *Status) Message() string + type UnreservePlugin interface + Unreserve func(pc *PluginContext, p *v1.Pod, nodeName string) + type WaitingPod interface + Allow func() bool + GetPod func() *v1.Pod + Reject func(msg string) bool
Go to main page