Documentation
¶
Index ¶
- Constants
- func NewClusterAffinity(_ framework.Handle) (framework.Plugin, error)
- type ClusterAffinity
- func (pl *ClusterAffinity) Filter(ctx context.Context, su *framework.SchedulingUnit, ...) *framework.Result
- func (pl *ClusterAffinity) Name() string
- func (pl *ClusterAffinity) NormalizeScore(ctx context.Context, scores framework.ClusterScoreList) *framework.Result
- func (pl *ClusterAffinity) Score(ctx context.Context, su *framework.SchedulingUnit, ...) (int64, *framework.Result)
- func (pl *ClusterAffinity) ScoreExtensions() framework.ScoreExtensions
Constants ¶
View Source
const (
// ErrReason for node affinity/selector not matching.
ErrReason = "cluster(s) didn't match cluster selector"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClusterAffinity ¶
type ClusterAffinity struct{}
func (*ClusterAffinity) Filter ¶
func (pl *ClusterAffinity) Filter( ctx context.Context, su *framework.SchedulingUnit, cluster *fedcorev1a1.FederatedCluster, ) *framework.Result
Filter invoked at the filter extension point.
func (*ClusterAffinity) Name ¶
func (pl *ClusterAffinity) Name() string
func (*ClusterAffinity) NormalizeScore ¶
func (pl *ClusterAffinity) NormalizeScore(ctx context.Context, scores framework.ClusterScoreList) *framework.Result
NormalizeScore invoked after scoring all nodes.
func (*ClusterAffinity) Score ¶
func (pl *ClusterAffinity) Score( ctx context.Context, su *framework.SchedulingUnit, cluster *fedcorev1a1.FederatedCluster, ) (int64, *framework.Result)
func (*ClusterAffinity) ScoreExtensions ¶
func (pl *ClusterAffinity) ScoreExtensions() framework.ScoreExtensions
Click to show internal directories.
Click to hide internal directories.