extend

Documentation

Index

• Constants
• Variables
• func GetDefaultNodeMetric(node *v1.Node, metric manager.MetricData) manager.NodeWithMetric
• func GetDefaultPodMetric(pod *v1.Pod, metric manager.MetricData) manager.PodWithMetric
• func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)
• type Arbiter
  • func (ex *Arbiter) Name() string
  • func (ex *Arbiter) NormalizeScore(ctx context.Context, state *framework.CycleState, p *v1.Pod, ...) *framework.Status
  • func (ex *Arbiter) PostBind(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeName string)
  • func (ex *Arbiter) PreFilterExtensions() framework.PreFilterExtensions
  • func (ex *Arbiter) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (score int64, newState *framework.Status)
  • func (ex *Arbiter) ScoreExtensions() framework.ScoreExtensions

Constants

const (
	Name           = "Arbiter"
	LogPrefix      = "[arbiter] "
	DebugLogic     = `console.log("[arbiter]", "pod:", JSON.stringify(pod), "node:", JSON.stringify(node));`
	PredictedRatio = 0.6
	PreLogic       = `` /* 134-byte string literal not displayed */

)

Variables

var (
	ErrNoScoreFunction = errors.New("no score function found")
)

Functions

func GetDefaultNodeMetric

func GetDefaultNodeMetric(node *v1.Node, metric manager.MetricData) manager.NodeWithMetric

func GetDefaultPodMetric

func GetDefaultPodMetric(pod *v1.Pod, metric manager.MetricData) manager.PodWithMetric

func New

func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)

Types

type Arbiter

type Arbiter struct {
	// contains filtered or unexported fields
}

func (*Arbiter) Name

func (ex *Arbiter) Name() string

func (*Arbiter) NormalizeScore

func (ex *Arbiter) NormalizeScore(ctx context.Context, state *framework.CycleState, p *v1.Pod, scores framework.NodeScoreList) *framework.Status

func (*Arbiter) PostBind

func (ex *Arbiter) PostBind(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeName string)

func (*Arbiter) PreFilterExtensions

func (ex *Arbiter) PreFilterExtensions() framework.PreFilterExtensions

func (*Arbiter) Score

func (ex *Arbiter) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (score int64, newState *framework.Status)

func (*Arbiter) ScoreExtensions

func (ex *Arbiter) ScoreExtensions() framework.ScoreExtensions