frontends

package

v0.0.0-...-3b9963d Latest Latest Go to latest Published: Mar 26, 2020 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/MatthewJSalerno/goflow

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 ¶

View Source

const FLOWS = fields.FLOWS

View Source

const IN_BYTES = fields.IN_BYTES

CONSTANTS Actual fields...

View Source

const IN_PKTS = fields.IN_PKTS

View Source

const IPV4_DST_ADDR = fields.IPV4_DST_ADDR

View Source

const IPV4_NEXT_HOP = fields.IPV4_NEXT_HOP

View Source

const IPV4_SRC_ADDR = fields.IPV4_SRC_ADDR

View Source

const L4_DST_PORT = fields.L4_DST_PORT

View Source

const L4_SRC_PORT = fields.L4_SRC_PORT

View Source

const LAST_SWITCHED = fields.LAST_SWITCHED

View Source

const OUT_BYTES = fields.OUT_BYTES

View Source

const OUT_PKTS = fields.OUT_PKTS

View Source

const PROTOCOL = fields.PROTOCOL

View Source

const SRC_MASK = fields.SRC_MASK

View Source

const TCP_FLAGS = fields.TCP_FLAGS

View Source

const TOS = fields.TOS

Variables ¶

View Source

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()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL