Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 86 for nodeInfos (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/scheduler/framework/extender.go

    	// The failedNodes and failedAndUnresolvableNodes optionally contains the list
    	// of failed nodes and failure reasons, except nodes in the latter are
    	// unresolvable.
    	Filter(pod *v1.Pod, nodes []*NodeInfo) (filteredNodes []*NodeInfo, failedNodesMap extenderv1.FailedNodesMap, failedAndUnresolvable extenderv1.FailedNodesMap, err error)
    
    	// Prioritize based on extender-implemented priority functions. The returned scores & weight
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    	s, err := getPreFilterState(cycleState)
    	if err != nil {
    		return framework.AsStatus(err)
    	}
    
    	pl.updateWithPod(s, podInfoToAdd.Pod, podToSchedule, nodeInfo.Node(), 1)
    	return nil
    }
    
    // RemovePod from pre-computed data in cycleState.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. pkg/scheduler/testing/framework/fake_extender.go

    	logger := klog.TODO()
    	for nodeName, victims := range nodeNameToVictimsCopy {
    		// Try to do preemption on extender side.
    		nodeInfo, _ := nodeInfos.Get(nodeName)
    		extenderVictimPods, extenderPDBViolations, fits, err := f.selectVictimsOnNodeByExtender(logger, pod, nodeInfo)
    		if err != nil {
    			return nil, err
    		}
    		// If it's unfit after extender's preemption, this node is unresolvable by preemption overall,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			}
    
    			informerFactory.Start(ctx.Done())
    			informerFactory.WaitForCacheSync(ctx.Done())
    
    			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
    			})
    
    			if tt.args == nil {
    				tt.args = getDefaultDefaultPreemptionArgs()
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.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))
    	}
    	node := nodeInfo.Node()
    
    	s, err := getPreScoreState(state)
    	if err != nil {
    		return 0, framework.AsStatus(err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    		tc.informerFactory.Shutdown()
    	})
    
    	tc.informerFactory.WaitForCacheSync(tc.ctx.Done())
    
    	for _, node := range nodes {
    		nodeInfo := framework.NewNodeInfo()
    		nodeInfo.SetNode(node)
    		tc.nodeInfos = append(tc.nodeInfos, nodeInfo)
    	}
    	tc.state = framework.NewCycleState()
    
    	return tc
    }
    
    // createReactor implements the logic required for the UID and ResourceVersion
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
Back to top