- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 137 for nodeInfos (0.32 sec)
-
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) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
if nominatedNodeStatus.Code() == framework.UnschedulableAndUnresolvable { return true, "" } if nodeInfo, _ := nodeInfos.Get(nomNodeName); nodeInfo != nil { podPriority := corev1helpers.PodPriority(pod) for _, p := range nodeInfo.Pods { if corev1helpers.PodPriority(p.Pod) < podPriority && podTerminatingByPreemption(p.Pod, pl.fts.EnablePodDisruptionConditions) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go
pl := newPluginWithListers(ctx, b, []*v1.Pod{tt.Pod}, nodes, makePVCsWithPV(tt.NumPVC), makePVsWithZoneLabel(tt.NumPV)) nodeInfos := make([]*framework.NodeInfo, len(nodes), len(nodes)) for i := 0; i < len(nodes); i++ { nodeInfo := &framework.NodeInfo{} nodeInfo.SetNode(nodes[i]) nodeInfos[i] = nodeInfo } p := pl.(*VolumeZone) state := framework.NewCycleState() b.ResetTimer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 05:17:04 UTC 2023 - 20K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
informerFactory.WaitForCacheSync(ctx.Done()) t.Log("Verify") p := pl.(*VolumeBinding) nodeInfos := make([]*framework.NodeInfo, 0) for _, node := range item.nodes { nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(node) nodeInfos = append(nodeInfos, nodeInfo) } state := framework.NewCycleState() t.Logf("Verify: call PreFilter and check status")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
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) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
s, err := getPreFilterState(cycleState) if err != nil { return framework.AsStatus(err) } pl.updateWithPod(s, podInfoToAdd.Pod, podToSchedule, nodeInfo.Node(), 1) return nil } // RemovePod from pre-computed data in cycleState.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (1) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
} informerFactory.Start(ctx.Done()) informerFactory.WaitForCacheSync(ctx.Done()) 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 }) if tt.args == nil { tt.args = getDefaultDefaultPreemptionArgs() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
logger := klog.TODO() for nodeName, victims := range nodeNameToVictimsCopy { // Try to do preemption on extender side. nodeInfo, _ := nodeInfos.Get(nodeName) extenderVictimPods, extenderPDBViolations, fits, err := f.selectVictimsOnNodeByExtender(logger, pod, nodeInfo) if err != nil { return nil, err } // If it's unfit after extender's preemption, this node is unresolvable by preemption overall,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
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)