intermediate

package

v0.3.1 Latest Latest Go to latest Published: Nov 23, 2020 License: Apache-2.0 Imports: 7 Imported by: 6

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/vmware/go-ipfix

Links

Open Source Insights

Documentation ¶

Index ¶

type AggregationProcess
- func InitAggregationProcess(messageChan chan *entities.Message, workerNum int, correlateFields []string) (*AggregationProcess, error)
type FlowKey
type FlowKeyRecordMapCallBack

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AggregationProcess ¶ added in v0.3.1

type AggregationProcess struct {
	// contains filtered or unexported fields
}

func InitAggregationProcess ¶

func InitAggregationProcess(messageChan chan *entities.Message, workerNum int, correlateFields []string) (*AggregationProcess, error)

InitAggregationProcess takes in message channel (e.g. from collector) as input channel, workerNum(number of workers to process message) and correlateFields (fields to be correlated and filled).

func (*AggregationProcess) AggregateMsgByFlowKey ¶ added in v0.3.1

func (a *AggregationProcess) AggregateMsgByFlowKey(message *entities.Message) error

AggregateMsgByFlowKey gets flow key from records in message and stores in cache

func (*AggregationProcess) DeleteFlowKeyFromMap ¶ added in v0.3.1

func (a *AggregationProcess) DeleteFlowKeyFromMap(flowKey FlowKey)

func (*AggregationProcess) ForAllRecordsDo ¶ added in v0.3.1

func (a *AggregationProcess) ForAllRecordsDo(callback FlowKeyRecordMapCallBack) error

ForAllRecordsDo takes in callback function to process the operations to flowkey->records pairs in the map

func (*AggregationProcess) Start ¶ added in v0.3.1

func (a *AggregationProcess) Start()

func (*AggregationProcess) Stop ¶ added in v0.3.1

func (a *AggregationProcess) Stop()

type FlowKey ¶ added in v0.3.1

type FlowKey struct {
	SourceAddress      string
	DestinationAddress string
	Protocol           uint8
	SourcePort         uint16
	DestinationPort    uint16
}

type FlowKeyRecordMapCallBack ¶ added in v0.3.1

type FlowKeyRecordMapCallBack func(key FlowKey, records []entities.Record) error

Source Files ¶

View all Source files

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