Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

models

package

Go to main page

Versions in this module

v1

v1.2.0

Mar 24, 2017

Changes in this version

+ const DEFAULT_METRIC_BATCH_SIZE

+ const DEFAULT_METRIC_BUFFER_LIMIT

+ var GlobalMetricsGathered = selfstat.Register("agent", "metrics_gathered", map[string]string{})

+ type AggregatorConfig struct

+ Delay time.Duration

+ DropOriginal bool

+ Filter Filter

+ MeasurementPrefix string

+ MeasurementSuffix string

+ Name string

+ NameOverride string

+ Period time.Duration

+ Tags map[string]string

type Filter

+ FieldDrop []string

+ FieldPass []string

+ NameDrop []string

+ NamePass []string

+ TagExclude []string

+ TagInclude []string

+ func (f *Filter) Apply(measurement string, fields map[string]interface{}, tags map[string]string) bool

+ func (f *Filter) Compile() error

+ type ProcessorConfig struct

+ Filter Filter

+ Name string

+ Order int64

+ type RunningAggregator struct

+ Config *AggregatorConfig

+ func NewRunningAggregator(a telegraf.Aggregator, conf *AggregatorConfig) *RunningAggregator

+ func (r *RunningAggregator) Add(in telegraf.Metric) bool

+ func (r *RunningAggregator) MakeMetric(measurement string, fields map[string]interface{}, tags map[string]string, ...) telegraf.Metric

+ func (r *RunningAggregator) Name() string

+ func (r *RunningAggregator) Run(acc telegraf.Accumulator, shutdown chan struct{})

type RunningInput

+ MetricsGathered selfstat.Stat

+ func NewRunningInput(input telegraf.Input, config *InputConfig) *RunningInput

+ func (r *RunningInput) MakeMetric(measurement string, fields map[string]interface{}, tags map[string]string, ...) telegraf.Metric

+ func (r *RunningInput) SetDefaultTags(tags map[string]string)

+ func (r *RunningInput) SetTrace(trace bool)

+ func (r *RunningInput) Trace() bool

type RunningOutput

+ BufferLimit selfstat.Stat

+ BufferSize selfstat.Stat

+ MetricBatchSize int

+ MetricBufferLimit int

+ MetricsFiltered selfstat.Stat

+ MetricsWritten selfstat.Stat

+ WriteTime selfstat.Stat

+ func (ro *RunningOutput) AddMetric(m telegraf.Metric)

+ type RunningProcessor struct

+ Config *ProcessorConfig

+ Name string

+ Processor telegraf.Processor

+ func (rp *RunningProcessor) Apply(in ...telegraf.Metric) []telegraf.Metric

+ type RunningProcessors []*RunningProcessor

+ func (rp RunningProcessors) Len() int

+ func (rp RunningProcessors) Less(i, j int) bool

+ func (rp RunningProcessors) Swap(i, j int)

v0

v0.10.1

Jan 27, 2016

Changes in this version

+ const DEFAULT_POINT_BUFFER_LIMIT

+ type Filter struct

+ Drop []string

+ IsActive bool

+ Pass []string

+ TagDrop []TagFilter

+ TagPass []TagFilter

+ func (f Filter) ShouldPass(key string) bool

+ func (f Filter) ShouldPointPass(point *client.Point) bool

+ func (f Filter) ShouldTagsPass(tags map[string]string) bool

+ type InputConfig struct

+ Filter Filter

+ Interval time.Duration

+ MeasurementPrefix string

+ MeasurementSuffix string

+ Name string

+ NameOverride string

+ Tags map[string]string

+ type OutputConfig struct

+ Filter Filter

+ Name string

+ type RunningInput struct

+ Config *InputConfig

+ Input inputs.Input

+ Name string

+ type RunningOutput struct

+ Config *OutputConfig

+ Name string

+ Output outputs.Output

+ PointBufferLimit int

+ Quiet bool

+ func NewRunningOutput(name string, output outputs.Output, conf *OutputConfig) *RunningOutput

+ func (ro *RunningOutput) AddPoint(point *client.Point)

+ func (ro *RunningOutput) Write() error

+ type TagFilter struct

+ Filter []string

+ Name string