-
Notifications
You must be signed in to change notification settings - Fork 510
/
requests.go
136 lines (118 loc) · 4.47 KB
/
requests.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
136
package request
import (
"net/http"
"github.com/gophercloud/gophercloud"
"github.com/gophercloud/gophercloud/pagination"
)
// ListOptsBuilder allows extensions to add parameters to the List request.
type ListOptsBuilder interface {
ToTransferRequestListQuery() (string, error)
}
// ListOpts allows the filtering and sorting of paginated collections through
// the API. Filtering is achieved by passing in struct field values that map to
// the server attributes you want to see returned.
// https://developer.openstack.org/api-ref/dns/
type ListOpts struct {
Status string `q:"status"`
}
// ToTransferRequestListQuery formats a ListOpts into a query string.
func (opts ListOpts) ToTransferRequestListQuery() (string, error) {
q, err := gophercloud.BuildQueryString(opts)
return q.String(), err
}
// List implements a transfer request List request.
func List(client *gophercloud.ServiceClient, opts ListOptsBuilder) pagination.Pager {
url := baseURL(client)
if opts != nil {
query, err := opts.ToTransferRequestListQuery()
if err != nil {
return pagination.Pager{Err: err}
}
url += query
}
return pagination.NewPager(client, url, func(r pagination.PageResult) pagination.Page {
return TransferRequestPage{pagination.LinkedPageBase{PageResult: r}}
})
}
// Get returns information about a transfer request, given its ID.
func Get(client *gophercloud.ServiceClient, transferRequestID string) (r GetResult) {
resp, err := client.Get(resourceURL(client, transferRequestID), &r.Body, nil)
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// CreateOptsBuilder allows extensions to add additional attributes to the
// Create request.
type CreateOptsBuilder interface {
ToTransferRequestCreateMap() (map[string]interface{}, error)
}
// CreateOpts specifies the attributes used to create a transfer request.
type CreateOpts struct {
// TargetProjectID is ID that the request will be limited to. No other project
// will be allowed to accept this request.
TargetProjectID string `json:"target_project_id,omitempty"`
// Description of the transfer request.
Description string `json:"description,omitempty"`
}
// ToTransferRequestCreateMap formats an CreateOpts structure into a request body.
func (opts CreateOpts) ToTransferRequestCreateMap() (map[string]interface{}, error) {
b, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return b, nil
}
// Create implements a transfer request create request.
func Create(client *gophercloud.ServiceClient, zoneID string, opts CreateOptsBuilder) (r CreateResult) {
b, err := opts.ToTransferRequestCreateMap()
if err != nil {
r.Err = err
return
}
resp, err := client.Post(createURL(client, zoneID), &b, &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{http.StatusCreated, http.StatusAccepted},
})
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// UpdateOptsBuilder allows extensions to add additional attributes to the
// Update request.
type UpdateOptsBuilder interface {
ToTransferRequestUpdateMap() (map[string]interface{}, error)
}
// UpdateOpts specifies the attributes to update a transfer request.
type UpdateOpts struct {
// TargetProjectID is ID that the request will be limited to. No other project
// will be allowed to accept this request.
TargetProjectID string `json:"target_project_id,omitempty"`
// Description of the transfer request.
Description string `json:"description,omitempty"`
}
// ToTransferRequestUpdateMap formats an UpdateOpts structure into a request body.
func (opts UpdateOpts) ToTransferRequestUpdateMap() (map[string]interface{}, error) {
b, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return b, nil
}
// Update implements a transfer request update request.
func Update(client *gophercloud.ServiceClient, transferID string, opts UpdateOptsBuilder) (r UpdateResult) {
b, err := opts.ToTransferRequestUpdateMap()
if err != nil {
r.Err = err
return
}
resp, err := client.Patch(resourceURL(client, transferID), &b, &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{http.StatusOK, http.StatusAccepted},
})
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}
// Delete implements a transfer request delete request.
func Delete(client *gophercloud.ServiceClient, transferID string) (r DeleteResult) {
resp, err := client.Delete(resourceURL(client, transferID), &gophercloud.RequestOpts{
OkCodes: []int{http.StatusNoContent},
})
_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
return
}