Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 139 for nodeInfos (0.16 sec)

  1. 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)
  2. 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)
  3. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.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()
    
    	var count int64
    	if pl.addedPrefSchedTerms != nil {
    		count += pl.addedPrefSchedTerms.Score(node)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/preemption/preemption.go

    	// for "pod" to be scheduled.
    	// Note that both `state` and `nodeInfo` are deep copied.
    	SelectVictimsOnNode(ctx context.Context, state *framework.CycleState,
    		pod *v1.Pod, nodeInfo *framework.NodeInfo, pdbs []*policy.PodDisruptionBudget) ([]*v1.Pod, int, *framework.Status)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  5. src/internal/profile/graph.go

    		objfile = m.File
    	}
    
    	if ni := nodeInfo(l, li, objfile, o); ni != nil {
    		return nm.FindOrInsertNode(*ni, o.KeptNodes)
    	}
    	return nil
    }
    
    func nodeInfo(l *Location, line Line, objfile string, o *Options) *NodeInfo {
    	if line.Function == nil {
    		return &NodeInfo{Address: l.Address}
    	}
    	ni := &NodeInfo{
    		Address: l.Address,
    		Lineno:  int(line.Line),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 05 20:59:15 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/fit.go

    	Capacity  int64
    }
    
    // Fits checks if node have enough resources to host the pod.
    func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) []InsufficientResource {
    	return fitsRequest(computePodResourceRequest(pod), nodeInfo, nil, nil)
    }
    
    func fitsRequest(podRequest *preFilterState, nodeInfo *framework.NodeInfo, ignoredExtendedResources, ignoredResourceGroups sets.Set[string]) []InsufficientResource {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/cache.go

    		}
    		for _, nodeName := range nodesList {
    			if nodeInfo := snapshot.nodeInfoMap[nodeName]; nodeInfo != nil {
    				snapshot.nodeInfoList = append(snapshot.nodeInfoList, nodeInfo)
    				if len(nodeInfo.PodsWithAffinity) > 0 {
    					snapshot.havePodsWithAffinityNodeInfoList = append(snapshot.havePodsWithAffinityNodeInfoList, nodeInfo)
    				}
    				if len(nodeInfo.PodsWithRequiredAntiAffinity) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    			}
    		})
    	}
    }
    
    func mustGetNodeInfo(t *testing.T, snapshot *cache.Snapshot, name string) *framework.NodeInfo {
    	t.Helper()
    	nodeInfo, err := snapshot.NodeInfos().Get(name)
    	if err != nil {
    		t.Fatal(err)
    	}
    	return nodeInfo
    }
    
    func mustNewPodInfo(t *testing.T, pod *v1.Pod) *framework.PodInfo {
    	podInfo, err := framework.NewPodInfo(pod)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  9. src/cmd/vendor/github.com/google/pprof/internal/graph/graph.go

    		objfile = m.File
    	}
    
    	if ni := nodeInfo(l, li, objfile, o); ni != nil {
    		return nm.FindOrInsertNode(*ni, o.KeptNodes)
    	}
    	return nil
    }
    
    func nodeInfo(l *profile.Location, line profile.Line, objfile string, o *Options) *NodeInfo {
    	if line.Function == nil {
    		return &NodeInfo{Address: l.Address, Objfile: objfile}
    	}
    	ni := &NodeInfo{
    		Address:  l.Address,
    		Lineno:   int(line.Line),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 31K bytes
    - Viewed (0)
  10. pkg/scheduler/schedule_one.go

    	nnn := pod.Status.NominatedNodeName
    	nodeInfo, err := sched.nodeInfoSnapshot.Get(nnn)
    	if err != nil {
    		return nil, err
    	}
    	node := []*framework.NodeInfo{nodeInfo}
    	feasibleNodes, err := sched.findNodesThatPassFilters(ctx, fwk, state, pod, &diagnosis, node)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top