testutil

Documentation

Index

• func GetLocalHost() string
• func MockBatchPoints() client.BatchPoints
• type Accumulator
  • func (a *Accumulator) Add(measurement string, value interface{}, tags map[string]string)
  • func (a *Accumulator) AddValuesWithTime(measurement string, values map[string]interface{}, tags map[string]string, ...)
  • func (a *Accumulator) CheckTaggedValue(measurement string, val interface{}, tags map[string]string) bool
  • func (a *Accumulator) CheckValue(measurement string, val interface{}) bool
  • func (a *Accumulator) Get(measurement string) (*Point, bool)
  • func (a *Accumulator) HasFloatValue(measurement string) bool
  • func (a *Accumulator) HasIntValue(measurement string) bool
  • func (a *Accumulator) HasUIntValue(measurement string) bool
  • func (a *Accumulator) ValidateTaggedValue(measurement string, val interface{}, tags map[string]string) error
  • func (a *Accumulator) ValidateValue(measurement string, val interface{}) error
• type Point

Functions

func GetLocalHost

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

func MockBatchPoints() client.BatchPoints

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

Types

type Accumulator

type Accumulator struct {
	Points []*Point
}

Accumulator defines a mocked out accumulator

func (*Accumulator) Add

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

Add adds a measurement point to the accumulator

func (*Accumulator) AddValuesWithTime

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

AddValuesWithTime adds a measurement point with a specified timestamp.

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 checks that the accumulators point for the given measurement is the same as the given value.

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) HasUIntValue

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

HasUIntValue returns true if the measurement has a UInt value

func (*Accumulator) ValidateTaggedValue

func (a *Accumulator) ValidateTaggedValue(
	measurement string,
	val 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) ValidateValue

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

ValidateValue calls ValidateTaggedValue

type Point

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

Point defines a single point measurement