sfserver

Documentation

Overview

Package sfserver provides sflow collection services via UDP and passes flows into annotator layer

Index

• func Dump(fl *netflow.Flow)
• type SflowServer
  • func New(numReaders int, config *config.Config, ...) *SflowServer
  • func (sfs *SflowServer) Close()

Functions

func Dump

func Dump(fl *netflow.Flow)

Dump dumps a flow on the screen

Types

type SflowServer

type SflowServer struct {
	// Output is the channel used to send flows to the annotator layer
	Output chan *netflow.Flow
	// contains filtered or unexported fields
}

SflowServer represents a sflow Collector instance

func New

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

New creates and starts a new `SflowServer` instance

func (*SflowServer) Close

func (sfs *SflowServer) Close()

Close closes the socket and stops the workers