testutil

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 18, 2015 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetLocalHost added in v0.1.4

func GetLocalHost() string

GetLocalHost returns the DOCKER_HOST environment variable, parsing out any scheme or ports so that only the IP address is returned.

func MockBatchPoints added in v0.1.7

func MockBatchPoints() client.BatchPoints

MockBatchPoints returns a mock BatchPoints object for using in unit tests of telegraf output sinks.

func TestPoint added in v0.2.1

func TestPoint(value interface{}, name ...string) *client.Point

TestPoint Returns a simple test point:

measurement -> "test1" or name
tags -> "tag1":"value1"
value -> value
time -> time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC)

Types

type Accumulator

type Accumulator struct {
	sync.Mutex
	Points []*Point
}

Accumulator defines a mocked out accumulator

func (*Accumulator) Add

func (a *Accumulator) Add(
	measurement string,
	value interface{},
	tags map[string]string,
	t ...time.Time,
)

Add adds a measurement point to the accumulator

func (*Accumulator) AddDefaultTag added in v0.2.0

func (a *Accumulator) AddDefaultTag(key, value string)

func (*Accumulator) AddFields added in v0.2.0

func (a *Accumulator) AddFields(
	measurement string,
	fields map[string]interface{},
	tags map[string]string,
	timestamp ...time.Time,
)

AddFields adds a measurement point with a specified timestamp.

func (*Accumulator) CheckFieldsValue added in v0.2.1

func (a *Accumulator) CheckFieldsValue(measurement string, fields map[string]interface{}) bool

CheckValue checks that the accumulators point for the given measurement is the same as the given value.

func (*Accumulator) CheckTaggedFieldsValue added in v0.2.1

func (a *Accumulator) CheckTaggedFieldsValue(
	measurement string,
	fields map[string]interface{},
	tags map[string]string,
) bool

CheckTaggedFieldsValue calls ValidateTaggedFieldsValue

func (*Accumulator) CheckTaggedValue

func (a *Accumulator) CheckTaggedValue(
	measurement string,
	val interface{},
	tags map[string]string,
) bool

CheckTaggedValue calls ValidateTaggedValue

func (*Accumulator) CheckValue

func (a *Accumulator) CheckValue(measurement string, val interface{}) bool

CheckValue calls CheckFieldsValue passing a single-value map as fields

func (*Accumulator) Debug added in v0.2.0

func (a *Accumulator) Debug() bool

func (*Accumulator) Get

func (a *Accumulator) Get(measurement string) (*Point, bool)

Get gets the specified measurement point from the accumulator

func (*Accumulator) HasFloatValue

func (a *Accumulator) HasFloatValue(measurement string) bool

HasFloatValue returns true if the given measurement has a float value

func (*Accumulator) HasIntValue

func (a *Accumulator) HasIntValue(measurement string) bool

HasIntValue returns true if the measurement has an Int value

func (*Accumulator) HasMeasurement added in v0.1.8

func (a *Accumulator) HasMeasurement(measurement string) bool

HasMeasurement returns true if the accumulator has a measurement with the given name

func (*Accumulator) HasUIntValue added in v0.1.4

func (a *Accumulator) HasUIntValue(measurement string) bool

HasUIntValue returns true if the measurement has a UInt value

func (*Accumulator) Prefix added in v0.2.0

func (a *Accumulator) Prefix() string

func (*Accumulator) SetDebug added in v0.2.0

func (a *Accumulator) SetDebug(debug bool)

func (*Accumulator) SetDefaultTags added in v0.2.0

func (a *Accumulator) SetDefaultTags(tags map[string]string)

func (*Accumulator) SetPrefix added in v0.2.0

func (a *Accumulator) SetPrefix(prefix string)

func (*Accumulator) ValidateFieldsValue added in v0.2.1

func (a *Accumulator) ValidateFieldsValue(
	measurement string,
	fields map[string]interface{},
) error

ValidateFieldsValue calls ValidateTaggedFieldsValue

func (*Accumulator) ValidateTaggedFields added in v0.2.1

func (a *Accumulator) ValidateTaggedFields(
	measurement string,
	fields map[string]interface{},
	tags map[string]string,
) error

func (*Accumulator) ValidateTaggedFieldsValue added in v0.2.1

func (a *Accumulator) ValidateTaggedFieldsValue(
	measurement string,
	fields map[string]interface{},
	tags map[string]string,
) error

ValidateTaggedValue validates that the given measurement and value exist in the accumulator and with the given tags.

func (*Accumulator) ValidateTaggedValue

func (a *Accumulator) ValidateTaggedValue(
	measurement string,
	val interface{},
	tags map[string]string,
) error

ValidateTaggedValue calls ValidateTaggedFieldsValue passing a single-value map as fields

func (*Accumulator) ValidateValue

func (a *Accumulator) ValidateValue(measurement string, val interface{}) error

ValidateValue calls ValidateTaggedValue

type Point

type Point struct {
	Measurement string
	Tags        map[string]string
	Fields      map[string]interface{}
	Time        time.Time
}

Point defines a single point measurement

func (*Point) String added in v0.2.1

func (p *Point) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL