telegraf

Mar 24, 2017

Changes in this version

type Accumulator

+ AddCounter func(measurement string, fields map[string]interface{}, tags map[string]string, ...)

+ AddError func(err error)

+ AddGauge func(measurement string, fields map[string]interface{}, tags map[string]string, ...)

+ SetPrecision func(precision, interval time.Duration)

+ type Aggregator interface

+ Add func(in Metric)

+ Description func() string

+ Push func(acc Accumulator)

+ Reset func()

+ SampleConfig func() string

+ type Input interface

+ Description func() string

+ Gather func(Accumulator) error

+ SampleConfig func() string

+ type Metric interface

+ AddField func(key string, value interface{})

+ AddTag func(key, value string)

+ Copy func() Metric

+ Fields func() map[string]interface{}

+ HasField func(key string) bool

+ HasTag func(key string) bool

+ HashID func() uint64

+ IsAggregate func() bool

+ Len func() int

+ Name func() string

+ Point func() *client.Point

+ RemoveField func(key string) error

+ RemoveTag func(key string)

+ Serialize func() []byte

+ SetAggregate func(bool)

+ SetName func(name string)

+ SetPrefix func(prefix string)

+ SetSuffix func(suffix string)

+ Split func(maxSize int) []Metric

+ String func() string

+ Tags func() map[string]string

+ Time func() time.Time

+ Type func() ValueType

+ UnixNano func() int64

+ type Output interface

+ Close func() error

+ Connect func() error

+ Description func() string

+ SampleConfig func() string

+ Write func(metrics []Metric) error

+ type Processor interface

+ Apply func(in ...Metric) []Metric

+ Description func() string

+ SampleConfig func() string

+ type ServiceInput interface

+ Description func() string

+ Gather func(Accumulator) error

+ SampleConfig func() string

+ Start func(Accumulator) error

+ Stop func()

+ type ServiceOutput interface

+ Close func() error

+ Connect func() error

+ Description func() string

+ SampleConfig func() string

+ Start func() error

+ Stop func()

+ Write func(metrics []Metric) error

+ type ValueType int

+ const Counter

+ const Gauge

+ const Untyped

Nov 18, 2015

Changes in this version

type Config

+ func (c *Config) GetPluginConfig(name string) *ConfiguredPlugin

Oct 27, 2015

Changes in this version

+ func PrintOutputConfig(name string) error

+ type Accumulator interface

+ Add func(measurement string, value interface{}, tags map[string]string, t ...time.Time)

+ AddDefaultTag func(key, value string)

+ AddFields func(measurement string, fields map[string]interface{}, tags map[string]string, ...)

+ Debug func() bool

+ Prefix func() string

+ SetDebug func(enabled bool)

+ SetDefaultTags func(tags map[string]string)

+ SetPrefix func(prefix string)

+ func NewAccumulator(plugin *ConfiguredPlugin, points chan *client.Point) Accumulator

type Agent

+ FlushInterval duration.Duration

+ FlushJitter duration.Duration

+ FlushRetries int

+ RoundInterval bool

+ Tags map[string]string

type Config

+ func (c *Config) LoadDirectory(path string) error

Sep 22, 2015

Changes in this version

type BatchPoints

+ func (bp *BatchPoints) AddFields(measurement string, fields map[string]interface{}, tags map[string]string)

+ func (bp *BatchPoints) AddFieldsWithTime(measurement string, fields map[string]interface{}, tags map[string]string, ...)

Sep 4, 2015

Changes in this version

type Agent

+ Precision string

+ UTC bool

Aug 27, 2015

Changes in this version

+ func PrintPluginConfig(name string) error

Aug 18, 2015

Changes in this version

type Agent

+ func (a *Agent) Close() error

+ func (a *Agent) LoadOutputs() ([]string, error)

type Config

+ func (c *Config) ApplyOutput(name string, v interface{}) error

+ func (c *Config) Outputs() map[string]*ast.Table

+ func (c *Config) OutputsDeclared() []string

type ConfiguredPlugin

+ TagDrop []TagFilter

+ TagPass []TagFilter

+ type TagFilter struct

+ Filter []string

+ Name string

Jun 18, 2015

Changes in this version

+ var ErrInvalidConfig = errors.New("invalid configuration")

+ func PrintSampleConfig()

+ type Agent struct

+ Config *Config

+ Debug bool

+ Hostname string

+ Interval Duration

+ func NewAgent(config *Config) (*Agent, error)

+ func (a *Agent) LoadPlugins() ([]string, error)

+ func (a *Agent) Run(shutdown chan struct{}) error

+ func (a *Agent) Test() error

+ func (a *Agent) TestAllPlugins() error

+ func (agent *Agent) Connect() error

+ type BatchPoints struct

+ Config *ConfiguredPlugin

+ Debug bool

+ Prefix string

+ func (bp *BatchPoints) Add(measurement string, val interface{}, tags map[string]string)

+ func (bp *BatchPoints) AddValuesWithTime(measurement string, values map[string]interface{}, tags map[string]string, ...)

+ type Config struct

+ Database string

+ Password string

+ Tags map[string]string

+ URL string

+ UserAgent string

+ Username string

+ func DefaultConfig() *Config

+ func LoadConfig(path string) (*Config, error)

+ func (c *Config) ApplyAgent(v interface{}) error

+ func (c *Config) ApplyPlugin(name string, v interface{}) (*ConfiguredPlugin, error)

+ func (c *Config) ListTags() string

+ func (c *Config) Plugins() map[string]*ast.Table

+ func (c *Config) PluginsDeclared() []string

+ type ConfiguredPlugin struct

+ Drop []string

+ Interval time.Duration

+ Name string

+ Pass []string

+ func (cp *ConfiguredPlugin) ShouldPass(measurement string) bool

+ type Duration struct

+ func (d *Duration) UnmarshalTOML(b []byte) error