type NodeAffinity … var _ … var _ … var _ … var _ … var _ … const Name … const preScoreStateKey … const preFilterStateKey … const ErrReasonPod … const errReasonEnforced … const errReasonConflict … // Name returns name of the plugin. It is used in logs, etc. func (pl *NodeAffinity) Name() string { … } type preFilterState … // Clone just returns the same state because it is not affected by pod additions or deletions. func (s *preFilterState) Clone() framework.StateData { … } // EventsToRegister returns the possible events that may make a Pod // failed by this plugin schedulable. func (pl *NodeAffinity) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … } // isSchedulableAfterNodeChange is invoked whenever a node changed. It checks whether // that change made a previously unschedulable pod schedulable. func (pl *NodeAffinity) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } // PreFilter builds and writes cycle state used by Filter. func (pl *NodeAffinity) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … } // PreFilterExtensions not necessary for this plugin as state doesn't depend on pod additions or deletions. func (pl *NodeAffinity) PreFilterExtensions() framework.PreFilterExtensions { … } // Filter checks if the Node matches the Pod .spec.affinity.nodeAffinity and // the plugin's added affinity. func (pl *NodeAffinity) 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 { … } // PreScore builds and writes cycle state used by Score and NormalizeScore. func (pl *NodeAffinity) PreScore(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status { … } // Score returns the sum of the weights of the terms that match the Node. // Terms came from the Pod .spec.affinity.nodeAffinity and from the plugin's // default affinity. func (pl *NodeAffinity) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status) { … } // NormalizeScore invoked after scoring all nodes. func (pl *NodeAffinity) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status { … } // ScoreExtensions of the Score plugin. func (pl *NodeAffinity) ScoreExtensions() framework.ScoreExtensions { … } // New initializes a new plugin and returns it. func New(_ context.Context, plArgs runtime.Object, h framework.Handle, fts feature.Features) (framework.Plugin, error) { … } func getArgs(obj runtime.Object) (config.NodeAffinityArgs, error) { … } func getPodPreferredNodeAffinity(pod *v1.Pod) (*nodeaffinity.PreferredSchedulingTerms, error) { … } func getPreScoreState(cycleState *framework.CycleState) (*preScoreState, error) { … } func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) { … }
Codebase Browser
kubernetes