Documentation
¶
Index ¶
- type CacheComparer
- func (c *CacheComparer) Compare() error
- func (c *CacheComparer) CompareNodes(nodes []*v1.Node, nodeinfos map[string]*schedulernodeinfo.NodeInfo) (missed, redundant []string)
- func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*schedulernodeinfo.NodeInfo) (missed, redundant []string)
- type CacheDebugger
- type CacheDumper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*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]*schedulernodeinfo.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]*schedulernodeinfo.NodeInfo) (missed, redundant []string)
ComparePods compares actual pods with cached pods.
type CacheDebugger ¶
type CacheDebugger struct {
Comparer CacheComparer
Dumper CacheDumper
}
CacheDebugger provides ways to check and write cache information for debugging.
func New ¶
func New( nodeLister corelisters.NodeLister, podLister corelisters.PodLister, cache internalcache.Cache, podQueue internalqueue.SchedulingQueue, ) *CacheDebugger
New creates a CacheDebugger.
func (*CacheDebugger) ListenForSignal ¶ added in v1.14.0
func (d *CacheDebugger) ListenForSignal(stopCh <-chan struct{})
ListenForSignal starts a goroutine that will trigger the CacheDebugger's behavior when the process receives SIGINT (Windows) or SIGUSER2 (non-Windows).
type CacheDumper ¶
type CacheDumper struct {
// contains filtered or unexported fields
}
CacheDumper writes some information from the scheduler cache and the scheduling queue to the scheduler logs for debugging purposes.
func (*CacheDumper) DumpAll ¶
func (d *CacheDumper) DumpAll()
DumpAll writes cached nodes and scheduling queue information to the scheduler logs.
Source Files