type TaintToleration … var _ … var _ … var _ … var _ … const Name … const preScoreStateKey … const ErrReasonNotMatch … // Name returns name of the plugin. It is used in logs, etc. func (pl *TaintToleration) Name() string { … } // EventsToRegister returns the possible events that may make a Pod // failed by this plugin schedulable. func (pl *TaintToleration) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … } // isSchedulableAfterNodeChange is invoked for all node events reported by // an informer. It checks whether that change made a previously unschedulable // pod schedulable. func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } // Filter invoked at the filter extension point. func (pl *TaintToleration) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { … } type preScoreState … // Clone implements the mandatory Clone interface. We don't really copy the data since // there is no need for that. func (s *preScoreState) Clone() framework.StateData { … } // getAllTolerationEffectPreferNoSchedule gets the list of all Tolerations with Effect PreferNoSchedule or with no effect. func getAllTolerationPreferNoSchedule(tolerations []v1.Toleration) (tolerationList []v1.Toleration) { … } // PreScore builds and writes cycle state used by Score and NormalizeScore. func (pl *TaintToleration) PreScore(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status { … } func getPreScoreState(cycleState *framework.CycleState) (*preScoreState, error) { … } // CountIntolerableTaintsPreferNoSchedule gives the count of intolerable taints of a pod with effect PreferNoSchedule func countIntolerableTaintsPreferNoSchedule(taints []v1.Taint, tolerations []v1.Toleration) (intolerableTaints int) { … } // Score invoked at the Score extension point. func (pl *TaintToleration) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status) { … } // NormalizeScore invoked after scoring all nodes. func (pl *TaintToleration) NormalizeScore(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status { … } // ScoreExtensions of the Score plugin. func (pl *TaintToleration) ScoreExtensions() framework.ScoreExtensions { … } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, h framework.Handle, fts feature.Features) (framework.Plugin, error) { … } // isSchedulableAfterPodTolerationChange is invoked whenever a pod's toleration changed. func (pl *TaintToleration) isSchedulableAfterPodTolerationChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … }
Codebase Browser
kubernetes