mirror of https://github.com/k3s-io/k3s
118 lines
2.8 KiB
Go
118 lines
2.8 KiB
Go
package storageos
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"net/http"
|
|
|
|
"github.com/storageos/go-api/types"
|
|
)
|
|
|
|
var (
|
|
|
|
// PoolAPIPrefix is a partial path to the HTTP endpoint.
|
|
PoolAPIPrefix = "pools"
|
|
|
|
// ErrNoSuchPool is the error returned when the pool does not exist.
|
|
ErrNoSuchPool = errors.New("no such pool")
|
|
|
|
// ErrPoolInUse is the error returned when the pool requested to be removed is still in use.
|
|
ErrPoolInUse = errors.New("pool in use and cannot be removed")
|
|
)
|
|
|
|
// PoolList returns the list of available pools.
|
|
func (c *Client) PoolList(opts types.ListOptions) ([]*types.Pool, error) {
|
|
listOpts := doOptions{
|
|
fieldSelector: opts.FieldSelector,
|
|
labelSelector: opts.LabelSelector,
|
|
namespace: opts.Namespace,
|
|
context: opts.Context,
|
|
}
|
|
resp, err := c.do("GET", PoolAPIPrefix, listOpts)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer resp.Body.Close()
|
|
var pools []*types.Pool
|
|
if err := json.NewDecoder(resp.Body).Decode(&pools); err != nil {
|
|
return nil, err
|
|
}
|
|
return pools, nil
|
|
}
|
|
|
|
// PoolCreate creates a pool on the server and returns the new object.
|
|
func (c *Client) PoolCreate(opts types.PoolOptions) (*types.Pool, error) {
|
|
resp, err := c.do("POST", PoolAPIPrefix, doOptions{
|
|
data: opts,
|
|
context: opts.Context,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
var pool types.Pool
|
|
if err := json.NewDecoder(resp.Body).Decode(&pool); err != nil {
|
|
return nil, err
|
|
}
|
|
return &pool, nil
|
|
}
|
|
|
|
// PoolUpdate - update pool
|
|
func (c *Client) PoolUpdate(opts types.PoolOptions) (*types.Pool, error) {
|
|
ref := opts.Name
|
|
if IsUUID(opts.ID) {
|
|
ref = opts.ID
|
|
}
|
|
|
|
resp, err := c.do("PUT", PoolAPIPrefix+"/"+ref, doOptions{
|
|
data: opts,
|
|
context: opts.Context,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
var pool types.Pool
|
|
if err := json.NewDecoder(resp.Body).Decode(&pool); err != nil {
|
|
return nil, err
|
|
}
|
|
return &pool, nil
|
|
}
|
|
|
|
// Pool returns a pool by its reference.
|
|
func (c *Client) Pool(ref string) (*types.Pool, error) {
|
|
resp, err := c.do("GET", PoolAPIPrefix+"/"+ref, doOptions{})
|
|
if err != nil {
|
|
if e, ok := err.(*Error); ok && e.Status == http.StatusNotFound {
|
|
return nil, ErrNoSuchPool
|
|
}
|
|
return nil, err
|
|
}
|
|
defer resp.Body.Close()
|
|
var pool types.Pool
|
|
if err := json.NewDecoder(resp.Body).Decode(&pool); err != nil {
|
|
return nil, err
|
|
}
|
|
return &pool, nil
|
|
}
|
|
|
|
// PoolDelete removes a pool by its reference.
|
|
func (c *Client) PoolDelete(opts types.DeleteOptions) error {
|
|
deleteOpts := doOptions{
|
|
force: opts.Force,
|
|
context: opts.Context,
|
|
}
|
|
resp, err := c.do("DELETE", PoolAPIPrefix+"/"+opts.Name, deleteOpts)
|
|
if err != nil {
|
|
if e, ok := err.(*Error); ok {
|
|
if e.Status == http.StatusNotFound {
|
|
return ErrNoSuchPool
|
|
}
|
|
if e.Status == http.StatusConflict {
|
|
return ErrPoolInUse
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
defer resp.Body.Close()
|
|
return nil
|
|
}
|