accumulator

Documentation

Index

• type Accumulator
  • func NewAccumulator(e emitter.Emitter) *Accumulator
  • func (ac *Accumulator) AddCounter(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) AddError(err error)
  • func (ac *Accumulator) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) AddGauge(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) AddHistogram(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) AddSummary(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) SetPrecision(precision, interval time.Duration)

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