comparer

Documentation

Index

• type CacheComparer
  • func New(nodeLister corelisters.NodeLister, podLister corelisters.PodLister, ...) *CacheComparer
  • func (c *CacheComparer) Compare() error
  • func (c *CacheComparer) CompareNodes(nodes []*v1.Node, nodeinfos map[string]*schedulercache.NodeInfo) (missed, redundant []string)
  • func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*schedulercache.NodeInfo) (missed, redundant []string)

Types

type CacheComparer

type CacheComparer struct {
	NodeLister corelisters.NodeLister
	PodLister  corelisters.PodLister
	Cache      schedulerinternalcache.Cache
	PodQueue   internalqueue.SchedulingQueue
}

CacheComparer is an implementation of the Scheduler's cache comparer.

func New

func New(
	nodeLister corelisters.NodeLister,
	podLister corelisters.PodLister,
	cache schedulerinternalcache.Cache,
	podQueue internalqueue.SchedulingQueue,
) *CacheComparer

New creates a CacheComparer.

func (*CacheComparer) Compare

func (c *CacheComparer) Compare() error

Compare compares the nodes and pods of NodeLister with Cache.Snapshot.

func (*CacheComparer) CompareNodes

func (c *CacheComparer) CompareNodes(nodes []*v1.Node, nodeinfos map[string]*schedulercache.NodeInfo) (missed, redundant []string)

CompareNodes compares actual nodes with cached nodes.

func (*CacheComparer) ComparePods

func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*schedulercache.NodeInfo) (missed, redundant []string)

ComparePods compares actual pods with cached pods.