Documentation ¶
Index ¶
- func GetLocalHost() string
- func MockMetrics() []telegraf.Metric
- func TestMetric(value interface{}, name ...string) telegraf.Metric
- type Accumulator
- func (a *Accumulator) Add(measurement string, value interface{}, tags map[string]string, t ...time.Time)
- func (a *Accumulator) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
- 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) Debug() bool
- func (a *Accumulator) Get(measurement string) (*Metric, bool)
- func (a *Accumulator) HasFloatField(measurement string, field string) bool
- func (a *Accumulator) HasIntField(measurement string, field string) bool
- func (a *Accumulator) HasMeasurement(measurement string) bool
- func (a *Accumulator) HasUIntField(measurement string, field string) bool
- func (a *Accumulator) NFields() int
- func (a *Accumulator) SetDebug(debug bool)
- type Metric
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
MockMetrics returns a mock []telegraf.Metric object for using in unit tests of telegraf output sinks.
func TestMetric ¶
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 ¶
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) 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) AssertContainsFields ¶
func (a *Accumulator) AssertContainsFields( t *testing.T, measurement string, fields map[string]interface{}, )
func (*Accumulator) AssertContainsTaggedFields ¶
func (*Accumulator) Debug ¶
func (a *Accumulator) Debug() bool
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) HasIntField ¶
func (a *Accumulator) HasIntField(measurement string, field string) bool
HasIntValue 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) 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) SetDebug ¶
func (a *Accumulator) SetDebug(debug bool)