influxdb

README

InfluxDB Plugin

The InfluxDB plugin sends flushed metrics to InfluxDB.

This plugin is still in an experimental state.

Configuration

This plugin can be enabled using the following configuration:

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

Documentation

Index

• type InfluxDBPlugin
  • func NewInfluxDBPlugin(logger *logrus.Logger, addr string, consistency string, db string, ...) *InfluxDBPlugin
  • func (p *InfluxDBPlugin) Flush(ctx context.Context, metrics []samplers.InterMetric) error
  • func (p *InfluxDBPlugin) Name() string

Types

type InfluxDBPlugin

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

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 (*InfluxDBPlugin) Flush

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

Flush sends a slice of metrics to InfluxDB

func (*InfluxDBPlugin) Name

func (p *InfluxDBPlugin) Name() string

Name returns the name of the plugin.