telegraf

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