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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
package qos
import (
"github.com/gophercloud/gophercloud"
"github.com/gophercloud/gophercloud/pagination"
)
// QoS contains all the information associated with an OpenStack QoS specification.
type QoS struct {
// Name is the name of the QoS.
Name string `json:"name"`
// Unique identifier for the QoS.
ID string `json:"id"`
// Consumer of QoS
Consumer string `json:"consumer"`
// Arbitrary key-value pairs defined by the user.
Specs map[string]string `json:"specs"`
}
type commonResult struct {
gophercloud.Result
}
// Extract will get the QoS object out of the commonResult object.
func (r commonResult) Extract() (*QoS, error) {
var s QoS
err := r.ExtractInto(&s)
return &s, err
}
// ExtractInto converts our response data into a QoS struct
func (r commonResult) ExtractInto(qos interface{}) error {
return r.Result.ExtractIntoStructPtr(qos, "qos_specs")
}
// CreateResult contains the response body and error from a Create request.
type CreateResult struct {
commonResult
}
// DeleteResult contains the response body and error from a Delete request.
type DeleteResult struct {
gophercloud.ErrResult
}
type QoSPage struct {
pagination.LinkedPageBase
}
// IsEmpty determines if a QoSPage contains any results.
func (page QoSPage) IsEmpty() (bool, error) {
if page.StatusCode == 204 {
return true, nil
}
qos, err := ExtractQoS(page)
return len(qos) == 0, err
}
// NextPageURL uses the response's embedded link reference to navigate to the
// next page of results.
func (page QoSPage) NextPageURL() (string, error) {
var s struct {
Links []gophercloud.Link `json:"qos_specs_links"`
}
err := page.ExtractInto(&s)
if err != nil {
return "", err
}
return gophercloud.ExtractNextURL(s.Links)
}
// ExtractQoS provides access to the list of qos in a page acquired
// from the List operation.
func ExtractQoS(r pagination.Page) ([]QoS, error) {
var s struct {
QoSs []QoS `json:"qos_specs"`
}
err := (r.(QoSPage)).ExtractInto(&s)
return s.QoSs, err
}
// GetResult is the response of a Get operations. Call its Extract method to
// interpret it as a Flavor.
type GetResult struct {
commonResult
}
// Extract interprets any updateResult as qosSpecs, if possible.
func (r updateResult) Extract() (map[string]string, error) {
var s struct {
QosSpecs map[string]string `json:"qos_specs"`
}
err := r.ExtractInto(&s)
return s.QosSpecs, err
}
// updateResult contains the result of a call for (potentially) multiple
// key-value pairs. Call its Extract method to interpret it as a
// map[string]interface.
type updateResult struct {
gophercloud.Result
}
// AssociateResult contains the response body and error from a Associate request.
type AssociateResult struct {
gophercloud.ErrResult
}
// DisassociateResult contains the response body and error from a Disassociate request.
type DisassociateResult struct {
gophercloud.ErrResult
}
// DisassociateAllResult contains the response body and error from a DisassociateAll request.
type DisassociateAllResult struct {
gophercloud.ErrResult
}
// QoS contains all the information associated with an OpenStack QoS specification.
type QosAssociation struct {
// Name is the name of the associated resource
Name string `json:"name"`
// Unique identifier of the associated resources
ID string `json:"id"`
// AssociationType of the QoS Association
AssociationType string `json:"association_type"`
}
// AssociationPage contains a single page of all Associations of a QoS
type AssociationPage struct {
pagination.SinglePageBase
}
// IsEmpty indicates whether an Association page is empty.
func (page AssociationPage) IsEmpty() (bool, error) {
if page.StatusCode == 204 {
return true, nil
}
v, err := ExtractAssociations(page)
return len(v) == 0, err
}
// ExtractAssociations interprets a page of results as a slice of QosAssociations
func ExtractAssociations(r pagination.Page) ([]QosAssociation, error) {
var s struct {
QosAssociations []QosAssociation `json:"qos_associations"`
}
err := (r.(AssociationPage)).ExtractInto(&s)
return s.QosAssociations, err
}
|
