Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 137 for nodeInfos (0.14 sec)

  1. pkg/scheduler/framework/autoscaler_contract/lister_contract_test.go

    func (c *nodeInfoListerContract) List() ([]*framework.NodeInfo, error) {
    	return nil, nil
    }
    
    func (c *nodeInfoListerContract) HavePodsWithAffinityList() ([]*framework.NodeInfo, error) {
    	return nil, nil
    }
    
    func (c *nodeInfoListerContract) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error) {
    	return nil, nil
    }
    
    func (c *nodeInfoListerContract) Get(_ string) (*framework.NodeInfo, error) {
    	return nil, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 20 02:30:08 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    		if nominatedNodeStatus.Code() == framework.UnschedulableAndUnresolvable {
    			return true, ""
    		}
    
    		if nodeInfo, _ := nodeInfos.Get(nomNodeName); nodeInfo != nil {
    			podPriority := corev1helpers.PodPriority(pod)
    			for _, p := range nodeInfo.Pods {
    				if corev1helpers.PodPriority(p.Pod) < podPriority && podTerminatingByPreemption(p.Pod, pl.fts.EnablePodDisruptionConditions) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go

    			pl := newPluginWithListers(ctx, b, []*v1.Pod{tt.Pod}, nodes, makePVCsWithPV(tt.NumPVC), makePVsWithZoneLabel(tt.NumPV))
    			nodeInfos := make([]*framework.NodeInfo, len(nodes), len(nodes))
    			for i := 0; i < len(nodes); i++ {
    				nodeInfo := &framework.NodeInfo{}
    				nodeInfo.SetNode(nodes[i])
    				nodeInfos[i] = nodeInfo
    			}
    			p := pl.(*VolumeZone)
    			state := framework.NewCycleState()
    
    			b.ResetTimer()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 05:17:04 UTC 2023
    - 20K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			informerFactory.WaitForCacheSync(ctx.Done())
    
    			t.Log("Verify")
    
    			p := pl.(*VolumeBinding)
    			nodeInfos := make([]*framework.NodeInfo, 0)
    			for _, node := range item.nodes {
    				nodeInfo := framework.NewNodeInfo()
    				nodeInfo.SetNode(node)
    				nodeInfos = append(nodeInfos, nodeInfo)
    			}
    			state := framework.NewCycleState()
    
    			t.Logf("Verify: call PreFilter and check status")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K 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/scoring.go

    	nodeInfo, err := pl.sharedLister.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(cycleState)
    	if err != nil {
    		return 0, framework.AsStatus(err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  7. 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 (1)
  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/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)
  10. pkg/scheduler/framework/plugins/noderesources/balanced_allocation.go

    }
    
    // Score invoked at the score extension point.
    func (ba *BalancedAllocation) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status) {
    	nodeInfo, err := ba.handle.SnapshotSharedLister().NodeInfos().Get(nodeName)
    	if err != nil {
    		return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err))
    	}
    
    	s, err := getBalancedAllocationPreScoreState(state)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
Back to top