- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for seenNode (0.22 sec)
-
pkg/scheduler/internal/cache/cache.go
} else { cache.removeNodeImageStates(n.info.Node()) } cache.moveNodeInfoToHead(logger, node.Name) cache.nodeTree.addNode(logger, node) cache.addNodeImageStates(node, n.info) n.info.SetNode(node) return n.info.Snapshot() } func (cache *cacheImpl) UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo { cache.mu.Lock() defer cache.mu.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
} } } else if result.Nodes != nil { nodeResult = make([]*framework.NodeInfo, len(result.Nodes.Items)) for i := range result.Nodes.Items { nodeResult[i] = framework.NewNodeInfo() nodeResult[i].SetNode(&result.Nodes.Items[i]) } } return nodeResult, result.FailedNodes, result.FailedAndUnresolvableNodes, nil } // Prioritize based on extender implemented priority functions. Weight*priority is added
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/extender_test.go
// 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) } tt.nodeInfos = tf.NodeInfoLister(nodeInfoList)
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/framework/types.go
n.PVCRefCounts[key] += 1 } else { n.PVCRefCounts[key] -= 1 if n.PVCRefCounts[key] <= 0 { delete(n.PVCRefCounts, key) } } } } // SetNode sets the overall node information. func (n *NodeInfo) SetNode(node *v1.Node) { n.node = node n.Allocatable = NewResource(node.Status.Allocatable) n.Generation = nextGeneration() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption_test.go
}, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { var nodeInfos []*framework.NodeInfo for _, name := range nodeNames { ni := framework.NewNodeInfo() ni.SetNode(st.MakeNode().Name(name).Obj()) nodeInfos = append(nodeInfos, ni) } nodes, _ := nodesWherePreemptionMightHelp(nodeInfos, tt.nodesStatuses) if len(tt.expected) != len(nodes) {
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/framework/plugins/tainttoleration/taint_toleration_test.go
}, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { _, ctx := ktesting.NewTestContext(t) nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(test.node) p, err := New(ctx, nil, nil, feature.Features{}) if err != nil { t.Fatalf("creating plugin: %v", err) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
addLimitToNode() addDriversCSINode(true) case "csinode-with-no-limit": addDriversCSINode(false) case "no-csi-driver": initCSINode() default: // Do nothing. } nodeInfo.SetNode(node) return nodeInfo, csiNode
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
func isFit(pod *v1.Pod, node *v1.Node) bool { if node == nil { return false } nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(node) return len(Fits(pod, nodeInfo)) == 0 } // Filter invoked at the filter extension point. // Checks if a node has sufficient resources, such as cpu, memory, gpu, opaque int resources etc to run a pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
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/plugins/nodeaffinity/node_affinity_test.go
_, ctx := ktesting.NewTestContext(t) node := v1.Node{ObjectMeta: metav1.ObjectMeta{ Name: test.nodeName, Labels: test.labels, }} nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(&node) p, err := New(ctx, &test.args, nil) if err != nil { t.Fatalf("Creating plugin: %v", err) } state := framework.NewCycleState() var gotStatus *framework.Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0)