initial telemetry v2

Author: DSpeichert

openstack/client.go

@@ -39,20 +39,20 @@ func NewClient(endpoint string) (*gophercloud.ProviderClient, error) {
 	}
 
 	parts := strings.Split(path[0:len(path)-1], "/")
-	for index,version := range(parts) {
+	for index, version := range parts {
 		if 2 <= len(version) && len(version) <= 4 && strings.HasPrefix(version, "v") {
 			_, err := strconv.ParseFloat(version[1:], 64)
 			if err == nil {
 				// post version suffixes in path are not supported
 				// version must be on the last index
-				if index < len(parts) - 1 {
+				if index < len(parts)-1 {
 					return nil, fmt.Errorf("Path suffixes (after version) are not supported.")
 				}
 				switch version {
 				case "v2.0", "v3":
 					// valid version found, strip from base
 					return &gophercloud.ProviderClient{
-						IdentityBase:     base[0:len(base)-len(version)-1],
+						IdentityBase:     base[0 : len(base)-len(version)-1],
 						IdentityEndpoint: endpoint,
 					}, nil
 				default:
@@ -356,3 +356,13 @@ func NewImageServiceV2(client *gophercloud.ProviderClient, eo gophercloud.Endpoi
 		Endpoint:     url,
 		ResourceBase: url + "v2/"}, nil
 }
+
+// NewTelemetryV2 creates a ServiceClient that may be used to access the v2 telemetry service.
+func NewTelemetryV2(client *gophercloud.ProviderClient, eo gophercloud.EndpointOpts) (*gophercloud.ServiceClient, error) {
+	eo.ApplyDefaults("metering")
+	url, err := client.EndpointLocator(eo)
+	if err != nil {
+		return nil, err
+	}
+	return &gophercloud.ServiceClient{ProviderClient: client, Endpoint: url}, nil
+}

openstack/telemetry/v2/meters/doc.go

@@ -0,0 +1 @@
+package meters

openstack/telemetry/v2/meters/requests.go

@@ -0,0 +1,88 @@
+package meters
+
+import "github.com/rackspace/gophercloud"
+
+// ListOptsBuilder allows extensions to add additional parameters to the
+// List request.
+type ListOptsBuilder interface {
+	ToMeterListQuery() (string, error)
+}
+
+// ListOpts allows the filtering and sorting of collections through
+// the API. Filtering is achieved by passing in struct field values that map to
+// the server attributes you want to see returned.
+type ListOpts struct {
+}
+
+// ToServerListQuery formats a ListOpts into a query string.
+func (opts ListOpts) ToMeterListQuery() (string, error) {
+	q, err := gophercloud.BuildQueryString(opts)
+	if err != nil {
+		return "", err
+	}
+	return q.String(), nil
+}
+
+// List makes a request against the API to list meters accessible to you.
+func List(client *gophercloud.ServiceClient, opts ListOptsBuilder) (res listResult, err error) {
+	url := listURL(client)
+
+	if opts != nil {
+		query, err := opts.ToMeterListQuery()
+		if err != nil {
+			return res, err
+		}
+		url += query
+	}
+
+	_, err = client.Get(url, &res.Body, &gophercloud.RequestOpts{})
+
+	return
+}
+
+// StatisticsOptsBuilder allows extensions to add additional parameters to the
+// List request.
+type MeterStatisticsOptsBuilder interface {
+	ToMeterStatisticsQuery() (string, error)
+}
+
+// StatisticsOpts allows the filtering and sorting of collections through
+// the API. Filtering is achieved by passing in struct field values that map to
+// the server attributes you want to see returned.
+type MeterStatisticsOpts struct {
+	QueryField string `q:"q.field"`
+	QueryOp    string `q:"q.op"`
+	QueryValue string `q:"q.value"`
+
+	// Optional group by
+	GroupBy string `q:"groupby"`
+
+	// Optional number of seconds in a period
+	Period int `q:"period"`
+}
+
+// ToStatisticsQuery formats a StatisticsOpts into a query string.
+func (opts MeterStatisticsOpts) ToMeterStatisticsQuery() (string, error) {
+	q, err := gophercloud.BuildQueryString(opts)
+	if err != nil {
+		return "", err
+	}
+	return q.String(), nil
+}
+
+// List makes a request against the API to list meters accessible to you.
+func MeterStatistics(client *gophercloud.ServiceClient, n string, opts MeterStatisticsOptsBuilder) (res statisticsResult, err error) {
+	url := statisticsURL(client, n)
+
+	if opts != nil {
+		query, err := opts.ToMeterStatisticsQuery()
+		if err != nil {
+			return res, err
+		}
+		url += query
+	}
+
+	_, err = client.Get(url, &res.Body, &gophercloud.RequestOpts{})
+
+	return
+}

openstack/telemetry/v2/meters/results.go

@@ -0,0 +1,99 @@
+package meters
+
+import (
+	"reflect"
+
+	"github.com/mitchellh/mapstructure"
+	"github.com/rackspace/gophercloud"
+)
+
+type MeterListResult struct {
+	MeterId    string `json:"meter_id"`
+	Name       string `json:"name"`
+	ProjectId  string `json:"project_id"`
+	ResourceId string `json:"resource_id"`
+	Source     string `json:"source"`
+	Type       string `json:"type"`
+	Unit       string `json:"user"`
+	UserId     string `json:"user_id"`
+}
+
+type listResult struct {
+	gophercloud.Result
+}
+
+// Extract interprets any serverResult as a Server, if possible.
+func (r listResult) Extract() (*[]MeterListResult, error) {
+	if r.Err != nil {
+		return nil, r.Err
+	}
+
+	var response []MeterListResult
+
+	config := &mapstructure.DecoderConfig{
+		DecodeHook: toMapFromString,
+		Result:     &response,
+	}
+	decoder, err := mapstructure.NewDecoder(config)
+	if err != nil {
+		return nil, err
+	}
+
+	err = decoder.Decode(r.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	return &response, nil
+}
+
+type MeterStatisticsResult struct {
+	Avg           float32 `json:"avg"`
+	Count         int     `json:"count"`
+	Duration      float32 `json:"duration"`
+	DurationEnd   string  `json:"duration_end"`
+	DurationStart string  `json:"duration_start"`
+	Max           float32 `json:"max"`
+	Min           float32 `json:"min"`
+	Period        int     `json:"user_id"`
+	PeriodEnd     string  `json:"period_end"`
+	PeriodStart   string  `json:"period_start"`
+	Sum           float32 `json:"sum"`
+	Unit          string  `json:"unit"`
+}
+
+type statisticsResult struct {
+	gophercloud.Result
+}
+
+// Extract interprets any serverResult as a Server, if possible.
+func (r statisticsResult) Extract() (*[]MeterStatisticsResult, error) {
+	if r.Err != nil {
+		return nil, r.Err
+	}
+
+	var response []MeterStatisticsResult
+
+	config := &mapstructure.DecoderConfig{
+		DecodeHook: toMapFromString,
+		Result:     &response,
+	}
+	decoder, err := mapstructure.NewDecoder(config)
+	if err != nil {
+		return nil, err
+	}
+
+	err = decoder.Decode(r.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	return &response, nil
+}
+
+func toMapFromString(from reflect.Kind, to reflect.Kind, data interface{}) (interface{}, error) {
+	if (from == reflect.String) && (to == reflect.Map) {
+		return map[string]interface{}{}, nil
+	}
+	return data, nil
+}

openstack/telemetry/v2/meters/urls.go

@@ -0,0 +1,19 @@
+package meters
+
+import "github.com/rackspace/gophercloud"
+
+func listURL(client *gophercloud.ServiceClient) string {
+	return client.ServiceURL("v2", "meters")
+}
+
+func showURL(client *gophercloud.ServiceClient, name string) string {
+	return client.ServiceURL("v2", "meters", name)
+}
+
+func createURL(client *gophercloud.ServiceClient, name string) string {
+	return client.ServiceURL("v2", "meters", name)
+}
+
+func statisticsURL(client *gophercloud.ServiceClient, name string) string {
+	return client.ServiceURL("v2", "meters", name, "statistics")
+}