-
Notifications
You must be signed in to change notification settings - Fork 52
/
results.go
117 lines (96 loc) · 3.45 KB
/
results.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
package metrics
import (
"github.com/gophercloud/gophercloud/v2"
"github.com/gophercloud/gophercloud/v2/pagination"
"github.com/gophercloud/utils/v2/gnocchi/metric/v1/archivepolicies"
"github.com/gophercloud/utils/v2/gnocchi/metric/v1/resources"
)
type commonResult struct {
gophercloud.Result
}
// Extract is a function that accepts a result and extracts a Gnocchi metric.
func (r commonResult) Extract() (*Metric, error) {
var s *Metric
err := r.ExtractInto(&s)
return s, err
}
// GetResult represents the result of a get operation. Call its Extract
// method to interpret it as a metric.
type GetResult struct {
commonResult
}
// CreateResult represents the result of a create operation. Call its Extract
// method to interpret it as a Gnocchi metric.
type CreateResult struct {
commonResult
}
// DeleteResult represents the result of a delete operation. Call its
// ExtractErr method to determine if the request succeeded or failed.
type DeleteResult struct {
gophercloud.ErrResult
}
// Metric is an entity storing aggregates identified by an UUID.
// It can be attached to a resource using a name.
// How a metric stores its aggregates is defined by the archive policy
// it is associated to.
type Metric struct {
// ArchivePolicy is a Gnocchi archive policy that describes the aggregate
// storage policy of a metric.
ArchivePolicy archivepolicies.ArchivePolicy `json:"archive_policy"`
// ArchivePolicyName is a name of the Gnocchi archive policy that describes
// the aggregate storage policy of a metric.
// Usually that field is not empty if a Metric struct is a result
// from a create request.
ArchivePolicyName string `json:"archive_policy_name"`
// CreatedByProjectID contains the id of the Identity project that
// was used for a metric creation.
CreatedByProjectID string `json:"created_by_project_id"`
// CreatedByUserID contains the id of the Identity user
// that created the Gnocchi metric.
CreatedByUserID string `json:"created_by_user_id"`
// Creator shows who created the metric.
// Usually it contains concatenated string with values from
// "created_by_user_id" and "created_by_project_id" fields.
Creator string `json:"creator"`
// ID uniquely identifies the Gnocchi metric.
ID string `json:"id"`
// Name is a human-readable name for the Gnocchi metric.
Name string `json:"name"`
// ResourceID identifies the associated Gnocchi resource of the metric.
ResourceID string `json:"resource_id"`
// Resource is a Gnocchi resource representation.
Resource resources.Resource `json:"resource"`
// Unit is a unit of measurement for measures of that Gnocchi metric.
Unit string `json:"unit"`
}
// MetricPage is the page returned by a pager when traversing over a collection
// of metrics.
type MetricPage struct {
pagination.MarkerPageBase
}
// IsEmpty checks whether a MetricPage struct is empty.
func (r MetricPage) IsEmpty() (bool, error) {
is, err := ExtractMetrics(r)
return len(is) == 0, err
}
// LastMarker returns the last metric ID in a ListResult.
func (r MetricPage) LastMarker() (string, error) {
metrics, err := ExtractMetrics(r)
if err != nil {
return "", err
}
if len(metrics) == 0 {
return "", nil
}
return metrics[len(metrics)-1].ID, nil
}
// ExtractMetrics interprets the results of a single page from a List() call,
// producing a slice of Metric structs.
func ExtractMetrics(r pagination.Page) ([]Metric, error) {
var s []Metric
err := (r.(MetricPage)).ExtractInto(&s)
if err != nil {
return nil, err
}
return s, err
}