- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for volumeLimits (0.17 sec)
-
pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go
return string(b) } func generateCSINode(nodeIDs nodeIDMap, volumeLimits *storage.VolumeNodeResources, topologyKeys topologyKeyMap) *storage.CSINode { nodeDrivers := []storage.CSINodeDriver{} for k, nodeID := range nodeIDs { dspec := storage.CSINodeDriver{ Name: k, NodeID: nodeID, Allocatable: volumeLimits, } if top, exists := topologyKeys[k]; exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 17 02:02:59 UTC 2022 - 34.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go
for k := range existingVolumes { delete(newVolumes, k) } numNewVolumes := len(newVolumes) maxAttachLimit := pl.maxVolumeFunc(node) volumeLimits := volumeLimits(nodeInfo) if maxAttachLimitFromAllocatable, ok := volumeLimits[pl.volumeLimitKey]; ok { maxAttachLimit = int(maxAttachLimitFromAllocatable) } if numExistingVolumes+numNewVolumes > maxAttachLimit {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 19.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
}, nil } func getVolumeLimits(nodeInfo *framework.NodeInfo, csiNode *storagev1.CSINode) map[v1.ResourceName]int64 { // TODO: stop getting values from Node object in v1.18 nodeVolumeLimits := volumeLimits(nodeInfo) if csiNode != nil { for i := range csiNode.Spec.Drivers { d := csiNode.Spec.Drivers[i] if d.Allocatable != nil && d.Allocatable.Count != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0)