noderesourcetopology

Documentation

Index

• Constants
• func DeepCopyTopologyHints(srcHints []topologymanager.TopologyHint) []topologymanager.TopologyHint
• func New(args runtime.Object, h framework.Handle) (framework.Plugin, error)
• func TopologyZonesToNUMANodeMap(zones []*v1alpha1.TopologyZone) map[int]NUMANode
• type NUMANode
• type NUMANodeList
  • func TopologyZonesToNUMANodeList(zones []*v1alpha1.TopologyZone) NUMANodeList
• type NUMAScoreFunc
• type TopologyMatch
  • func (tm *TopologyMatch) EventsToRegister() []framework.ClusterEvent
  • func (tm *TopologyMatch) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (tm *TopologyMatch) Name() string
  • func (tm *TopologyMatch) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (tm *TopologyMatch) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (tm *TopologyMatch) ScoreExtensions() framework.ScoreExtensions
  • func (tm *TopologyMatch) Unreserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...)

Constants

const (
	TopologyMatchName = "NodeResourceTopology"
)

Functions

func DeepCopyTopologyHints

func DeepCopyTopologyHints(srcHints []topologymanager.TopologyHint) []topologymanager.TopologyHint

DeepCopyTopologyHints returns deep copied hints of source hints

func New

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

func TopologyZonesToNUMANodeMap

func TopologyZonesToNUMANodeMap(zones []*v1alpha1.TopologyZone) map[int]NUMANode

Types

type NUMANode

type NUMANode struct {
	SocketID    string
	NUMAID      int
	Capacity    v1.ResourceList
	Allocatable v1.ResourceList
	Available   v1.ResourceList
	Costs       map[int]int
}

type NUMANodeList

type NUMANodeList []NUMANode

func TopologyZonesToNUMANodeList

func TopologyZonesToNUMANodeList(zones []*v1alpha1.TopologyZone) NUMANodeList

type NUMAScoreFunc

type NUMAScoreFunc func(v1.ResourceList, NUMANodeList, scoreStrategyFn, resourceToWeightMap, sets.String, bool) int64

type TopologyMatch

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

func (*TopologyMatch) EventsToRegister

func (tm *TopologyMatch) EventsToRegister() []framework.ClusterEvent

EventsToRegister returns the possible events that may make a Pod failed by this plugin schedulable. NOTE: if in-place-update (KEP 1287) gets implemented, then PodUpdate event should be registered for this plugin since a Pod update may free up resources that make other Pods schedulable.

func (*TopologyMatch) Filter

func (tm *TopologyMatch) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status

func (*TopologyMatch) Name

func (tm *TopologyMatch) Name() string

Name returns name of the plugin.

func (*TopologyMatch) Reserve

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

func (*TopologyMatch) Score

func (tm *TopologyMatch) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status)

func (*TopologyMatch) ScoreExtensions

func (tm *TopologyMatch) ScoreExtensions() framework.ScoreExtensions

func (*TopologyMatch) Unreserve

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