648 lines
15 KiB
Go
648 lines
15 KiB
Go
package metric
|
|
|
|
import (
|
|
"fmt"
|
|
"math"
|
|
"regexp"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/influxdata/telegraf"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestNewMetric(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
"datacenter": "us-east-1",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
"usage_busy": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, telegraf.Untyped, m.Type())
|
|
assert.Equal(t, tags, m.Tags())
|
|
assert.Equal(t, fields, m.Fields())
|
|
assert.Equal(t, "cpu", m.Name())
|
|
assert.Equal(t, now, m.Time())
|
|
assert.Equal(t, now.UnixNano(), m.UnixNano())
|
|
}
|
|
|
|
func TestNewErrors(t *testing.T) {
|
|
// creating a metric with an empty name produces an error:
|
|
m, err := New(
|
|
"",
|
|
map[string]string{
|
|
"datacenter": "us-east-1",
|
|
"mytag": "foo",
|
|
"another": "tag",
|
|
},
|
|
map[string]interface{}{
|
|
"value": float64(1),
|
|
},
|
|
time.Now(),
|
|
)
|
|
assert.Error(t, err)
|
|
assert.Nil(t, m)
|
|
|
|
// creating a metric with empty fields produces an error:
|
|
m, err = New(
|
|
"foobar",
|
|
map[string]string{
|
|
"datacenter": "us-east-1",
|
|
"mytag": "foo",
|
|
"another": "tag",
|
|
},
|
|
map[string]interface{}{},
|
|
time.Now(),
|
|
)
|
|
assert.Error(t, err)
|
|
assert.Nil(t, m)
|
|
}
|
|
|
|
func TestNewMetric_Tags(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
"datacenter": "us-east-1",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"value": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.True(t, m.HasTag("host"))
|
|
assert.True(t, m.HasTag("datacenter"))
|
|
|
|
m.AddTag("newtag", "foo")
|
|
assert.True(t, m.HasTag("newtag"))
|
|
|
|
m.RemoveTag("host")
|
|
assert.False(t, m.HasTag("host"))
|
|
assert.True(t, m.HasTag("newtag"))
|
|
assert.True(t, m.HasTag("datacenter"))
|
|
|
|
m.RemoveTag("datacenter")
|
|
assert.False(t, m.HasTag("datacenter"))
|
|
assert.True(t, m.HasTag("newtag"))
|
|
assert.Equal(t, map[string]string{"newtag": "foo"}, m.Tags())
|
|
|
|
m.RemoveTag("newtag")
|
|
assert.False(t, m.HasTag("newtag"))
|
|
assert.Equal(t, map[string]string{}, m.Tags())
|
|
|
|
assert.Equal(t, "cpu value=1 "+fmt.Sprint(now.UnixNano())+"\n", m.String())
|
|
}
|
|
|
|
func TestSerialize(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{
|
|
"datacenter": "us-east-1",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"value": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t,
|
|
[]byte("cpu,datacenter=us-east-1 value=1 "+fmt.Sprint(now.UnixNano())+"\n"),
|
|
m.Serialize())
|
|
|
|
m.RemoveTag("datacenter")
|
|
assert.Equal(t,
|
|
[]byte("cpu value=1 "+fmt.Sprint(now.UnixNano())+"\n"),
|
|
m.Serialize())
|
|
}
|
|
|
|
func TestHashID(t *testing.T) {
|
|
m, _ := New(
|
|
"cpu",
|
|
map[string]string{
|
|
"datacenter": "us-east-1",
|
|
"mytag": "foo",
|
|
"another": "tag",
|
|
},
|
|
map[string]interface{}{
|
|
"value": float64(1),
|
|
},
|
|
time.Now(),
|
|
)
|
|
hash := m.HashID()
|
|
|
|
// adding a field doesn't change the hash:
|
|
m.AddField("foo", int64(100))
|
|
assert.Equal(t, hash, m.HashID())
|
|
|
|
// removing a non-existent tag doesn't change the hash:
|
|
m.RemoveTag("no-op")
|
|
assert.Equal(t, hash, m.HashID())
|
|
|
|
// adding a tag does change it:
|
|
m.AddTag("foo", "bar")
|
|
assert.NotEqual(t, hash, m.HashID())
|
|
hash = m.HashID()
|
|
|
|
// removing a tag also changes it:
|
|
m.RemoveTag("mytag")
|
|
assert.NotEqual(t, hash, m.HashID())
|
|
}
|
|
|
|
func TestHashID_Consistency(t *testing.T) {
|
|
m, _ := New(
|
|
"cpu",
|
|
map[string]string{
|
|
"datacenter": "us-east-1",
|
|
"mytag": "foo",
|
|
"another": "tag",
|
|
},
|
|
map[string]interface{}{
|
|
"value": float64(1),
|
|
},
|
|
time.Now(),
|
|
)
|
|
hash := m.HashID()
|
|
|
|
for i := 0; i < 1000; i++ {
|
|
m2, _ := New(
|
|
"cpu",
|
|
map[string]string{
|
|
"datacenter": "us-east-1",
|
|
"mytag": "foo",
|
|
"another": "tag",
|
|
},
|
|
map[string]interface{}{
|
|
"value": float64(1),
|
|
},
|
|
time.Now(),
|
|
)
|
|
assert.Equal(t, hash, m2.HashID())
|
|
}
|
|
}
|
|
|
|
func TestNewMetric_NameModifiers(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{}
|
|
fields := map[string]interface{}{
|
|
"value": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
hash := m.HashID()
|
|
suffix := fmt.Sprintf(" value=1 %d\n", now.UnixNano())
|
|
assert.Equal(t, "cpu"+suffix, m.String())
|
|
|
|
m.SetPrefix("pre_")
|
|
assert.NotEqual(t, hash, m.HashID())
|
|
hash = m.HashID()
|
|
assert.Equal(t, "pre_cpu"+suffix, m.String())
|
|
|
|
m.SetSuffix("_post")
|
|
assert.NotEqual(t, hash, m.HashID())
|
|
hash = m.HashID()
|
|
assert.Equal(t, "pre_cpu_post"+suffix, m.String())
|
|
|
|
m.SetName("mem")
|
|
assert.NotEqual(t, hash, m.HashID())
|
|
assert.Equal(t, "mem"+suffix, m.String())
|
|
}
|
|
|
|
func TestNewMetric_FieldModifiers(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"value": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.True(t, m.HasField("value"))
|
|
assert.False(t, m.HasField("foo"))
|
|
|
|
m.AddField("newfield", "foo")
|
|
assert.True(t, m.HasField("newfield"))
|
|
|
|
assert.NoError(t, m.RemoveField("newfield"))
|
|
assert.False(t, m.HasField("newfield"))
|
|
|
|
// don't allow user to remove all fields:
|
|
assert.Error(t, m.RemoveField("value"))
|
|
|
|
m.AddField("value2", int64(101))
|
|
assert.NoError(t, m.RemoveField("value"))
|
|
assert.False(t, m.HasField("value"))
|
|
}
|
|
|
|
func TestNewMetric_Fields(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(1),
|
|
"int": int64(1),
|
|
"bool": true,
|
|
"false": false,
|
|
"string": "test",
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, fields, m.Fields())
|
|
}
|
|
|
|
func TestNewMetric_Time(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(1),
|
|
"int": int64(1),
|
|
"bool": true,
|
|
"false": false,
|
|
"string": "test",
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
m = m.Copy()
|
|
m2 := m.Copy()
|
|
|
|
assert.Equal(t, now.UnixNano(), m.Time().UnixNano())
|
|
assert.Equal(t, now.UnixNano(), m2.UnixNano())
|
|
}
|
|
|
|
func TestNewMetric_Copy(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{}
|
|
fields := map[string]interface{}{
|
|
"float": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
m2 := m.Copy()
|
|
|
|
assert.Equal(t,
|
|
fmt.Sprintf("cpu float=1 %d\n", now.UnixNano()),
|
|
m.String())
|
|
m.AddTag("host", "localhost")
|
|
assert.Equal(t,
|
|
fmt.Sprintf("cpu,host=localhost float=1 %d\n", now.UnixNano()),
|
|
m.String())
|
|
|
|
assert.Equal(t,
|
|
fmt.Sprintf("cpu float=1 %d\n", now.UnixNano()),
|
|
m2.String())
|
|
}
|
|
|
|
func TestNewMetric_AllTypes(t *testing.T) {
|
|
now := time.Now()
|
|
tags := map[string]string{}
|
|
fields := map[string]interface{}{
|
|
"float64": float64(1),
|
|
"float32": float32(1),
|
|
"int64": int64(1),
|
|
"int32": int32(1),
|
|
"int16": int16(1),
|
|
"int8": int8(1),
|
|
"int": int(1),
|
|
"uint64": uint64(1),
|
|
"uint32": uint32(1),
|
|
"uint16": uint16(1),
|
|
"uint8": uint8(1),
|
|
"uint": uint(1),
|
|
"bytes": []byte("foo"),
|
|
"nil": nil,
|
|
"maxuint64": uint64(MaxInt) + 10,
|
|
"maxuint": uint(MaxInt) + 10,
|
|
"unsupported": []int{1, 2},
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Contains(t, m.String(), "float64=1")
|
|
assert.Contains(t, m.String(), "float32=1")
|
|
assert.Contains(t, m.String(), "int64=1i")
|
|
assert.Contains(t, m.String(), "int32=1i")
|
|
assert.Contains(t, m.String(), "int16=1i")
|
|
assert.Contains(t, m.String(), "int8=1i")
|
|
assert.Contains(t, m.String(), "int=1i")
|
|
assert.Contains(t, m.String(), "uint64=1i")
|
|
assert.Contains(t, m.String(), "uint32=1i")
|
|
assert.Contains(t, m.String(), "uint16=1i")
|
|
assert.Contains(t, m.String(), "uint8=1i")
|
|
assert.Contains(t, m.String(), "uint=1i")
|
|
assert.NotContains(t, m.String(), "nil")
|
|
assert.Contains(t, m.String(), fmt.Sprintf("maxuint64=%di", MaxInt))
|
|
assert.Contains(t, m.String(), fmt.Sprintf("maxuint=%di", MaxInt))
|
|
}
|
|
|
|
func TestIndexUnescapedByte(t *testing.T) {
|
|
tests := []struct {
|
|
in []byte
|
|
b byte
|
|
expected int
|
|
}{
|
|
{
|
|
in: []byte(`foobar`),
|
|
b: 'b',
|
|
expected: 3,
|
|
},
|
|
{
|
|
in: []byte(`foo\bar`),
|
|
b: 'b',
|
|
expected: -1,
|
|
},
|
|
{
|
|
in: []byte(`foo\\bar`),
|
|
b: 'b',
|
|
expected: 5,
|
|
},
|
|
{
|
|
in: []byte(`foobar`),
|
|
b: 'f',
|
|
expected: 0,
|
|
},
|
|
{
|
|
in: []byte(`foobar`),
|
|
b: 'r',
|
|
expected: 5,
|
|
},
|
|
{
|
|
in: []byte(`\foobar`),
|
|
b: 'f',
|
|
expected: -1,
|
|
},
|
|
}
|
|
|
|
for _, test := range tests {
|
|
got := indexUnescapedByte(test.in, test.b)
|
|
assert.Equal(t, test.expected, got)
|
|
}
|
|
}
|
|
|
|
func TestNewGaugeMetric(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
"datacenter": "us-east-1",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
"usage_busy": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now, telegraf.Gauge)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, telegraf.Gauge, m.Type())
|
|
assert.Equal(t, tags, m.Tags())
|
|
assert.Equal(t, fields, m.Fields())
|
|
assert.Equal(t, "cpu", m.Name())
|
|
assert.Equal(t, now, m.Time())
|
|
assert.Equal(t, now.UnixNano(), m.UnixNano())
|
|
}
|
|
|
|
func TestNewCounterMetric(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
"datacenter": "us-east-1",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
"usage_busy": float64(1),
|
|
}
|
|
m, err := New("cpu", tags, fields, now, telegraf.Counter)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, telegraf.Counter, m.Type())
|
|
assert.Equal(t, tags, m.Tags())
|
|
assert.Equal(t, fields, m.Fields())
|
|
assert.Equal(t, "cpu", m.Name())
|
|
assert.Equal(t, now, m.Time())
|
|
assert.Equal(t, now.UnixNano(), m.UnixNano())
|
|
}
|
|
|
|
// test splitting metric into various max lengths
|
|
func TestSplitMetric(t *testing.T) {
|
|
now := time.Unix(0, 1480940990034083306)
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(100001),
|
|
"int": int64(100001),
|
|
"bool": true,
|
|
"false": false,
|
|
"string": "test",
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
split80 := m.Split(80)
|
|
assert.Len(t, split80, 2)
|
|
|
|
split70 := m.Split(70)
|
|
assert.Len(t, split70, 3)
|
|
|
|
split60 := m.Split(60)
|
|
assert.Len(t, split60, 4)
|
|
}
|
|
|
|
// test splitting metric into various max lengths
|
|
// use a simple regex check to verify that the split metrics are valid
|
|
func TestSplitMetric_RegexVerify(t *testing.T) {
|
|
now := time.Unix(0, 1480940990034083306)
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"foo": float64(98934259085),
|
|
"bar": float64(19385292),
|
|
"number": float64(19385292),
|
|
"another": float64(19385292),
|
|
"n": float64(19385292),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
// verification regex
|
|
re := regexp.MustCompile(`cpu,host=localhost \w+=\d+(,\w+=\d+)* 1480940990034083306`)
|
|
|
|
split90 := m.Split(90)
|
|
assert.Len(t, split90, 2)
|
|
for _, splitM := range split90 {
|
|
assert.True(t, re.Match(splitM.Serialize()), splitM.String())
|
|
}
|
|
|
|
split70 := m.Split(70)
|
|
assert.Len(t, split70, 3)
|
|
for _, splitM := range split70 {
|
|
assert.True(t, re.Match(splitM.Serialize()), splitM.String())
|
|
}
|
|
|
|
split20 := m.Split(20)
|
|
assert.Len(t, split20, 5)
|
|
for _, splitM := range split20 {
|
|
assert.True(t, re.Match(splitM.Serialize()), splitM.String())
|
|
}
|
|
}
|
|
|
|
// test splitting metric even when given length is shorter than
|
|
// shortest possible length
|
|
// Split should split metric as short as possible, ie, 1 field per metric
|
|
func TestSplitMetric_TooShort(t *testing.T) {
|
|
now := time.Unix(0, 1480940990034083306)
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(100001),
|
|
"int": int64(100001),
|
|
"bool": true,
|
|
"false": false,
|
|
"string": "test",
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
split := m.Split(10)
|
|
assert.Len(t, split, 5)
|
|
strings := make([]string, 5)
|
|
for i, splitM := range split {
|
|
strings[i] = splitM.String()
|
|
}
|
|
|
|
assert.Contains(t, strings, "cpu,host=localhost float=100001 1480940990034083306\n")
|
|
assert.Contains(t, strings, "cpu,host=localhost int=100001i 1480940990034083306\n")
|
|
assert.Contains(t, strings, "cpu,host=localhost bool=true 1480940990034083306\n")
|
|
assert.Contains(t, strings, "cpu,host=localhost false=false 1480940990034083306\n")
|
|
assert.Contains(t, strings, "cpu,host=localhost string=\"test\" 1480940990034083306\n")
|
|
}
|
|
|
|
func TestSplitMetric_NoOp(t *testing.T) {
|
|
now := time.Unix(0, 1480940990034083306)
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(100001),
|
|
"int": int64(100001),
|
|
"bool": true,
|
|
"false": false,
|
|
"string": "test",
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
split := m.Split(1000)
|
|
assert.Len(t, split, 1)
|
|
assert.Equal(t, m, split[0])
|
|
}
|
|
|
|
func TestSplitMetric_OneField(t *testing.T) {
|
|
now := time.Unix(0, 1480940990034083306)
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"float": float64(100001),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, "cpu,host=localhost float=100001 1480940990034083306\n", m.String())
|
|
|
|
split := m.Split(1000)
|
|
assert.Len(t, split, 1)
|
|
assert.Equal(t, "cpu,host=localhost float=100001 1480940990034083306\n", split[0].String())
|
|
|
|
split = m.Split(1)
|
|
assert.Len(t, split, 1)
|
|
assert.Equal(t, "cpu,host=localhost float=100001 1480940990034083306\n", split[0].String())
|
|
|
|
split = m.Split(40)
|
|
assert.Len(t, split, 1)
|
|
assert.Equal(t, "cpu,host=localhost float=100001 1480940990034083306\n", split[0].String())
|
|
}
|
|
|
|
func TestNewMetricAggregate(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
assert.False(t, m.IsAggregate())
|
|
m.SetAggregate(true)
|
|
assert.True(t, m.IsAggregate())
|
|
}
|
|
|
|
func TestNewMetricPoint(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
p := m.Point()
|
|
pfields, _ := p.Fields()
|
|
|
|
assert.Equal(t, fields, m.Fields())
|
|
assert.Equal(t, fields, pfields)
|
|
assert.Equal(t, "cpu", p.Name())
|
|
}
|
|
|
|
func TestNewMetricString(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": float64(99),
|
|
}
|
|
m, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
|
|
lineProto := fmt.Sprintf("cpu,host=localhost usage_idle=99 %d\n",
|
|
now.UnixNano())
|
|
assert.Equal(t, lineProto, m.String())
|
|
}
|
|
|
|
func TestNewMetricFailNaN(t *testing.T) {
|
|
now := time.Now()
|
|
|
|
tags := map[string]string{
|
|
"host": "localhost",
|
|
}
|
|
fields := map[string]interface{}{
|
|
"usage_idle": math.NaN(),
|
|
}
|
|
|
|
_, err := New("cpu", tags, fields, now)
|
|
assert.NoError(t, err)
|
|
}
|