1. 前言

2. NewConfigFactory

3. PodInformer(scheduled pod cache)

func (c *configFactory) addPodToCache(obj interface{}) {
    pod, ok := obj.(*v1.Pod)
    ...
    if err := c.schedulerCache.AddPod(pod); err != nil {
        klog.Errorf("scheduler cache AddPod failed: %v", err)
    }
    ...
}

func (c *configFactory) updatePodInCache(oldObj, newObj interface{}) {
    oldPod, ok := oldObj.(*v1.Pod)
    if !ok {
        klog.Errorf("cannot convert oldObj to *v1.Pod: %v", oldObj)
        return
    }
    newPod, ok := newObj.(*v1.Pod)
    if !ok {
        klog.Errorf("cannot convert newObj to *v1.Pod: %v", newObj)
        return
    }
    if err := c.schedulerCache.UpdatePod(oldPod, newPod); err != nil {
        klog.Errorf("scheduler cache UpdatePod failed: %v", err)
    }
       // 这个是equivlance部分 可以先不管 因为不影响
    c.invalidateCachedPredicatesOnUpdatePod(newPod, oldPod)
    c.podQueue.AssignedPodUpdated(newPod)
}

func (c *configFactory) deletePodFromCache(obj interface{}) {
    ...
    if err := c.schedulerCache.RemovePod(pod); err != nil {
        klog.Errorf("scheduler cache RemovePod failed: %v", err)
    }
    ...
}

4. PodInformer(unscheduled pod queue)

5. NodeInformer

func (c *configFactory) addNodeToCache(obj interface{}) {
    node, ok := obj.(*v1.Node)
    if !ok {
        klog.Errorf("cannot convert to *v1.Node: %v", obj)
        return
    }
    ...
    if err := c.schedulerCache.AddNode(node); err != nil {
        klog.Errorf("scheduler cache AddNode failed: %v", err)
    }
    ...
}
func (c *configFactory) updateNodeInCache(oldObj, newObj interface{}) {
    oldNode, ok := oldObj.(*v1.Node)
    if !ok {
        klog.Errorf("cannot convert oldObj to *v1.Node: %v", oldObj)
        return
    }
    newNode, ok := newObj.(*v1.Node)
    if !ok {
        klog.Errorf("cannot convert newObj to *v1.Node: %v", newObj)
        return
    }

    ...
    if err := c.schedulerCache.UpdateNode(oldNode, newNode); err != nil {
        klog.Errorf("scheduler cache UpdateNode failed: %v", err)
    }

    ...
}
func (c *configFactory) deleteNodeFromCache(obj interface{}) {
    var node *v1.Node
    switch t := obj.(type) {
    case *v1.Node:
        node = t
    case cache.DeletedFinalStateUnknown:
        var ok bool
        node, ok = t.Obj.(*v1.Node)
        if !ok {
            klog.Errorf("cannot convert to *v1.Node: %v", t.Obj)
            return
        }
    default:
        klog.Errorf("cannot convert to *v1.Node: %v", t)
        return
    }
    ...
    if err := c.schedulerCache.RemoveNode(node); err != nil {
        klog.Errorf("scheduler cache RemoveNode failed: %v", err)
    }
    ...
}

6. pvInformer pvcInformer serviceInformer

7. 总结