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
• type IPFIXAggregationProcess
• type IPFIXCollectingProcess
• type IPFIXExportingProcess
• type IPFIXRegistry

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

Types

type IPFIXAggregationProcess

type IPFIXAggregationProcess interface {
	Start()
	Stop()
	ForAllExpiredFlowRecordsDo(callback ipfixintermediate.FlowKeyRecordMapCallBack) error
	GetExpiryFromExpirePriorityQueue() time.Duration
	GetRecords(flowKey *ipfixintermediate.FlowKey) []map[string]interface{}
	ResetStatElementsInRecord(record ipfixentities.Record) error
	SetCorrelatedFieldsFilled(record *ipfixintermediate.AggregationFlowRecord)
	AreCorrelatedFieldsFilled(record ipfixintermediate.AggregationFlowRecord) bool
	IsAggregatedRecordIPv4(record ipfixintermediate.AggregationFlowRecord) bool
	SetExternalFieldsFilled(record *ipfixintermediate.AggregationFlowRecord)
	AreExternalFieldsFilled(record ipfixintermediate.AggregationFlowRecord) bool
	GetNumFlows() int64
}

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
	GetNumRecordsReceived() int64
	GetNumConnToCollector() int64
}

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 ipfixentities.Set) (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.