analytics.go

package harper

import (
	"time"
)

type GetAnalyticsResult map[string]interface{}

func (c *Client) GetAnalytics(metric string, getAttributes AttributeList, startTime, endTime int64) ([]GetAnalyticsResult, error) {
	op := operation{
		Operation:     OP_GET_ANALYTICS,
		Metric:        metric,
		GetAttributes: getAttributes,
		StartTime:     startTime,
		EndTime:       endTime,
	}

	results := make([]GetAnalyticsResult, 0)

	err := c.opRequest(op, &results)
	if err != nil {
		return nil, err
	}

	for i, r := range results {
		if r["id"] != nil {
			timeMillis := r["id"].(float64)
			idTime := time.UnixMilli(int64(timeMillis))
			results[i]["id"] = idTime
		}
	}

	return results, nil
}

type ListMetricsResult string

type MetricType int

const (
	MetricTypeCustom MetricType = iota
	MetricTypeBuiltin
)

var metricTypeName = map[MetricType]string{
	MetricTypeCustom:  "custom",
	MetricTypeBuiltin: "builtin",
}

func (c *Client) ListMetrics(types []MetricType) ([]ListMetricsResult, error) {
	typeNames := make([]string, 0, len(types))
	for _, typ := range types {
		typeNames = append(typeNames, metricTypeName[typ])
	}

	op := operation{
		Operation:   OP_LIST_METRICS,
		MetricTypes: typeNames,
	}

	results := make([]ListMetricsResult, 0)

	err := c.opRequest(op, &results)
	if err != nil {
		return nil, err
	}

	return results, nil
}

type DescribeMetricResult struct {
	Attributes []string `json:"attributes"`
}

func (c *Client) DescribeMetric(metric string) (*DescribeMetricResult, error) {
	op := operation{
		Operation: OP_DESCRIBE_METRIC,
		Metric:    metric,
	}

	var result DescribeMetricResult
	err := c.opRequest(op, &result)
	if err != nil {
		return nil, err
	}

	return &result, nil
}