flowhandler

Documentation

Index

• Constants
• type Config
• type ControlMessage
• type FlowHandler
  • func New(config Config, resultChan chan map[string]interface{}, nr newrelic.Application) *FlowHandler
  • func (s *FlowHandler) Start(controlChan chan ControlMessage) error
• type IpfixHandler
  • func NewIpfixHandler(packetChan chan IpfixPacket, resultChan chan map[string]interface{}, ...) *IpfixHandler
  • func (h *IpfixHandler) Start()
• type IpfixPacket
• type SflowHandler
  • func NewSflowHandler(packetChan chan SflowPacket, resultChan chan map[string]interface{}, ...) *SflowHandler
  • func (h *SflowHandler) Start()
• type SflowPacket

Constants

const (
	ICMPTypeDestinationUnreachable = "Destination Unreachable"
	ICMPTypeParameterProblem       = "Parameter Problem"
	ICMPTypeRedirectMessage        = "Redirect Message"
)

const SflowPacketBufferSize = 2048

Types

type Config

type Config struct {
	BindAddress    string `envconfig:"FLOW_BIND_ADDRESS"`
	Port           int    `envconfig:"FLOW_PORT"`
	SflowEventType string `envconfig:"SFLOW_EVENT_TYPE"`
	IpfixEventType string `envconfig:"IPFIX_EVENT_TYPE"`
	AsnPeerMap     map[uint32]string
}

type ControlMessage

type ControlMessage int

const (
	ControlMessageQuit  ControlMessage = iota
	ControlMessageStart ControlMessage = iota
	ControlMessageReady ControlMessage = iota
	ControlMessageDone  ControlMessage = iota
)

type FlowHandler

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

*****************************************************************************

*
* FlowHandler struct
*
*****************************************************************************

func New

func New(config Config, resultChan chan map[string]interface{}, nr newrelic.Application) *FlowHandler

*****************************************************************************

*
* Create a new FlowHandler instance
*
*****************************************************************************

func (*FlowHandler) Start

func (s *FlowHandler) Start(controlChan chan ControlMessage) error

*****************************************************************************

*
* Start the UDP server
*
*****************************************************************************

type IpfixHandler

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

*****************************************************************************

*
* IPFIXhandler object
*
*****************************************************************************

func NewIpfixHandler

func NewIpfixHandler(packetChan chan IpfixPacket, resultChan chan map[string]interface{}, eventType string, peerMap map[uint32]string, nr newrelic.Application) *IpfixHandler

*****************************************************************************

*
* Create a new IPFIXhandler instance
*
*****************************************************************************

func (*IpfixHandler) Start

func (h *IpfixHandler) Start()

*****************************************************************************

*
* Start the IPFIX processor
*
*****************************************************************************

type IpfixPacket

type IpfixPacket struct {
	AgentIP   string
	BytesRead int
	Data      []byte
}

type SflowHandler

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

*****************************************************************************

*
* SflowHandler object
*
*****************************************************************************

func NewSflowHandler

func NewSflowHandler(packetChan chan SflowPacket, resultChan chan map[string]interface{}, eventType string, nr newrelic.Application) *SflowHandler

*****************************************************************************

*
* Create a new SflowHandler instance
*
*****************************************************************************

func (*SflowHandler) Start

func (h *SflowHandler) Start()

*****************************************************************************

*
* Start the Sflow processor
*
*****************************************************************************

type SflowPacket

type SflowPacket []byte