forked from grafana/metrictank
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmsgp_test.go
More file actions
113 lines (103 loc) · 2.35 KB
/
msgp_test.go
File metadata and controls
113 lines (103 loc) · 2.35 KB
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
package response
import (
"math"
"testing"
"github.com/grafana/metrictank/api/models"
"gopkg.in/raintank/schema.v1"
)
func BenchmarkHttpRespMsgpEmptySeries(b *testing.B) {
data := []models.Series{
{
Target: "an.empty.series",
Datapoints: make([]schema.Point, 0),
Interval: 10,
},
}
var resp *Msgp
for n := 0; n < b.N; n++ {
resp = NewMsgp(200, models.SeriesByTarget(data))
resp.Body()
resp.Close()
}
}
func BenchmarkHttpRespMsgpEmptySeriesNeedsEscaping(b *testing.B) {
data := []models.Series{
{
Target: `an.empty\series`,
Datapoints: make([]schema.Point, 0),
Interval: 10,
},
}
var resp *Msgp
for n := 0; n < b.N; n++ {
resp = NewMsgp(200, models.SeriesByTarget(data))
resp.Body()
resp.Close()
}
}
func BenchmarkHttpRespMsgpIntegers(b *testing.B) {
points := make([]schema.Point, 1000, 1000)
baseTs := 1500000000
for i := 0; i < 1000; i++ {
points[i] = schema.Point{Val: float64(10000 * i), Ts: uint32(baseTs + 10*i)}
}
data := []models.Series{
{
Target: "some.metric.with.a-whole-bunch-of.integers",
Datapoints: points,
Interval: 10,
},
}
b.SetBytes(int64(len(points) * 12))
b.ResetTimer()
var resp *Msgp
for n := 0; n < b.N; n++ {
resp = NewMsgp(200, models.SeriesByTarget(data))
resp.Body()
resp.Close()
}
}
func BenchmarkHttpRespMsgpFloats(b *testing.B) {
points := make([]schema.Point, 1000, 1000)
baseTs := 1500000000
for i := 0; i < 1000; i++ {
points[i] = schema.Point{Val: 12.34 * float64(i), Ts: uint32(baseTs + 10*i)}
}
data := []models.Series{
{
Target: "some.metric.with.a-whole-bunch-of.floats",
Datapoints: points,
Interval: 10,
},
}
b.SetBytes(int64(len(points) * 12))
b.ResetTimer()
var resp *Msgp
for n := 0; n < b.N; n++ {
resp = NewMsgp(200, models.SeriesByTarget(data))
resp.Body()
resp.Close()
}
}
func BenchmarkHttpRespMsgpNulls(b *testing.B) {
points := make([]schema.Point, 1000, 1000)
baseTs := 1500000000
for i := 0; i < 1000; i++ {
points[i] = schema.Point{Val: math.NaN(), Ts: uint32(baseTs + 10*i)}
}
data := []models.Series{
{
Target: "some.metric.with.a-whole-bunch-of.nulls",
Datapoints: points,
Interval: 10,
},
}
b.SetBytes(int64(len(points) * 12))
b.ResetTimer()
var resp *Msgp
for n := 0; n < b.N; n++ {
resp = NewMsgp(200, models.SeriesByTarget(data))
resp.Body()
resp.Close()
}
}