shmscoring

Documentation

Index

• Constants
• func New(obj runtime.Object, h framework.Handle) (framework.Plugin, error)
• type NodeMetric
• type ShmScoring
  • func (s *ShmScoring) Name() string
  • func (s *ShmScoring) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (s *ShmScoring) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (s *ShmScoring) ScoreExtensions() framework.ScoreExtensions
• type ShmmConnector
  • func NewShmmConnector(addrs []string, ports []string) *ShmmConnector
  • func (s *ShmmConnector) GetNodeMetric(nodeName string) (NodeMetric, error)

Constants

const Name = "ShmScoring"

Functions

func New

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

Types

type NodeMetric

type NodeMetric struct {
	ShmSum      int64
	ShmDiskUsed int64
	ShmDiskFree int64
	ShmDiskAll  int64
	ModelCount  int
	Models      []string
}

type ShmScoring

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

func (*ShmScoring) Name

func (s *ShmScoring) Name() string

func (*ShmScoring) NormalizeScore

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

func (*ShmScoring) Score

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

func (*ShmScoring) ScoreExtensions

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

type ShmmConnector

type ShmmConnector struct {
	ShmmAddrPorts map[string]string
}

func NewShmmConnector

func NewShmmConnector(addrs []string, ports []string) *ShmmConnector

func (*ShmmConnector) GetNodeMetric

func (s *ShmmConnector) GetNodeMetric(nodeName string) (NodeMetric, error)