telegraf/testutil/accumulator.go

257 lines
5.0 KiB
Go
Raw Normal View History

package testutil
import (
"encoding/json"
"fmt"
2015-06-20 12:32:32 +00:00
"reflect"
2015-10-16 14:54:33 +00:00
"sync"
"sync/atomic"
2016-01-05 23:58:35 +00:00
"testing"
2015-10-16 18:54:05 +00:00
"time"
2016-01-05 23:58:35 +00:00
"github.com/stretchr/testify/assert"
)
2015-04-06 21:53:43 +00:00
// Metric defines a single point measurement
type Metric struct {
2015-05-29 20:25:48 +00:00
Measurement string
Tags map[string]string
2015-11-13 19:51:37 +00:00
Fields map[string]interface{}
2015-05-29 20:25:48 +00:00
Time time.Time
}
func (p *Metric) String() string {
2015-11-13 19:51:37 +00:00
return fmt.Sprintf("%s %v", p.Measurement, p.Fields)
}
// Accumulator defines a mocked out accumulator
type Accumulator struct {
2015-10-16 14:54:33 +00:00
sync.Mutex
Metrics []*Metric
nMetrics uint64
Discard bool
Errors []error
debug bool
}
// Add adds a measurement point to the accumulator
func (a *Accumulator) Add(
measurement string,
value interface{},
tags map[string]string,
t ...time.Time,
) {
2015-11-13 19:51:37 +00:00
fields := map[string]interface{}{"value": value}
a.AddFields(measurement, fields, tags, t...)
}
func (a *Accumulator) NMetrics() uint64 {
return atomic.LoadUint64(&a.nMetrics)
}
// AddFields adds a measurement point with a specified timestamp.
func (a *Accumulator) AddFields(
2015-05-29 20:25:48 +00:00
measurement string,
2015-11-13 19:51:37 +00:00
fields map[string]interface{},
tags map[string]string,
timestamp ...time.Time,
) {
atomic.AddUint64(&a.nMetrics, 1)
if a.Discard {
return
}
a.Lock()
defer a.Unlock()
2015-11-13 19:51:37 +00:00
if tags == nil {
tags = map[string]string{}
}
if len(fields) == 0 {
return
}
var t time.Time
if len(timestamp) > 0 {
t = timestamp[0]
} else {
t = time.Now()
}
2015-11-13 19:51:37 +00:00
if a.debug {
pretty, _ := json.MarshalIndent(fields, "", " ")
prettyTags, _ := json.MarshalIndent(tags, "", " ")
msg := fmt.Sprintf("Adding Measurement [%s]\nFields:%s\nTags:%s\n",
measurement, string(pretty), string(prettyTags))
fmt.Print(msg)
}
p := &Metric{
2015-11-13 19:51:37 +00:00
Measurement: measurement,
Fields: fields,
Tags: tags,
Time: t,
}
a.Metrics = append(a.Metrics, p)
}
// AddError appends the given error to Accumulator.Errors.
func (a *Accumulator) AddError(err error) {
if err == nil {
return
}
a.Lock()
a.Errors = append(a.Errors, err)
a.Unlock()
}
func (a *Accumulator) SetPrecision(precision, interval time.Duration) {
return
}
func (a *Accumulator) DisablePrecision() {
return
}
func (a *Accumulator) Debug() bool {
// stub for implementing Accumulator interface.
return a.debug
}
func (a *Accumulator) SetDebug(debug bool) {
// stub for implementing Accumulator interface.
a.debug = debug
}
// Get gets the specified measurement point from the accumulator
func (a *Accumulator) Get(measurement string) (*Metric, bool) {
for _, p := range a.Metrics {
2015-05-29 20:25:48 +00:00
if p.Measurement == measurement {
2015-05-18 17:46:44 +00:00
return p, true
}
}
return nil, false
}
2016-01-05 23:58:35 +00:00
// NFields returns the total number of fields in the accumulator, across all
// measurements
func (a *Accumulator) NFields() int {
a.Lock()
defer a.Unlock()
2016-01-05 23:58:35 +00:00
counter := 0
for _, pt := range a.Metrics {
2016-01-05 23:58:35 +00:00
for _, _ = range pt.Fields {
counter++
2015-04-06 17:34:55 +00:00
}
}
2016-01-05 23:58:35 +00:00
return counter
2015-04-07 18:54:21 +00:00
}
2015-05-18 17:46:44 +00:00
func (a *Accumulator) AssertContainsTaggedFields(
2016-01-05 23:58:35 +00:00
t *testing.T,
measurement string,
fields map[string]interface{},
tags map[string]string,
2016-01-05 23:58:35 +00:00
) {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
if !reflect.DeepEqual(tags, p.Tags) {
continue
}
if p.Measurement == measurement {
assert.Equal(t, fields, p.Fields)
2016-01-05 23:58:35 +00:00
return
}
}
2016-01-05 23:58:35 +00:00
msg := fmt.Sprintf("unknown measurement %s with tags %v", measurement, tags)
assert.Fail(t, msg)
}
func (a *Accumulator) AssertContainsFields(
t *testing.T,
measurement string,
fields map[string]interface{},
) {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
if p.Measurement == measurement {
assert.Equal(t, fields, p.Fields)
return
}
}
msg := fmt.Sprintf("unknown measurement %s", measurement)
assert.Fail(t, msg)
}
// HasIntValue returns true if the measurement has an Int value
2016-01-05 23:58:35 +00:00
func (a *Accumulator) HasIntField(measurement string, field string) bool {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
2015-05-29 20:25:48 +00:00
if p.Measurement == measurement {
2016-01-05 23:58:35 +00:00
for fieldname, value := range p.Fields {
if fieldname == field {
_, ok := value.(int64)
return ok
}
}
2015-05-18 17:46:44 +00:00
}
}
return false
}
2015-08-04 22:48:19 +00:00
// HasUIntValue returns true if the measurement has a UInt value
2016-01-05 23:58:35 +00:00
func (a *Accumulator) HasUIntField(measurement string, field string) bool {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
2015-08-04 22:48:19 +00:00
if p.Measurement == measurement {
2016-01-05 23:58:35 +00:00
for fieldname, value := range p.Fields {
if fieldname == field {
_, ok := value.(uint64)
return ok
}
}
2015-08-04 22:48:19 +00:00
}
}
return false
}
// HasFloatValue returns true if the given measurement has a float value
2016-01-05 23:58:35 +00:00
func (a *Accumulator) HasFloatField(measurement string, field string) bool {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
2015-05-29 20:25:48 +00:00
if p.Measurement == measurement {
2016-01-05 23:58:35 +00:00
for fieldname, value := range p.Fields {
if fieldname == field {
_, ok := value.(float64)
return ok
}
}
2015-05-18 17:46:44 +00:00
}
}
return false
}
2015-09-02 23:16:52 +00:00
// HasMeasurement returns true if the accumulator has a measurement with the
// given name
func (a *Accumulator) HasMeasurement(measurement string) bool {
a.Lock()
defer a.Unlock()
for _, p := range a.Metrics {
2015-09-02 23:16:52 +00:00
if p.Measurement == measurement {
return true
}
}
return false
}