ipfix

Documentation

Index

• func NewIPFIXAggregationProcess(input ipfixintermediate.AggregationInput) (*ipfixAggregationProcess, error)
• func NewIPFIXCollectingProcess(input ipfixcollect.CollectorInput) (*ipfixCollectingProcess, error)
• func NewIPFIXExportingProcess(input ipfixexport.ExporterInput) (*ipfixExportingProcess, error)
• func NewIPFIXRegistry() *ipfixRegistry
• func NewSet(isDecoding bool) *ipfixSet
• type IPFIXAggregationProcess
• type IPFIXCollectingProcess
• type IPFIXExportingProcess
• type IPFIXRegistry
• type IPFIXSet

Functions

func NewIPFIXAggregationProcess

func NewIPFIXAggregationProcess(input ipfixintermediate.AggregationInput) (*ipfixAggregationProcess, error)

func NewIPFIXCollectingProcess

func NewIPFIXCollectingProcess(input ipfixcollect.CollectorInput) (*ipfixCollectingProcess, error)

func NewIPFIXExportingProcess

func NewIPFIXExportingProcess(input ipfixexport.ExporterInput) (*ipfixExportingProcess, error)

func NewIPFIXRegistry

func NewIPFIXRegistry() *ipfixRegistry

func NewSet

func NewSet(isDecoding bool) *ipfixSet

Types

type IPFIXAggregationProcess

type IPFIXAggregationProcess interface {
	Start()
	Stop()
	ForAllRecordsDo(callback ipfixintermediate.FlowKeyRecordMapCallBack) error
	DeleteFlowKeyFromMapWithoutLock(flowKey ipfixintermediate.FlowKey)
}

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

type IPFIXCollectingProcess

type IPFIXCollectingProcess interface {
	Start()
	Stop()
	GetMsgChan() chan *ipfixentities.Message
}

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

type IPFIXExportingProcess

type IPFIXExportingProcess interface {
	NewTemplateID() uint16
	SendSet(set IPFIXSet) (int, error)
	CloseConnToCollector()
}

IPFIXExportingProcess 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.

type IPFIXSet

type IPFIXSet interface {
	PrepareSet(setType ipfixentities.ContentType, templateID uint16) error
	AddRecord(elements []*ipfixentities.InfoElementWithValue, templateID uint16) error
	GetSet() ipfixentities.Set
	ResetSet()
}

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