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
|
/*
* Datadog API for Go
*
* Please see the included LICENSE file for licensing information.
*
* Copyright 2013 by authors and contributors.
*/
package datadog
import (
"net/url"
"strconv"
)
// DataPoint is a tuple of [UNIX timestamp, value]. This has to use floats
// because the value could be non-integer.
type DataPoint [2]*float64
// Metric represents a collection of data points that we might send or receive
// on one single metric line.
type Metric struct {
Metric *string `json:"metric,omitempty"`
Points []DataPoint `json:"points,omitempty"`
Type *string `json:"type,omitempty"`
Host *string `json:"host,omitempty"`
Tags []string `json:"tags,omitempty"`
Unit *string `json:"unit,omitempty"`
Interval *int `json:"interval,omitempty"`
}
// Unit represents a unit definition that we might receive when query for timeseries data.
type Unit struct {
Family string `json:"family"`
ScaleFactor float32 `json:"scale_factor"`
Name string `json:"name"`
ShortName string `json:"short_name"`
Plural string `json:"plural"`
Id int `json:"id"`
}
// A Series is characterized by 2 units as: x per y
// One or both could be missing
type UnitPair []*Unit
// Series represents a collection of data points we get when we query for timeseries data
type Series struct {
Metric *string `json:"metric,omitempty"`
DisplayName *string `json:"display_name,omitempty"`
Points []DataPoint `json:"pointlist,omitempty"`
Start *float64 `json:"start,omitempty"`
End *float64 `json:"end,omitempty"`
Interval *int `json:"interval,omitempty"`
Aggr *string `json:"aggr,omitempty"`
Length *int `json:"length,omitempty"`
Scope *string `json:"scope,omitempty"`
Expression *string `json:"expression,omitempty"`
Units *UnitPair `json:"unit,omitempty"`
QueryIndex *int `json:"query_index,omitempty"`
}
// reqPostSeries from /api/v1/series
type reqPostSeries struct {
Series []Metric `json:"series,omitempty"`
}
// reqMetrics is the container for receiving metric results.
type reqMetrics struct {
Series []Series `json:"series,omitempty"`
}
// PostMetrics takes as input a slice of metrics and then posts them up to the
// server for posting data.
func (client *Client) PostMetrics(series []Metric) error {
return client.doJsonRequest("POST", "/v1/series",
reqPostSeries{Series: series}, nil)
}
// QueryMetrics takes as input from, to (seconds from Unix Epoch) and query string and then requests
// timeseries data for that time peried
func (client *Client) QueryMetrics(from, to int64, query string) ([]Series, error) {
v := url.Values{}
v.Add("from", strconv.FormatInt(from, 10))
v.Add("to", strconv.FormatInt(to, 10))
v.Add("query", query)
var out reqMetrics
err := client.doJsonRequest("GET", "/v1/query?"+v.Encode(), nil, &out)
if err != nil {
return nil, err
}
return out.Series, nil
}
|
