▽

Package leastrecentlyusednode

Constants

const (
    PluginName = "LeastRecentlyUsedNode"
)

func NewLeastRecentlyUsedNodeClusterAgentPlugin ¶

func NewLeastRecentlyUsedNodeClusterAgentPlugin(configMap config.PluginConfig, clusterAgentServices pipeline.ClusterAgentServices) (pipeline.Plugin, error)

func NewLeastRecentlyUsedNodeSchedulingPlugin ¶

func NewLeastRecentlyUsedNodeSchedulingPlugin(configMap config.PluginConfig, scheduler pipeline.PolarisScheduler) (pipeline.Plugin, error)

type LeastRecentlyUsedNodePlugin ¶

This plugin assigns higher scores to nodes, which have not received a new pod for a longer time, i.e., nodes with an older LastPodAddedTimestamp get higher scores.

type LeastRecentlyUsedNodePlugin struct {
}

func (*LeastRecentlyUsedNodePlugin) Name ¶

func (lru *LeastRecentlyUsedNodePlugin) Name() string

func (*LeastRecentlyUsedNodePlugin) NormalizeScores ¶

func (*LeastRecentlyUsedNodePlugin) NormalizeScores(ctx pipeline.SchedulingContext, podInfo *pipeline.PodInfo, scores []pipeline.NodeScore) pipeline.Status

func (*LeastRecentlyUsedNodePlugin) PreScore ¶

func (lru *LeastRecentlyUsedNodePlugin) PreScore(ctx pipeline.SchedulingContext, podInfo *pipeline.PodInfo, eligibleNodes []*pipeline.NodeInfo) pipeline.Status

func (*LeastRecentlyUsedNodePlugin) Score ¶

func (lru *LeastRecentlyUsedNodePlugin) Score(ctx pipeline.SchedulingContext, podInfo *pipeline.PodInfo, nodeInfo *pipeline.NodeInfo) (int64, pipeline.Status)

func (*LeastRecentlyUsedNodePlugin) ScoreExtensions ¶

func (lru *LeastRecentlyUsedNodePlugin) ScoreExtensions() pipeline.ScoreExtensions