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) AddMetric(m telegraf.Metric)
  • func (ac *Accumulator) AddMetrics(ms []telegraf.Metric)
  • func (ac *Accumulator) AddSummary(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (ac *Accumulator) SetPrecision(precision, interval time.Duration)
  • func (ac *Accumulator) WithTracking(max int) telegraf.TrackingAccumulator
• type TrackingAccumulator
  • func (ta *TrackingAccumulator) AddTrackingMetric(m telegraf.Metric) telegraf.TrackingID
  • func (ta *TrackingAccumulator) AddTrackingMetricGroup(group []telegraf.Metric) telegraf.TrackingID
  • func (ta *TrackingAccumulator) Delivered() <-chan telegraf.DeliveryInfo

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

func (ac *Accumulator) AddMetric(m telegraf.Metric)

AddMetric - adds a metric and will use the configured

func (*Accumulator) AddMetrics

func (ac *Accumulator) AddMetrics(ms []telegraf.Metric)

AddMetrics - is a convenience function for adding multiple metrics to the telegraf accumulator

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

func (*Accumulator) WithTracking

func (ac *Accumulator) WithTracking(max int) telegraf.TrackingAccumulator

WithTracking - returns an accumulator that supports tracking metrics

type TrackingAccumulator

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

TrackingAccumulator will signal after a metric has been processed. It indicates if the metric was accepted, rejected, or dropped

func (*TrackingAccumulator) AddTrackingMetric

func (ta *TrackingAccumulator) AddTrackingMetric(m telegraf.Metric) telegraf.TrackingID

AddTrackingMetric - Adds a metric to track on the the tracking accumulator

func (*TrackingAccumulator) AddTrackingMetricGroup

func (ta *TrackingAccumulator) AddTrackingMetricGroup(group []telegraf.Metric) telegraf.TrackingID

AddTrackingMetricGroup - Adds a group of metrics on the tracking accumulator

func (*TrackingAccumulator) Delivered

func (ta *TrackingAccumulator) Delivered() <-chan telegraf.DeliveryInfo

Delivered -