loadaware

Documentation

Index

• Constants
• func New(args runtime.Object, handle framework.Handle) (framework.Plugin, error)
• type Plugin
  • func (p *Plugin) EventsToRegister() []framework.ClusterEventWithHint
  • func (p *Plugin) Filter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (p *Plugin) Name() string
  • func (p *Plugin) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (p *Plugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)
  • func (p *Plugin) ScoreExtensions() framework.ScoreExtensions
  • func (p *Plugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...)

Constants

const (
	Name                                    = "LoadAwareScheduling"
	ErrReasonNodeMetricExpired              = "node(s) nodeMetric expired"
	ErrReasonUsageExceedThreshold           = "node(s) %s usage exceed threshold"
	ErrReasonAggregatedUsageExceedThreshold = "node(s) %s aggregated usage exceed threshold"
	ErrReasonFailedEstimatePod
)

const (
	// DefaultMilliCPURequest defines default milli cpu request number.
	DefaultMilliCPURequest int64 = 250 // 0.25 core
	// DefaultMemoryRequest defines default memory request size.
	DefaultMemoryRequest int64 = 200 * 1024 * 1024 // 200 MB
	// DefaultNodeMetricReportInterval defines the default koodlet report NodeMetric interval.
	DefaultNodeMetricReportInterval = 60 * time.Second
)

Functions

func New

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

Types

type Plugin

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

func (*Plugin) EventsToRegister

func (p *Plugin) EventsToRegister() []framework.ClusterEventWithHint

func (*Plugin) Filter

func (p *Plugin) Filter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeInfo *framework.NodeInfo) *framework.Status

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) Reserve

func (p *Plugin) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

func (*Plugin) Score

func (p *Plugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) (int64, *framework.Status)

func (*Plugin) ScoreExtensions

func (p *Plugin) ScoreExtensions() framework.ScoreExtensions

func (*Plugin) Unreserve

func (p *Plugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string)