frontends

Documentation

Index

• Constants
• Variables
• func Route(nfp netflowPacket, p []byte, start uint16) netflowPacket
• type Frontend
• type Netflow
  • func (n *Netflow) Configure(config map[string]string, b backends.Backend)
  • func (nf Netflow) Start()

Constants

const FLOWS = fields.FLOWS

const IN_BYTES = fields.IN_BYTES

CONSTANTS Actual fields...

const IN_PKTS = fields.IN_PKTS

const IPV4_DST_ADDR = fields.IPV4_DST_ADDR

const IPV4_NEXT_HOP = fields.IPV4_NEXT_HOP

const IPV4_SRC_ADDR = fields.IPV4_SRC_ADDR

const L4_DST_PORT = fields.L4_DST_PORT

const L4_SRC_PORT = fields.L4_SRC_PORT

const LAST_SWITCHED = fields.LAST_SWITCHED

const OUT_BYTES = fields.OUT_BYTES

const OUT_PKTS = fields.OUT_PKTS

const PROTOCOL = fields.PROTOCOL

const SRC_MASK = fields.SRC_MASK

const TCP_FLAGS = fields.TCP_FLAGS

const TOS = fields.TOS

Variables

var FUNCTIONMAP = map[uint16]func([]byte) fields.Value{
	IN_BYTES:             fields.GetInt,
	IN_PKTS:              fields.GetInt,
	PROTOCOL:             fields.GetInt,
	L4_SRC_PORT:          fields.GetInt,
	IPV4_SRC_ADDR:        fields.GetAddr,
	IPV4_DST_ADDR:        fields.GetAddr,
	OUT_BYTES:            fields.GetInt,
	OUT_PKTS:             fields.GetInt,
	L4_DST_PORT:          fields.GetInt,
	LAST_SWITCHED:        fields.GetInt,
	fields.IPV6_SRC_ADDR: fields.GetAddr6,
	fields.IPV6_DST_ADDR: fields.GetAddr6,
}

Functions

func Route

func Route(nfp netflowPacket, p []byte, start uint16) netflowPacket

Route Takes an entire packet slice, and routes each flowset to the correct handler

Requires

netflowPacket : netflowpacket struct
[]byte		  : Packet bytes
uint16		  : Byte index to start at (skip the headers, etc)

Types

type Frontend

type Frontend interface {
	Start()
	Configure(config map[string]string, backend backends.Backend)
}

Frontends are inbound interfaces for data

type Netflow

type Netflow struct {
	// Hey! Have you got any of those maps left?!?!
	// Uuuh yeah, a couple
	// map[SOURCE IP][SOURCE ID][TEMPLATE ID]
	Templates map[uint32]map[uint32]map[uint16]netflowPacketTemplate
	BindAddr  net.IP
	BindPort  int
	// contains filtered or unexported fields
}

GENERICS

Netflow listener and main object

func (*Netflow) Configure

func (n *Netflow) Configure(config map[string]string, b backends.Backend)

func (Netflow) Start

func (nf Netflow) Start()