Documentation
¶
Index ¶
- type 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
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) 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 -
Source Files