nfserver

Documentation

Overview

Package nfserver provides netflow collection services via UDP and passes flows into annotator layer

Index

• func Dump(fl *netflow.Flow)
• func DumpTemplate(tmpl *nf9.TemplateRecords)
• type NetflowServer
  • func New(numReaders int, config *config.Config, ...) *NetflowServer
  • func (nfs *NetflowServer) Close()

Functions

func Dump

func Dump(fl *netflow.Flow)

Dump dumps a flow on the screen

func DumpTemplate

func DumpTemplate(tmpl *nf9.TemplateRecords)

DumpTemplate dumps a template on the screen

Types

type NetflowServer

type NetflowServer struct {

	// receiver is the channel used to receive flows from the annotator layer
	Output chan *netflow.Flow
	// contains filtered or unexported fields
}

NetflowServer represents a Netflow Collector instance

func New

func New(numReaders int, config *config.Config, sampleRateCache *srcache.SamplerateCache) *NetflowServer

New creates and starts a new `NetflowServer` instance

func (*NetflowServer) Close

func (nfs *NetflowServer) Close()

Close closes the socket and stops the workers