github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 20:24:09 +00:00
Code Issues Projects Releases Wiki Activity

scheduler: make getVolumeLimits a function instead of a method

Browse Source
This commit is contained in:
SataQiu 2019-09-30 16:25:31 +08:00
parent 2b795b9825
commit 92300eaadb
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/scheduler/algorithm/predicates/csi_volume_predicate.go
View File

@ -67,7 +67,7 @@ func NewCSIMaxVolumeLimitPredicate(
return c.attachableLimitPredicate return c.attachableLimitPredicate
} }
func (c *CSIMaxVolumeLimitChecker) getVolumeLimits(nodeInfo *schedulernodeinfo.NodeInfo, csiNode *storagev1beta1.CSINode) map[v1.ResourceName]int64 { func getVolumeLimits(nodeInfo *schedulernodeinfo.NodeInfo, csiNode *storagev1beta1.CSINode) map[v1.ResourceName]int64 {
// TODO: stop getting values from Node object in v1.18 // TODO: stop getting values from Node object in v1.18
nodeVolumeLimits := nodeInfo.VolumeLimits() nodeVolumeLimits := nodeInfo.VolumeLimits()
if csiNode != nil { if csiNode != nil {
@ -117,7 +117,7 @@ func (c *CSIMaxVolumeLimitChecker) attachableLimitPredicate(
} }
// If the node doesn't have volume limits, the predicate will always be true // If the node doesn't have volume limits, the predicate will always be true
nodeVolumeLimits := c.getVolumeLimits(nodeInfo, csiNode) nodeVolumeLimits := getVolumeLimits(nodeInfo, csiNode)
if len(nodeVolumeLimits) == 0 { if len(nodeVolumeLimits) == 0 {
return true, nil, nil return true, nil, nil
} }