/
lxd_storage_pools.go
135 lines (105 loc) · 3.57 KB
/
lxd_storage_pools.go
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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
package lxd
import (
"fmt"
"net/url"
"strings"
"github.com/lxc/lxd/shared/api"
)
// Storage pool handling functions
// GetStoragePoolNames returns the names of all storage pools
func (r *ProtocolLXD) GetStoragePoolNames() ([]string, error) {
if !r.HasExtension("storage") {
return nil, fmt.Errorf("The server is missing the required \"storage\" API extension")
}
urls := []string{}
// Fetch the raw value
_, err := r.queryStruct("GET", "/storage-pools", nil, "", &urls)
if err != nil {
return nil, err
}
// Parse it
names := []string{}
for _, url := range urls {
fields := strings.Split(url, "/storage-pools/")
names = append(names, fields[len(fields)-1])
}
return names, nil
}
// GetStoragePools returns a list of StoragePool entries
func (r *ProtocolLXD) GetStoragePools() ([]api.StoragePool, error) {
if !r.HasExtension("storage") {
return nil, fmt.Errorf("The server is missing the required \"storage\" API extension")
}
pools := []api.StoragePool{}
// Fetch the raw value
_, err := r.queryStruct("GET", "/storage-pools?recursion=1", nil, "", &pools)
if err != nil {
return nil, err
}
return pools, nil
}
// GetStoragePool returns a StoragePool entry for the provided pool name
func (r *ProtocolLXD) GetStoragePool(name string) (*api.StoragePool, string, error) {
if !r.HasExtension("storage") {
return nil, "", fmt.Errorf("The server is missing the required \"storage\" API extension")
}
pool := api.StoragePool{}
// Fetch the raw value
etag, err := r.queryStruct("GET", fmt.Sprintf("/storage-pools/%s", url.PathEscape(name)), nil, "", &pool)
if err != nil {
return nil, "", err
}
return &pool, etag, nil
}
// CreateStoragePool defines a new storage pool using the provided StoragePool struct
func (r *ProtocolLXD) CreateStoragePool(pool api.StoragePoolsPost) error {
if !r.HasExtension("storage") {
return fmt.Errorf("The server is missing the required \"storage\" API extension")
}
if pool.Driver == "ceph" && !r.HasExtension("storage_driver_ceph") {
return fmt.Errorf("The server is missing the required \"storage_driver_ceph\" API extension")
}
// Send the request
_, _, err := r.query("POST", "/storage-pools", pool, "")
if err != nil {
return err
}
return nil
}
// UpdateStoragePool updates the pool to match the provided StoragePool struct
func (r *ProtocolLXD) UpdateStoragePool(name string, pool api.StoragePoolPut, ETag string) error {
if !r.HasExtension("storage") {
return fmt.Errorf("The server is missing the required \"storage\" API extension")
}
// Send the request
_, _, err := r.query("PUT", fmt.Sprintf("/storage-pools/%s", url.PathEscape(name)), pool, ETag)
if err != nil {
return err
}
return nil
}
// DeleteStoragePool deletes a storage pool
func (r *ProtocolLXD) DeleteStoragePool(name string) error {
if !r.HasExtension("storage") {
return fmt.Errorf("The server is missing the required \"storage\" API extension")
}
// Send the request
_, _, err := r.query("DELETE", fmt.Sprintf("/storage-pools/%s", url.PathEscape(name)), nil, "")
if err != nil {
return err
}
return nil
}
// GetStoragePoolResources gets the resources available to a given storage pool
func (r *ProtocolLXD) GetStoragePoolResources(name string) (*api.ResourcesStoragePool, error) {
if !r.HasExtension("resources") {
return nil, fmt.Errorf("The server is missing the required \"resources\" API extension")
}
res := api.ResourcesStoragePool{}
// Fetch the raw value
_, err := r.queryStruct("GET", fmt.Sprintf("/storage-pools/%s/resources", url.PathEscape(name)), nil, "", &res)
if err != nil {
return nil, err
}
return &res, nil
}