1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
package quotasets
import (
"fmt"
"github.com/gophercloud/gophercloud"
)
// Get returns public data about a previously created QuotaSet.
func Get(client *gophercloud.ServiceClient, projectID string) (r GetResult) {
resp, err := client.Get(getURL(client, projectID), &r.Body, nil)
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// GetDefaults returns public data about the project's default block storage quotas.
func GetDefaults(client *gophercloud.ServiceClient, projectID string) (r GetResult) {
resp, err := client.Get(getDefaultsURL(client, projectID), &r.Body, nil)
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// GetUsage returns detailed public data about a previously created QuotaSet.
func GetUsage(client *gophercloud.ServiceClient, projectID string) (r GetUsageResult) {
u := fmt.Sprintf("%s?usage=true", getURL(client, projectID))
resp, err := client.Get(u, &r.Body, nil)
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// Updates the quotas for the given projectID and returns the new QuotaSet.
func Update(client *gophercloud.ServiceClient, projectID string, opts UpdateOptsBuilder) (r UpdateResult) {
b, err := opts.ToBlockStorageQuotaUpdateMap()
if err != nil {
r.Err = err
return
}
resp, err := client.Put(updateURL(client, projectID), b, &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{200},
})
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// UpdateOptsBuilder enables extensions to add parameters to the update request.
type UpdateOptsBuilder interface {
// Extra specific name to prevent collisions with interfaces for other quotas
// (e.g. neutron)
ToBlockStorageQuotaUpdateMap() (map[string]interface{}, error)
}
// ToBlockStorageQuotaUpdateMap builds the update options into a serializable
// format.
func (opts UpdateOpts) ToBlockStorageQuotaUpdateMap() (map[string]interface{}, error) {
b, err := gophercloud.BuildRequestBody(opts, "quota_set")
if err != nil {
return nil, err
}
if opts.Extra != nil {
if v, ok := b["quota_set"].(map[string]interface{}); ok {
for key, value := range opts.Extra {
v[key] = value
}
}
}
return b, nil
}
// Options for Updating the quotas of a Tenant.
// All int-values are pointers so they can be nil if they are not needed.
// You can use gopercloud.IntToPointer() for convenience
type UpdateOpts struct {
// Volumes is the number of volumes that are allowed for each project.
Volumes *int `json:"volumes,omitempty"`
// Snapshots is the number of snapshots that are allowed for each project.
Snapshots *int `json:"snapshots,omitempty"`
// Gigabytes is the size (GB) of volumes and snapshots that are allowed for
// each project.
Gigabytes *int `json:"gigabytes,omitempty"`
// PerVolumeGigabytes is the size (GB) of volumes and snapshots that are
// allowed for each project and the specifed volume type.
PerVolumeGigabytes *int `json:"per_volume_gigabytes,omitempty"`
// Backups is the number of backups that are allowed for each project.
Backups *int `json:"backups,omitempty"`
// BackupGigabytes is the size (GB) of backups that are allowed for each
// project.
BackupGigabytes *int `json:"backup_gigabytes,omitempty"`
// Groups is the number of groups that are allowed for each project.
Groups *int `json:"groups,omitempty"`
// Force will update the quotaset even if the quota has already been used
// and the reserved quota exceeds the new quota.
Force bool `json:"force,omitempty"`
// Extra is a collection of miscellaneous key/values used to set
// quota per volume_type
Extra map[string]interface{} `json:"-"`
}
// Resets the quotas for the given tenant to their default values.
func Delete(client *gophercloud.ServiceClient, projectID string) (r DeleteResult) {
resp, err := client.Delete(updateURL(client, projectID), &gophercloud.RequestOpts{
OkCodes: []int{200},
})
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
|
