goflow

Documentation

Overview

Captures Netflow v9 and feeds flows to the following segments. Currently, this segment only uses a limited subset of goflow2 functionality. If no configuration option is provided a sflow and a netflow collector will be started. netflowLagcy is also built in but currently not tested.

Index

• type Goflow
  • func (segment Goflow) New(config map[string]string) segments.Segment
  • func (segment *Goflow) Run(wg *sync.WaitGroup)

Types

type Goflow

type Goflow struct {
	segments.BaseSegment
	Listen  []url.URL // optional, default config value for this slice is "sflow://:6343,netflow://:2055"
	Workers uint64    // optional, amunt of workers to spawn for each endpoint, default is 1
	// contains filtered or unexported fields
}

func (Goflow) New

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

func (*Goflow) Run

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