Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for nodeInfos (0.13 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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/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)
Back to top