qhandler_influxdb

README

handler-influxdb

InfluxDB handler for the qframe framework

Documentation

Index

• type Plugin
  • func New(qChan qtypes.QChan, cfg *config.Config, name string) (Plugin, error)
  • func (p *Plugin) Connect()
  • func (p *Plugin) MetricsToBatchPoint(m qtypes.Metric) (pt *client.Point, err error)
  • func (p *Plugin) NewBatchPoints() client.BatchPoints
  • func (p *Plugin) Run()
  • func (p *Plugin) WriteBatch(points client.BatchPoints) client.BatchPoints

Types

type Plugin

type Plugin struct {
	qtypes.Plugin

	SanitizeLabels bool
	// contains filtered or unexported fields
}

func New

func New(qChan qtypes.QChan, cfg *config.Config, name string) (Plugin, error)

func (*Plugin) Connect

func (p *Plugin) Connect()

Connect creates a connection to InfluxDB

func (*Plugin) MetricsToBatchPoint

func (p *Plugin) MetricsToBatchPoint(m qtypes.Metric) (pt *client.Point, err error)

func (*Plugin) NewBatchPoints

func (p *Plugin) NewBatchPoints() client.BatchPoints

func (*Plugin) Run

func (p *Plugin) Run()

Run fetches everything from the Data channel and flushes it to stdout

func (*Plugin) WriteBatch

func (p *Plugin) WriteBatch(points client.BatchPoints) client.BatchPoints