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

Merge pull request #88602 from yuga711/pd-limit

Browse Source 
Fix to expose max gce-pd disks per instance
This commit is contained in:
Kubernetes Prow Robot 2020-02-27 16:12:53 -08:00 committed by GitHub
commit a555825ab4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/volume/gcepd/gce_pd.go
View File

@ -25,7 +25,6 @@ import (
"path/filepath" "path/filepath"
"runtime" "runtime"
"strconv" "strconv"
"strings"
"k8s.io/klog" "k8s.io/klog"
"k8s.io/utils/mount" "k8s.io/utils/mount"
@ -65,13 +64,13 @@ const (
// The constants are used to map from the machine type (number of CPUs) to the limit of // The constants are used to map from the machine type (number of CPUs) to the limit of
// persistent disks that can be attached to an instance. Please refer to gcloud doc // persistent disks that can be attached to an instance. Please refer to gcloud doc
// https://cloud.google.com/compute/docs/disks/#increased_persistent_disk_limits // https://cloud.google.com/compute/docs/machine-types
// These constants are all the documented attach limit minus one because the // These constants are all the documented attach limit minus one because the
// node boot disk is considered an attachable disk so effective attach limit is // node boot disk is considered an attachable disk so effective attach limit is
// one less. // one less.
const ( const (
volumeLimitSmall = 15 volumeLimitSmall = 15
VolumeLimitBig = 127 volumeLimitBig = 127
) )
func getPath(uid types.UID, volName string, host volume.VolumeHost) string { func getPath(uid types.UID, volName string, host volume.VolumeHost) string {
@ -149,12 +148,14 @@ func (plugin *gcePersistentDiskPlugin) GetVolumeLimits() (map[string]int64, erro
klog.Errorf("Failed to get instance type from GCE cloud provider") klog.Errorf("Failed to get instance type from GCE cloud provider")
return volumeLimits, nil return volumeLimits, nil
} }
if strings.HasPrefix(instanceType, "n1-") || strings.HasPrefix(instanceType, "custom-") { smallMachineTypes := []string{"f1-micro", "g1-small", "e2-micro", "e2-small", "e2-medium"}
volumeLimits[util.GCEVolumeLimitKey] = VolumeLimitBig for _, small := range smallMachineTypes {
} else { if instanceType == small {
volumeLimits[util.GCEVolumeLimitKey] = volumeLimitSmall volumeLimits[util.GCEVolumeLimitKey] = volumeLimitSmall
return volumeLimits, nil
}
} }
volumeLimits[util.GCEVolumeLimitKey] = volumeLimitBig
return volumeLimits, nil return volumeLimits, nil
} }