Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 139 for nodeInfos (0.2 sec)

  1. pkg/scheduler/framework/listers.go

    type NodeInfoLister interface {
    	// List returns the list of NodeInfos.
    	List() ([]*NodeInfo, error)
    	// HavePodsWithAffinityList returns the list of NodeInfos of nodes with pods with affinity terms.
    	HavePodsWithAffinityList() ([]*NodeInfo, error)
    	// HavePodsWithRequiredAntiAffinityList returns the list of NodeInfos of nodes with pods with required anti-affinity terms.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 04 01:00:41 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/cache/debugger/comparer.go

    func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) {
    	actual := []string{}
    	for _, pod := range pods {
    		actual = append(actual, string(pod.UID))
    	}
    
    	cached := []string{}
    	for _, nodeinfo := range nodeinfos {
    		for _, p := range nodeinfo.Pods {
    			cached = append(cached, string(p.Pod.UID))
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/preemption/preemption_test.go

    			informerFactory.WaitForCacheSync(ctx.Done())
    			snapshot := internalcache.NewSnapshot(tt.initPods, tt.nodes)
    			nodeInfos, err := snapshot.NodeInfos().List()
    			if err != nil {
    				t.Fatal(err)
    			}
    			sort.Slice(nodeInfos, func(i, j int) bool {
    				return nodeInfos[i].Node().Name < nodeInfos[j].Node().Name
    			})
    
    			fakePostPlugin := &FakePostFilterPlugin{numViolatingVictim: tt.numViolatingVictim}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/debugger/dumper.go

    	d.dumpNodes(logger)
    	d.dumpSchedulingQueue(logger)
    }
    
    // dumpNodes writes NodeInfo to the scheduler logs.
    func (d *CacheDumper) dumpNodes(logger klog.Logger) {
    	dump := d.cache.Dump()
    	nodeInfos := make([]string, 0, len(dump.Nodes))
    	for name, nodeInfo := range dump.Nodes {
    		nodeInfos = append(nodeInfos, d.printNodeInfo(name, nodeInfo))
    	}
    	// Extra blank line added between node entries for readability.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/imagelocality/image_locality.go

    	nodeInfo, err := pl.handle.SnapshotSharedLister().NodeInfos().Get(nodeName)
    	if err != nil {
    		return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err))
    	}
    
    	nodeInfos, err := pl.handle.SnapshotSharedLister().NodeInfos().List()
    	if err != nil {
    		return 0, framework.AsStatus(err)
    	}
    	totalNumNodes := len(nodeInfos)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 06:17:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. pkg/scheduler/extender.go

    // and extender, i.e. when the pod is not found in nodeInfo.Pods.
    func (h *HTTPExtender) convertPodUIDToPod(
    	metaPod *extenderv1.MetaPod,
    	nodeInfo *framework.NodeInfo) (*v1.Pod, error) {
    	for _, p := range nodeInfo.Pods {
    		if string(p.Pod.UID) == metaPod.UID {
    			return p.Pod, nil
    		}
    	}
    	return nil, fmt.Errorf("extender: %v claims to preempt pod (UID: %v) on node: %v, but the pod is not found on that node",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    	var allNodes []*framework.NodeInfo
    	var nodesWithRequiredAntiAffinityPods []*framework.NodeInfo
    	var err error
    	if allNodes, err = pl.sharedLister.NodeInfos().List(); err != nil {
    		return nil, framework.AsStatus(fmt.Errorf("failed to list NodeInfos: %w", err))
    	}
    	if nodesWithRequiredAntiAffinityPods, err = pl.sharedLister.NodeInfos().HavePodsWithRequiredAntiAffinityList(); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    	// need to process nodes hosting pods with affinity.
    	var allNodes []*framework.NodeInfo
    	var err error
    	if hasConstraints {
    		allNodes, err = pl.sharedLister.NodeInfos().List()
    		if err != nil {
    			return framework.AsStatus(fmt.Errorf("failed to get all nodes from shared lister: %w", err))
    		}
    	} else {
    		allNodes, err = pl.sharedLister.NodeInfos().HavePodsWithAffinityList()
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  9. pkg/scheduler/extender_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			// nodeInfos instantiations
    			nodeInfoList := make([]*framework.NodeInfo, 0, len(tt.nodeNames))
    			for i, nm := range tt.nodeNames {
    				nodeInfo := framework.NewNodeInfo()
    				node := createNode(nm)
    				nodeInfo.SetNode(node)
    				nodeInfo.AddPod(tt.podsInNodeList[i])
    				nodeInfo.AddPod(tt.podsInNodeList[i+2])
    				nodeInfoList = append(nodeInfoList, nodeInfo)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/cache/snapshot.go

    func (s *Snapshot) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error) {
    	return s.havePodsWithRequiredAntiAffinityNodeInfoList, nil
    }
    
    // Get returns the NodeInfo of the given node name.
    func (s *Snapshot) Get(nodeName string) (*framework.NodeInfo, error) {
    	if v, ok := s.nodeInfoMap[nodeName]; ok && v.Node() != nil {
    		return v, nil
    	}
    	return nil, fmt.Errorf("nodeinfo not found for node name %q", nodeName)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
Back to top