telegraf

Documentation

Index

• func Adapt(aa accumulator.Accumulator, separator string) telegraf.Accumulator
• func MaybeInitLog(input telegraf2.Input)
• func NewInputAdapter(input telegraf.Input) api.Input
• func NewInputAdapterWithPrefix(prefix string, input telegraf.Input) api.Input
• type InputAdapter
  • func (i *InputAdapter) Collect(a api.Accumulator) error
  • func (i *InputAdapter) GetDefaultPrefix() string
• type Memory
  • func (m *Memory) AddCounter(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (m *Memory) AddError(err error)
  • func (m *Memory) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (m *Memory) AddGauge(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (m *Memory) AddHistogram(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (m *Memory) AddMetric(metric telegraf.Metric)
  • func (m *Memory) AddSummary(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (m *Memory) SetPrecision(precision time.Duration)
  • func (m *Memory) WithTracking(maxTracked int) telegraf.TrackingAccumulator
• type TelegrafAccumulatorAdapter
  • func (a *TelegrafAccumulatorAdapter) AddCounter(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *TelegrafAccumulatorAdapter) AddError(err error)
  • func (a *TelegrafAccumulatorAdapter) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *TelegrafAccumulatorAdapter) AddGauge(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *TelegrafAccumulatorAdapter) AddHistogram(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *TelegrafAccumulatorAdapter) AddMetric(metric telegraf.Metric)
  • func (a *TelegrafAccumulatorAdapter) AddSummary(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (a *TelegrafAccumulatorAdapter) SetPrecision(precision time.Duration)
  • func (a *TelegrafAccumulatorAdapter) WithTracking(maxTracked int) telegraf.TrackingAccumulator

Functions

func Adapt

func Adapt(aa accumulator.Accumulator, separator string) telegraf.Accumulator

func MaybeInitLog

func MaybeInitLog(input telegraf2.Input)

func NewInputAdapter

func NewInputAdapter(input telegraf.Input) api.Input

func NewInputAdapterWithPrefix

func NewInputAdapterWithPrefix(prefix string, input telegraf.Input) api.Input

Types

type InputAdapter

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

InputAdapter adapts telegraf.Input to api.Input

func (*InputAdapter) Collect

func (i *InputAdapter) Collect(a api.Accumulator) error

func (*InputAdapter) GetDefaultPrefix

func (i *InputAdapter) GetDefaultPrefix() string

type Memory

type Memory struct {
	Metrics []telegraf.Metric
	Errors  []error
}

func (*Memory) AddCounter

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

func (*Memory) AddError

func (m *Memory) AddError(err error)

func (*Memory) AddFields

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

func (*Memory) AddGauge

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

func (*Memory) AddHistogram

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

func (*Memory) AddMetric

func (m *Memory) AddMetric(metric telegraf.Metric)

func (*Memory) AddSummary

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

func (*Memory) SetPrecision

func (m *Memory) SetPrecision(precision time.Duration)

func (*Memory) WithTracking

func (m *Memory) WithTracking(maxTracked int) telegraf.TrackingAccumulator

type TelegrafAccumulatorAdapter

type TelegrafAccumulatorAdapter struct {
	Separator string
	AA        accumulator.Accumulator
}

func (*TelegrafAccumulatorAdapter) AddCounter

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

func (*TelegrafAccumulatorAdapter) AddError

func (a *TelegrafAccumulatorAdapter) AddError(err error)

func (*TelegrafAccumulatorAdapter) AddFields

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

func (*TelegrafAccumulatorAdapter) AddGauge

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

func (*TelegrafAccumulatorAdapter) AddHistogram

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

func (*TelegrafAccumulatorAdapter) AddMetric

func (a *TelegrafAccumulatorAdapter) AddMetric(metric telegraf.Metric)

func (*TelegrafAccumulatorAdapter) AddSummary

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

func (*TelegrafAccumulatorAdapter) SetPrecision

func (a *TelegrafAccumulatorAdapter) SetPrecision(precision time.Duration)

func (*TelegrafAccumulatorAdapter) WithTracking

func (a *TelegrafAccumulatorAdapter) WithTracking(maxTracked int) telegraf.TrackingAccumulator