influxdb

package

v1.7.0 Latest Latest Go to latest Published: Oct 19, 2017 License: MIT Imports: 14 Imported by: 0

Details

The InfluxDB plugin sends flushed metrics to InfluxDB.

This plugin is still in an experimental state.

This plugin can be enabled using the following configuration:

influx_address: http://localhost:8086
influx_consistency: one
influx_db_name: mydb

This section is empty.

This section is empty.

This section is empty.

type InfluxDBPlugin struct {
	Logger     *logrus.Logger
	InfluxURL  string
	HTTPClient *http.Client
	Statsd     *statsd.Client
}

InfluxDBPlugin is a plugin for emitting metrics to InfluxDB.

func NewInfluxDBPlugin(logger *logrus.Logger, addr string, consistency string, db string, client *http.Client, stats *statsd.Client) *InfluxDBPlugin

NewInfluxDBPlugin creates a new Influx Plugin.

func (p *InfluxDBPlugin) Flush(ctx context.Context, metrics []samplers.InterMetric) error

Flush sends a slice of metrics to InfluxDB

func (p *InfluxDBPlugin) Name() string

Name returns the name of the plugin.