github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 17:30:00 +00:00
Code Issues Projects Releases Wiki Activity

Set a Quobyte quota for newly created volumes

Browse Source
This commit is contained in:
Johannes Scheuermann 2017-06-28 23:03:33 +02:00
parent 343d751bc5
commit 6a88a03d59
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/volume/quobyte/quobyte_util.go
View File

@ -36,7 +36,7 @@ func (manager *quobyteVolumeManager) createVolume(provisioner *quobyteVolumeProv
capacity := provisioner.options.PVC.Spec.Resources.Requests[v1.ResourceName(v1.ResourceStorage)] capacity := provisioner.options.PVC.Spec.Resources.Requests[v1.ResourceName(v1.ResourceStorage)]
volumeSize := int(volume.RoundUpSize(capacity.Value(), 1024*1024*1024)) volumeSize := int(volume.RoundUpSize(capacity.Value(), 1024*1024*1024))
// Quobyte has the concept of Volumes which doen't have a specific size (they can grow unlimited) // Quobyte has the concept of Volumes which doen't have a specific size (they can grow unlimited)
// to simulate a size constraint we could set here a Quota // to simulate a size constraint we set here a Quota for logical space
volumeRequest := &quobyteapi.CreateVolumeRequest{ volumeRequest := &quobyteapi.CreateVolumeRequest{
Name: provisioner.volume, Name: provisioner.volume,
RootUserID: provisioner.user, RootUserID: provisioner.user,
@ -45,7 +45,15 @@ func (manager *quobyteVolumeManager) createVolume(provisioner *quobyteVolumeProv
ConfigurationName: provisioner.config, ConfigurationName: provisioner.config,
} }
if _, err := manager.createQuobyteClient().CreateVolume(volumeRequest); err != nil { quobyteClient := manager.createQuobyteClient()
volumeUUID, err := quobyteClient.CreateVolume(volumeRequest)
if err != nil {
return &v1.QuobyteVolumeSource{}, volumeSize, err
}
// Set Quoate for Volume with specified byte size
err = quobyteClient.SetVolumeQuota(volumeUUID, capacity.Value())
if err != nil {
return &v1.QuobyteVolumeSource{}, volumeSize, err return &v1.QuobyteVolumeSource{}, volumeSize, err
} }