telegraf

Documentation

Index

• func AddConfig(name string, config map[string]interface{})
• func AddTags(name string, tags []string)
• func AddUsage(name, usage string)
• func GetConfigByName(name string) map[string]interface{}
• func GetTagsByName(name string) []string
• func GetUsageByName(name string) string
• type Accumulator
  • func (acc *Accumulator) AddCounter(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (acc *Accumulator) AddError(err error)
  • func (acc *Accumulator) AddFields(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (acc *Accumulator) AddGauge(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (acc *Accumulator) AddHistogram(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (acc *Accumulator) AddMetric(telegraf.Metric)
  • func (acc *Accumulator) AddSummary(measurement string, fields map[string]interface{}, tags map[string]string, ...)
  • func (_ *Accumulator) SetPrecision(precision time.Duration)
  • func (acc *Accumulator) WithTracking(maxTracked int) telegraf.TrackingAccumulator
• type Collector
  • func NewCollector(name string, input telegraf.Input) *Collector
  • func (c *Collector) Collect() ([]map[string]interface{}, error)
  • func (c *Collector) Config() map[string]interface{}
  • func (c *Collector) Name() string
  • func (c *Collector) Tags() []string
  • func (c *Collector) Usages() string

Functions

func AddConfig

func AddConfig(name string, config map[string]interface{})

AddConfig adds config information to data table.

func AddTags

func AddTags(name string, tags []string)

AddTags adds tags information to data table.

func AddUsage

func AddUsage(name, usage string)

AddUsage adds usage information to data table.

func GetConfigByName

func GetConfigByName(name string) map[string]interface{}

GetConfigByName returns config information specific to logkit.

func GetTagsByName

func GetTagsByName(name string) []string

GetTagsByName returns tags information specific to logkit.

func GetUsageByName

func GetUsageByName(name string) string

GetUsageByName returns usage information specific to logkit.

Types

type Accumulator

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

Accumulator implements telegraf.Accumulator.

func (*Accumulator) AddCounter

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

func (*Accumulator) AddError

func (acc *Accumulator) AddError(err error)

func (*Accumulator) AddFields

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

func (*Accumulator) AddGauge

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

func (*Accumulator) AddHistogram

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

func (*Accumulator) AddMetric

func (acc *Accumulator) AddMetric(telegraf.Metric)

mock AddMetric. Implement when needed

func (*Accumulator) AddSummary

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

func (*Accumulator) SetPrecision

func (_ *Accumulator) SetPrecision(precision time.Duration)

func (*Accumulator) WithTracking

func (acc *Accumulator) WithTracking(maxTracked int) telegraf.TrackingAccumulator

mock WithTracking. Implement when needed

type Collector

type Collector struct {
	telegraf.Input
	// contains filtered or unexported fields
}

Collector converts inputs.Input to logkit format and implements metric.Collector.

func NewCollector

func NewCollector(name string, input telegraf.Input) *Collector

NewCollector creates new general collector.

func (*Collector) Collect

func (c *Collector) Collect() ([]map[string]interface{}, error)

func (*Collector) Config

func (c *Collector) Config() map[string]interface{}

func (*Collector) Name

func (c *Collector) Name() string

func (*Collector) Tags

func (c *Collector) Tags() []string

func (*Collector) Usages

func (c *Collector) Usages() string