sflow

Documentation

Overview

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

Index

• func Dump(fl *flow.Flow)
• type InterfaceResolver
• type SflowServer
  • func New(listen string, numReaders int, output chan []*flow.Flow, ...) (*SflowServer, error)
  • func (sfs *SflowServer) Stop()

Functions

func Dump

func Dump(fl *flow.Flow)

Dump dumps a flow on the screen

Types

type InterfaceResolver

type InterfaceResolver interface {
	Resolve(agent bnet.IP, ifID uint32) string
}

type SflowServer

type SflowServer struct {
	// contains filtered or unexported fields
}

SflowServer represents a sflow Collector instance

func New

func New(listen string, numReaders int, output chan []*flow.Flow, ifResolver InterfaceResolver) (*SflowServer, error)

New creates and starts a new `SflowServer` instance

func (*SflowServer) Stop

func (sfs *SflowServer) Stop()

Stop closes the socket and stops the workers