flowfilter

Documentation

Overview

Runs flows through a filter and forwards only matching flows. Reuses our own https://github.com/bwNetFlow/flowfilter project, see the docs there.

Index

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

Types

type FlowFilter

type FlowFilter struct {
	segments.BaseFilterSegment
	Filter string // optional, default is empty
	// contains filtered or unexported fields
}

FIXME: the flowfilter project needs to be updated to new protobuf too

func (FlowFilter) New

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

func (*FlowFilter) Run

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