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(setType ipfixentities.ContentType, templateID uint16, isDecoding bool) *ipfixSet
- type IPFIXAggregationProcess
- type IPFIXCollectingProcess
- type IPFIXExportingProcess
- type IPFIXRegistry
- type IPFIXSet
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
func NewSet ¶
func NewSet(setType ipfixentities.ContentType, templateID uint16, 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 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.
type IPFIXSet ¶
type IPFIXSet interface { AddRecord(elements []*ipfixentities.InfoElementWithValue, templateID uint16) error GetSet() ipfixentities.Set }
IPFIXSet interface is added to facilitate unit testing without involving the code from go-ipfix library.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.