Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for nodeInfos (0.5 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  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/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)
  7. 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)
  8. pkg/scheduler/framework/plugins/noderesources/resource_allocation.go

    	}
    	switch resource {
    	case v1.ResourceCPU:
    		return nodeInfo.Allocatable.MilliCPU, (requested.MilliCPU + podRequest)
    	case v1.ResourceMemory:
    		return nodeInfo.Allocatable.Memory, (requested.Memory + podRequest)
    	case v1.ResourceEphemeralStorage:
    		return nodeInfo.Allocatable.EphemeralStorage, (nodeInfo.Requested.EphemeralStorage + podRequest)
    	default:
    		if _, exists := nodeInfo.Allocatable.ScalarResources[resource]; exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 14:53:43 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/nodename/node_name.go

    	if !Fits(pod, nodeInfo) {
    		return framework.NewStatus(framework.UnschedulableAndUnresolvable, ErrReason)
    	}
    	return nil
    }
    
    // Fits actually checks if the pod fits the node.
    func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool {
    	return len(pod.Spec.NodeName) == 0 || pod.Spec.NodeName == nodeInfo.Node().Name
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    // Fits checks if the pod fits the node.
    func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool {
    	return fitsPorts(getContainerPorts(pod), nodeInfo)
    }
    
    func fitsPorts(wantPorts []*v1.ContainerPort, nodeInfo *framework.NodeInfo) bool {
    	// try to see whether existingPorts and wantPorts will conflict or not
    	existingPorts := nodeInfo.UsedPorts
    	for _, cp := range wantPorts {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top