Documentation
¶
Index ¶
- Variables
- func New(pluginRegistry framework.PluginMap, ...) framework.BinderFramework
- type GodelFramework
- func (f *GodelFramework) HasCheckConflictsPlugins() bool
- func (f *GodelFramework) HasCheckTopologyPlugins() bool
- func (f *GodelFramework) HasPlugin(pluginName string) bool
- func (f *GodelFramework) InitCycleState(pod *v1.Pod) (*framework.CycleState, error)
- func (f *GodelFramework) ListPlugins() map[string]sets.String
- func (f *GodelFramework) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
- func (f *GodelFramework) RunCheckConflictsPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) framework.PluginToStatus
- func (f *GodelFramework) RunCheckTopologyPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) framework.PluginToStatus
- func (f *GodelFramework) RunClusterPrePreemptingPlugins(preemptor *v1.Pod, state, commonState *framework.CycleState) *framework.Status
- func (f *GodelFramework) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
- func (f *GodelFramework) RunPostBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
- func (f *GodelFramework) RunPostVictimCheckingPlugins(preemptor, pod *v1.Pod, state, commonState *framework.CycleState) *framework.Status
- func (f *GodelFramework) RunPreBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
- func (f *GodelFramework) RunReservePluginsReserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
- func (f *GodelFramework) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
- func (f *GodelFramework) RunVictimCheckingPlugins(preemptor, pod *v1.Pod, state, commonState *framework.CycleState) *framework.Status
- func (f *GodelFramework) WaitOnPermit(ctx context.Context, pod *v1.Pod) (status *framework.Status)
Constants ¶
This section is empty.
Variables ¶
var DefaultGangTimeout = 5 * time.Minute
Functions ¶
func New ¶
func New( pluginRegistry framework.PluginMap, preemptionPluginRegistry framework.PluginMap, basePlugins *apis.BinderPluginCollection, ) framework.BinderFramework
New creates a new GodelBinderFramework, where pluginRegistry marks which plugins are supported, basePlugins presents which plugins are enabled by default. podConstraintConfigs are used in pod annotation, where hard constraint will be taken as filter plugins and soft constraint will be taken as score plugins. If plugin in podConstraintConfigs not exists in basePlugins, add this plugin to the new Godel Framework.
Types ¶
type GodelFramework ¶
type GodelFramework struct {
// contains filtered or unexported fields
}
GodelFramework is the component responsible for initializing and running scheduler plugins, determining plugins to run in each scheduling phase(or extension point)
func (*GodelFramework) HasCheckConflictsPlugins ¶
func (f *GodelFramework) HasCheckConflictsPlugins() bool
func (*GodelFramework) HasCheckTopologyPlugins ¶
func (f *GodelFramework) HasCheckTopologyPlugins() bool
func (*GodelFramework) HasPlugin ¶
func (f *GodelFramework) HasPlugin(pluginName string) bool
func (*GodelFramework) InitCycleState ¶
func (f *GodelFramework) InitCycleState(pod *v1.Pod) (*framework.CycleState, error)
func (*GodelFramework) ListPlugins ¶
func (f *GodelFramework) ListPlugins() map[string]sets.String
func (*GodelFramework) RunBindPlugins ¶
func (f *GodelFramework) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
RunBindPlugins runs the set of configured bind plugins until one returns a non `Skip` status.
func (*GodelFramework) RunCheckConflictsPlugins ¶
func (f *GodelFramework) RunCheckConflictsPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo framework.NodeInfo) framework.PluginToStatus
func (*GodelFramework) RunCheckTopologyPlugins ¶
func (f *GodelFramework) RunCheckTopologyPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo framework.NodeInfo) framework.PluginToStatus
func (*GodelFramework) RunClusterPrePreemptingPlugins ¶
func (f *GodelFramework) RunClusterPrePreemptingPlugins(preemptor *v1.Pod, state, commonState *framework.CycleState) *framework.Status
func (*GodelFramework) RunPermitPlugins ¶
func (f *GodelFramework) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
RunPermitPlugins runs the set of configured permit plugins. If any of these plugins returns a status other than "Success" or "Wait", it does not continue running the remaining plugins and returns an error. Otherwise, if any of the plugins returns "Wait", then this function will create and add waiting pod to a map of currently waiting pods and return status with "Wait" code. Pod will remain waiting pod for the minimum duration returned by the permit plugins.
func (*GodelFramework) RunPostBindPlugins ¶
func (f *GodelFramework) RunPostBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
RunPostBindPlugins runs the set of configured postbind plugins.
func (*GodelFramework) RunPostVictimCheckingPlugins ¶
func (f *GodelFramework) RunPostVictimCheckingPlugins(preemptor, pod *v1.Pod, state, commonState *framework.CycleState) *framework.Status
func (*GodelFramework) RunPreBindPlugins ¶
func (f *GodelFramework) RunPreBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
RunPreBindPlugins runs the set of configured binder plugins. It returns a failure (bool) if any of the plugins returns an error. It also returns an error containing the rejection message or the error occurred in the plugin.
func (*GodelFramework) RunReservePluginsReserve ¶
func (f *GodelFramework) RunReservePluginsReserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
RunReservePluginsReserve runs the Reserve method in the set of configured reserve plugins. If any of these plugins returns an error, it does not continue running the remaining ones and returns the error. In such a case, the pod will not be scheduled and the caller will be expected to call RunReservePluginsUnreserve.
func (*GodelFramework) RunReservePluginsUnreserve ¶
func (f *GodelFramework) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
RunReservePluginsUnreserve runs the Unreserve method in the set of configured reserve plugins.
func (*GodelFramework) RunVictimCheckingPlugins ¶
func (f *GodelFramework) RunVictimCheckingPlugins(preemptor, pod *v1.Pod, state, commonState *framework.CycleState) *framework.Status
func (*GodelFramework) WaitOnPermit ¶
WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
Source Files