Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const MaxNodeScore + const MaxTotalScore + const MaxWeight + const MinNodeScore + const NotFound + func DecodeInto(configuration *runtime.Unknown, into interface{}) error + type BindPlugin interface + Bind func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status + type Code int + const Error + const Skip + const Success + const Unschedulable + const UnschedulableAndUnresolvable + const Wait + func (c Code) String() string + type CycleState struct + func NewCycleState() *CycleState + func (c *CycleState) Clone() *CycleState + func (c *CycleState) Delete(key StateKey) + func (c *CycleState) Lock() + func (c *CycleState) RLock() + func (c *CycleState) RUnlock() + func (c *CycleState) Read(key StateKey) (StateData, error) + func (c *CycleState) Unlock() + func (c *CycleState) Write(key StateKey, val StateData) + type FilterPlugin interface + Filter func(ctx context.Context, state *CycleState, pod *v1.Pod, ...) *Status + type Framework interface + HasFilterPlugins func() bool + ListPlugins func() map[string][]config.Plugin + QueueSortFunc func() LessFunc + RunBindPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status + RunFilterPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, ...) *Status + RunPermitPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status + RunPostBindPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) + RunPostFilterPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodes []*v1.Node, ...) *Status + RunPreBindPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status + RunPreFilterExtensionAddPod func(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, ...) *Status + RunPreFilterExtensionRemovePod func(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, ...) *Status + RunPreFilterPlugins func(ctx context.Context, state *CycleState, pod *v1.Pod) *Status + RunReservePlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status + RunScorePlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodes []*v1.Node) (PluginToNodeScores, *Status) + RunUnreservePlugins func(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) + func NewFramework(r Registry, plugins *config.Plugins, args []config.PluginConfig, ...) (Framework, error) + type FrameworkHandle interface + ClientSet func() clientset.Interface + GetWaitingPod func(uid types.UID) WaitingPod + IterateOverWaitingPods func(callback func(WaitingPod)) + NodeInfoSnapshot func() *schedulernodeinfo.Snapshot + SharedInformerFactory func() informers.SharedInformerFactory + type LessFunc func(podInfo1, podInfo2 *PodInfo) bool + type NodeScore struct + Name string + Score int64 + type NodeScoreList []NodeScore + type NodeToStatusMap map[string]*Status + type Option func(*frameworkOptions) + func WithClientSet(clientSet clientset.Interface) Option + func WithInformerFactory(informerFactory informers.SharedInformerFactory) Option + type PermitPlugin interface + Permit func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) (*Status, time.Duration) + type Plugin interface + Name func() string + type PluginFactory = func(configuration *runtime.Unknown, f FrameworkHandle) (Plugin, error) + type PluginToNodeScores map[string]NodeScoreList + type PodInfo struct + Attempts int + InitialAttemptTimestamp time.Time + Pod *v1.Pod + Timestamp time.Time + func (podInfo *PodInfo) DeepCopy() *PodInfo + type PostBindPlugin interface + PostBind func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) + type PostFilterPlugin interface + PostFilter func(ctx context.Context, state *CycleState, pod *v1.Pod, nodes []*v1.Node, ...) *Status + type PreBindPlugin interface + PreBind func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status + type PreFilterExtensions interface + AddPod func(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, ...) *Status + RemovePod func(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, ...) *Status + type PreFilterPlugin interface + PreFilter func(ctx context.Context, state *CycleState, p *v1.Pod) *Status + PreFilterExtensions func() PreFilterExtensions + type QueueSortPlugin interface + Less func(*PodInfo, *PodInfo) bool + type Registry map[string]PluginFactory + func (r Registry) Merge(in Registry) error + func (r Registry) Register(name string, factory PluginFactory) error + func (r Registry) Unregister(name string) error + type ReservePlugin interface + Reserve func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status + type ScoreExtensions interface + NormalizeScore func(ctx context.Context, state *CycleState, p *v1.Pod, scores NodeScoreList) *Status + type ScorePlugin interface + Score func(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) (int64, *Status) + ScoreExtensions func() ScoreExtensions + type StateData interface + Clone func() StateData + type StateKey string + 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(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) + type WaitingPod interface + Allow func(pluginName string) bool + GetPendingPlugins func() []string + GetPod func() *v1.Pod + Reject func(msg string) bool
Go to main page