influx

Documentation

Overview

Collects and exports all flows to influxdb for long term storage. Tags to configure for Influxdb are from the protobuf definition. Supported Tags are: Cid,ProtoName,RemoteCountry,SamplerAddress,SrcIfDesc,DstIfDesc If no Tags are provided 'ProtoName' will be the only Tag used by default.

Index

• type Connector
  • func (c *Connector) CreatePoint(flow *flow.FlowMessage) *write.Point
  • func (c *Connector) Initialize()
• type Influx
  • func (segment Influx) New(config map[string]string) segments.Segment
  • func (segment *Influx) Run(wg *sync.WaitGroup)

Types

type Connector

type Connector struct {
	Address    string
	Org        string
	Bucket     string
	Token      string
	ExportFreq int
	Batchsize  int
	// contains filtered or unexported fields
}

Connector provides export features to Influx

func (*Connector) CreatePoint

func (c *Connector) CreatePoint(flow *flow.FlowMessage) *write.Point

func (*Connector) Initialize

func (c *Connector) Initialize()

Initialize a connection to Influxdb

type Influx

type Influx struct {
	segments.BaseSegment
	Address string   // URL for influxdb endpoint
	Org     string   // influx org name
	Bucket  string   // influx bucket
	Token   string   // influx access token
	Tags    []string // optional, list of Tags to be created. Recommended to keep this to a

}

func (Influx) New

func (segment Influx) New(config map[string]string) segments.Segment

func (*Influx) Run

func (segment *Influx) Run(wg *sync.WaitGroup)