plugin

Documentation

Index

• Constants
• func NewTopologyAwareScheduler(_ *runtime.Unknown, handle framework.FrameworkHandle) (framework.Plugin, error)
• type NodeTopologyMap
• type TopologyAwareScheduler
  • func (tm *TopologyAwareScheduler) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (tm *TopologyAwareScheduler) Name() string
  • func (tm *TopologyAwareScheduler) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)

Constants

const (
	// TopologyAwareScheduler is the name of the plugin used in the plugin registry and configurations.
	Name = "TopologyAwareScheduler"

	NoneTopologyManagerPolicy           = "none"
	BestEffortTopologyManagerPolicy     = "best-effort"
	RestrictedTopologyManagerPolicy     = "restricted"
	SingleNUMANodeTopologyManagerPolicy = "single-numa-node"
)

Functions

func NewTopologyAwareScheduler

func NewTopologyAwareScheduler(_ *runtime.Unknown, handle framework.FrameworkHandle) (framework.Plugin, error)

NewTopologyMatch initializes a new plugin and returns it.

Types

type NodeTopologyMap

type NodeTopologyMap map[string]topologyv1alpha1.NodeResourceTopology

type TopologyAwareScheduler

type TopologyAwareScheduler struct {

	// cli    *clientset.Clientset
	NodeTopologyInformer    topoinformerv1alpha1.NodeResourceTopologyInformer
	TopologyInformerFactory topoinformerexternal.SharedInformerFactory
	NodeTopologies          NodeTopologyMap
	NodeTopologyGuard       sync.RWMutex
	// contains filtered or unexported fields
}

func (*TopologyAwareScheduler) Filter

func (tm *TopologyAwareScheduler) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *nodeinfo.NodeInfo) *framework.Status

func (*TopologyAwareScheduler) Name

func (tm *TopologyAwareScheduler) Name() string

func (*TopologyAwareScheduler) Unreserve

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