edgescoring

Documentation

Index

• Constants
• func New(obj runtime.Object, h framework.Handle) (framework.Plugin, error)
• type EdgeMetric
• type EdgeScoring
  • func (s *EdgeScoring) Name() string
  • func (s *EdgeScoring) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (s *EdgeScoring) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (s *EdgeScoring) ScoreExtensions() framework.ScoreExtensions
• type EdgeScoringConnector
  • func NewEdgeScoringConnector(targets []config.EdgeScoringTarget) *EdgeScoringConnector
  • func (s *EdgeScoringConnector) GetEdgeMetric(nodeName string) (EdgeMetric, error)

Constants

const Name = "EdgeScoring"

Functions

func New

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

Types

type EdgeMetric

type EdgeMetric struct {
	CPUCurrent float64
	CPUFuture  float64
	MemCurrent float64
	MemFuture  float64
}

type EdgeScoring

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

func (*EdgeScoring) Name

func (s *EdgeScoring) Name() string

func (*EdgeScoring) NormalizeScore

func (s *EdgeScoring) NormalizeScore(
	ctx context.Context,
	state *framework.CycleState,
	pod *v1.Pod,
	scores framework.NodeScoreList,
) *framework.Status

func (*EdgeScoring) Score

func (s *EdgeScoring) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)

func (*EdgeScoring) ScoreExtensions

func (s *EdgeScoring) ScoreExtensions() framework.ScoreExtensions

type EdgeScoringConnector

type EdgeScoringConnector struct {
	Targets map[string]config.EdgeScoringTarget
}

func NewEdgeScoringConnector

func NewEdgeScoringConnector(targets []config.EdgeScoringTarget) *EdgeScoringConnector

func (*EdgeScoringConnector) GetEdgeMetric

func (s *EdgeScoringConnector) GetEdgeMetric(nodeName string) (EdgeMetric, error)