testutil

Documentation

Index

• func GetLocalHost() string
• func MockMetrics() []telegraf.Metric
• func TestMetric(value interface{}, name ...string) telegraf.Metric
• type Accumulator
  • func (a *Accumulator) AddCounter(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *Accumulator) AddError(err error)
  • func (a *Accumulator) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *Accumulator) AddGauge(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *Accumulator) AddMetrics(metrics []telegraf.Metric)
  • func (a *Accumulator) AssertContainsFields(t *testing.T, measurement string, fields map[string]interface{})
  • func (a *Accumulator) AssertContainsTaggedFields(t *testing.T, measurement string, fields map[string]interface{}, ...)
  • func (a *Accumulator) AssertDoesNotContainMeasurement(t *testing.T, measurement string)
  • func (a *Accumulator) ClearMetrics()
  • func (a *Accumulator) Debug() bool
  • func (a *Accumulator) DisablePrecision()
  • func (a *Accumulator) Get(measurement string) (*Metric, bool)
  • func (a *Accumulator) HasFloatField(measurement string, field string) bool
  • func (a *Accumulator) HasInt32Field(measurement string, field string) bool
  • func (a *Accumulator) HasIntField(measurement string, field string) bool
  • func (a *Accumulator) HasMeasurement(measurement string) bool
  • func (a *Accumulator) HasStringField(measurement string, field string) bool
  • func (a *Accumulator) HasUIntField(measurement string, field string) bool
  • func (a *Accumulator) NFields() int
  • func (a *Accumulator) NMetrics() uint64
  • func (a *Accumulator) SetDebug(debug bool)
  • func (a *Accumulator) SetPrecision(precision, interval time.Duration)
  • func (a *Accumulator) Wait()
• type Metric
  • func (p *Metric) String() string

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 MockMetrics

func MockMetrics() []telegraf.Metric

MockMetrics returns a mock []telegraf.Metric object for using in unit tests of telegraf output sinks.

func TestMetric

func TestMetric(value interface{}, name ...string) telegraf.Metric

TestMetric 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
	*sync.Cond

	Metrics []*Metric

	Discard bool
	Errors  []error
	// contains filtered or unexported fields
}

Accumulator defines a mocked out accumulator

func (*Accumulator) AddCounter

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

func (*Accumulator) AddError

func (a *Accumulator) AddError(err error)

AddError appends the given error to Accumulator.Errors.

func (*Accumulator) AddFields

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

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

func (*Accumulator) AddMetrics

func (a *Accumulator) AddMetrics(metrics []telegraf.Metric)

func (*Accumulator) AssertContainsFields

func (a *Accumulator) AssertContainsFields(
	t *testing.T,
	measurement string,
	fields map[string]interface{},
)

func (*Accumulator) AssertContainsTaggedFields

func (a *Accumulator) AssertContainsTaggedFields(
	t *testing.T,
	measurement string,
	fields map[string]interface{},
	tags map[string]string,
)

func (*Accumulator) AssertDoesNotContainMeasurement

func (a *Accumulator) AssertDoesNotContainMeasurement(t *testing.T, measurement string)

func (*Accumulator) ClearMetrics

func (a *Accumulator) ClearMetrics()

func (*Accumulator) Debug

func (a *Accumulator) Debug() bool

func (*Accumulator) DisablePrecision

func (a *Accumulator) DisablePrecision()

func (*Accumulator) Get

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

Get gets the specified measurement point from the accumulator

func (*Accumulator) HasFloatField

func (a *Accumulator) HasFloatField(measurement string, field string) bool

HasFloatValue returns true if the given measurement has a float value

func (*Accumulator) HasInt32Field

func (a *Accumulator) HasInt32Field(measurement string, field string) bool

HasInt32Field returns true if the measurement has an Int value

func (*Accumulator) HasIntField

func (a *Accumulator) HasIntField(measurement string, field string) bool

HasIntField returns true if the measurement has an Int value

func (*Accumulator) HasMeasurement

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

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

func (*Accumulator) HasStringField

func (a *Accumulator) HasStringField(measurement string, field string) bool

HasStringField returns true if the measurement has an String value

func (*Accumulator) HasUIntField

func (a *Accumulator) HasUIntField(measurement string, field string) bool

HasUIntValue returns true if the measurement has a UInt value

func (*Accumulator) NFields

func (a *Accumulator) NFields() int

NFields returns the total number of fields in the accumulator, across all measurements

func (*Accumulator) NMetrics

func (a *Accumulator) NMetrics() uint64

func (*Accumulator) SetDebug

func (a *Accumulator) SetDebug(debug bool)

func (*Accumulator) SetPrecision

func (a *Accumulator) SetPrecision(precision, interval time.Duration)

func (*Accumulator) Wait

func (a *Accumulator) Wait()

Wait waits for a metric to be added to the accumulator. Accumulator must already be locked.

type Metric

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

Metric defines a single point measurement

func (*Metric) String

func (p *Metric) String() string