ipfix

Documentation

Index

• func NewIPFIXDataRecord(tempID uint16) *ipfixDataRecord
• func NewIPFIXExportingProcess(collector net.Addr, obsID uint32, tempRefTimeout uint32) (*ipfixExportingProcess, error)
• func NewIPFIXRegistry() *ipfixRegistry
• func NewIPFIXTemplateRecord(elementCount uint16, tempID uint16) *ipfixTemplateRecord
• type IPFIXExportingProcess
• type IPFIXRecord
• type IPFIXRegistry

Functions

func NewIPFIXDataRecord

func NewIPFIXDataRecord(tempID uint16) *ipfixDataRecord

func NewIPFIXExportingProcess

func NewIPFIXExportingProcess(collector net.Addr, obsID uint32, tempRefTimeout uint32) (*ipfixExportingProcess, error)

func NewIPFIXRegistry

func NewIPFIXRegistry() *ipfixRegistry

func NewIPFIXTemplateRecord

func NewIPFIXTemplateRecord(elementCount uint16, tempID uint16) *ipfixTemplateRecord

Types

type IPFIXExportingProcess

type IPFIXExportingProcess interface {
	NewTemplateID() uint16
	AddRecordAndSendMsg(setType ipfixentities.ContentType, record ipfixentities.Record) (int, error)
	CloseConnToCollector()
}

IPFIXExportingProcess interface is added to facilitate unit testing without involving the code from go-ipfix library.

type IPFIXRecord

type IPFIXRecord interface {
	GetRecord() ipfixentities.Record
	PrepareRecord() (uint16, error)
	AddInfoElement(element *ipfixentities.InfoElement, val interface{}) (uint16, error)
	GetBuffer() *bytes.Buffer
	GetTemplateElements() []*ipfixentities.InfoElement
	GetFieldCount() uint16
}

IPFIXRecord interface is added to facilitate unit testing without involving the code from go-ipfix library.

type IPFIXRegistry

type IPFIXRegistry interface {
	LoadRegistry()
	GetInfoElement(name string, enterpriseID uint32) (*ipfixentities.InfoElement, error)
}

IPFIXRegistry interface is added to facilitate unit testing without involving the code from go-ipfix library.