ipfix

package
Version: v1.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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{}
	ResetStatAndThroughputElementsInRecord(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.

Directories

Path Synopsis
Package testing is a generated GoMock package.
Package testing is a generated GoMock package.

Jump to

Keyboard shortcuts

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