accumulator

package
v3.3.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 18, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Accumulator

type Accumulator struct {
	// contains filtered or unexported fields
}

Accumulator is an interface used to accumulate telegraf measurements from Telegraf plugins.

func NewAccumulator

func NewAccumulator(e emitter.Emitter) *Accumulator

NewAccumulator returns a pointer to an Accumulator

func (*Accumulator) AddCounter

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

AddCounter receives a measurement as a "Counter" with tags and a time stamp to the accumulator. Measurements are passed to the Accumulator's Emitter.

func (*Accumulator) AddError

func (ac *Accumulator) AddError(err error)

AddError - log an error returned by the plugin

func (*Accumulator) AddFields

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

AddFields receives a measurement with tags and a time stamp to the accumulator. Measurements are passed to the Accumulator's Emitter.

func (*Accumulator) AddGauge

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

AddGauge receives a measurement as a "Gauge" with tags and a time stamp to the accumulator. Measurements are passed to the Accumulator's Emitter.

func (*Accumulator) AddHistogram

func (ac *Accumulator) AddHistogram(measurement string, fields map[string]interface{},
	tags map[string]string, t ...time.Time)

AddHistogram receives a measurement as a "Counter" with tags and a time stamp to the accumulator. Measurements are passed to the Accumulator's Emitter.

func (*Accumulator) AddSummary

func (ac *Accumulator) AddSummary(measurement string, fields map[string]interface{},
	tags map[string]string, t ...time.Time)

AddSummary receives a measurement as a "Counter" with tags and a time stamp to the accumulator. Measurements are passed to the Accumulator's Emitter.

func (*Accumulator) SetPrecision

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

SetPrecision - SignalFx does not implement this

Jump to

Keyboard shortcuts

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