networktraffic

Documentation

Index

• Constants
• func New(obj runtime.Object, h framework.Handle) (framework.Plugin, error)
• type NetworkTraffic
  • func (n *NetworkTraffic) Name() string
  • func (n *NetworkTraffic) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (n *NetworkTraffic) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (n *NetworkTraffic) ScoreExtensions() framework.ScoreExtensions
• type PrometheusHandler
  • func NewPrometheus(address, networkInterface string, timeRange time.Duration) *PrometheusHandler
  • func (p *PrometheusHandler) GetNodeBandwidthMeasure(node string) (*model.Sample, error)

Constants

const Name = "NetworkTraffic"

Functions

func New

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

Types

type NetworkTraffic

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

NetworkTraffic is a score plugin that favors nodes based on their network traffic amount. Nodes with less traffic are favored. Implements framework.ScorePlugin

func (*NetworkTraffic) Name

func (n *NetworkTraffic) Name() string

func (*NetworkTraffic) NormalizeScore

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

func (*NetworkTraffic) Score

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

func (*NetworkTraffic) ScoreExtensions

func (n *NetworkTraffic) ScoreExtensions() framework.ScoreExtensions

type PrometheusHandler

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

func NewPrometheus

func NewPrometheus(address, networkInterface string, timeRange time.Duration) *PrometheusHandler

func (*PrometheusHandler) GetNodeBandwidthMeasure

func (p *PrometheusHandler) GetNodeBandwidthMeasure(node string) (*model.Sample, error)