influxdb

Documentation

Index

• func New(uri string, options map[string][]string) (api.Sink, error)
• type InfluxdbSink
  • func (k *InfluxdbSink) Start(wg *sync.WaitGroup) chan interface{}

Functions

func New

func New(uri string, options map[string][]string) (api.Sink, error)

Types

type InfluxdbSink

type InfluxdbSink struct {
}

func (*InfluxdbSink) Start

func (k *InfluxdbSink) Start(wg *sync.WaitGroup) chan interface{}