- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 139 for nodeInfos (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/scheduler/framework/plugins/interpodaffinity/filtering.go
var allNodes []*framework.NodeInfo var nodesWithRequiredAntiAffinityPods []*framework.NodeInfo var err error if allNodes, err = pl.sharedLister.NodeInfos().List(); err != nil { return nil, framework.AsStatus(fmt.Errorf("failed to list NodeInfos: %w", err)) } if nodesWithRequiredAntiAffinityPods, err = pl.sharedLister.NodeInfos().HavePodsWithRequiredAntiAffinityList(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 10:24:54 UTC 2023 - 14.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/scoring.go
// need to process nodes hosting pods with affinity. var allNodes []*framework.NodeInfo var err error if hasConstraints { allNodes, err = pl.sharedLister.NodeInfos().List() if err != nil { return framework.AsStatus(fmt.Errorf("failed to get all nodes from shared lister: %w", err)) } } else { allNodes, err = pl.sharedLister.NodeInfos().HavePodsWithAffinityList() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.5K bytes - Viewed (0) -
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) -
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)