- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for HavePodsWithAffinityList (0.47 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/framework/autoscaler_contract/lister_contract_test.go
type nodeInfoListerContract struct{} 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 20 02:30:08 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot.go
// List returns the list of nodes in the snapshot. func (s *Snapshot) List() ([]*framework.NodeInfo, error) { return s.nodeInfoList, nil } // HavePodsWithAffinityList returns the list of nodes with at least one pod with inter-pod affinity func (s *Snapshot) HavePodsWithAffinityList() ([]*framework.NodeInfo, error) { return s.havePodsWithAffinityNodeInfoList, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
// List lists all nodes. func (nodes NodeInfoLister) List() ([]*framework.NodeInfo, error) { return nodes, nil } // HavePodsWithAffinityList is supposed to list nodes with at least one pod with affinity. For the fake lister // we just return everything. func (nodes NodeInfoLister) HavePodsWithAffinityList() ([]*framework.NodeInfo, error) { return nodes, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/scoring.go
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 { return framework.AsStatus(fmt.Errorf("failed to get pods with affinity list: %w", err)) } } state := &preScoreState{ topologyScore: make(map[string]map[string]int64),
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/internal/cache/snapshot_test.go
if diff := cmp.Diff(test.expectedNodesInfos[i].Pods[j], info.Pods[j]); diff != "" { t.Errorf("Unexpected PodInfo (-want +got):\n%s", diff) } } } affinityList, err := snapshot.HavePodsWithAffinityList() if err != nil { t.Errorf("unexpected error but got %s", err) } if test.expectedPodsWithAffinity != len(affinityList) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0)