intermediate

package

Go to main page

Versions in this module

v0

v0.9.0

Feb 15, 2024

v0.8.2

Dec 15, 2023

v0.8.1

Dec 7, 2023

v0.8.0

Oct 2, 2023

v0.7.0

Sep 22, 2023

v0.6.2

Jun 7, 2023

v0.6.1

May 17, 2023

v0.6.0

Jan 9, 2023

v0.5.14

Jan 6, 2023

v0.5.13

Dec 6, 2022

v0.5.12

Feb 23, 2022

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) ResetStatAndThroughputElementsInRecord(record entities.Record) error

v0.5.11

Dec 10, 2021

Changes in this version

type AggregationElements

+ AntreaFlowEndSecondsElements []string

+ DestinationThroughputElements []string

+ SourceThroughputElements []string

+ ThroughputElements []string

v0.5.10

Nov 5, 2021

v0.5.9

Oct 18, 2021

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) GetNumFlows() int64

+ func (a *AggregationProcess) GetRecords(flowKey *FlowKey) []string

v0.5.8

Sep 17, 2021

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) GetNumberOfFlows() uint64

v0.5.7

Aug 13, 2021

v0.5.6

Aug 12, 2021

v0.5.5

Jul 27, 2021

v0.5.4

Jul 7, 2021

v0.5.3

Jun 18, 2021

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) AreCorrelatedFieldsFilled(record AggregationFlowRecord) bool

+ func (a *AggregationProcess) AreExternalFieldsFilled(record AggregationFlowRecord) bool

+ func (a *AggregationProcess) IsAggregatedRecordIPv4(record AggregationFlowRecord) bool

+ func (a *AggregationProcess) IsExporterOfAggregatedRecordIPv4(record AggregationFlowRecord) bool

+ func (a *AggregationProcess) SetCorrelatedFieldsFilled(record *AggregationFlowRecord, isFilled bool)

+ func (a *AggregationProcess) SetExternalFieldsFilled(record *AggregationFlowRecord, isFilled bool)

v0.5.2

May 18, 2021

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) IsMetadataFilled(record AggregationFlowRecord) bool

+ func (a *AggregationProcess) SetMetadataFilled(record AggregationFlowRecord, isFilled bool)

v0.5.1

May 13, 2021

Changes in this version

+ var MaxRetries = 5

+ var MinExpiryTime = 100 * time.Millisecond

type AggregationFlowRecord

+ PriorityQueueItem *ItemToExpire

type AggregationInput

+ ActiveExpiryTimeout time.Duration

+ InactiveExpiryTimeout time.Duration

type AggregationProcess

+ func (a *AggregationProcess) ForAllExpiredFlowRecordsDo(callback FlowKeyRecordMapCallBack) error

+ func (a *AggregationProcess) GetExpiryFromExpirePriorityQueue() time.Duration

+ func (a *AggregationProcess) ResetStatElementsInRecord(record entities.Record) error

+ type ItemToExpire struct

+ type TimeToExpirePriorityQueue []*ItemToExpire

+ func (pq *TimeToExpirePriorityQueue) Pop() interface{}

+ func (pq *TimeToExpirePriorityQueue) Push(x interface{})

+ func (pq *TimeToExpirePriorityQueue) Update(item *ItemToExpire, flowKey *FlowKey, flowRecord *AggregationFlowRecord, ...)

+ func (pq TimeToExpirePriorityQueue) Len() int

+ func (pq TimeToExpirePriorityQueue) Less(i, j int) bool

+ func (pq TimeToExpirePriorityQueue) Peek() *ItemToExpire

+ func (pq TimeToExpirePriorityQueue) Swap(i, j int)

v0.5.0

Apr 19, 2021

v0.4.8

Mar 19, 2021

v0.4.7

Mar 15, 2021

v0.4.6

Feb 25, 2021

v0.4.5

Feb 17, 2021

v0.4.4

Feb 11, 2021

v0.4.3

Feb 5, 2021

v0.4.2

Dec 15, 2020

v0.4.1

Dec 9, 2020

Changes in this version

type AggregationElements

+ AggregatedDestinationStatsElements []string

+ AggregatedSourceStatsElements []string

+ NonStatsElements []string

+ StatsElements []string

v0.4.0

Dec 8, 2020

Changes in this version

+ type AggregationElements struct

+ type AggregationFlowRecord struct

+ IsActive bool

+ ReadyToSend bool

+ Record entities.Record

+ type AggregationInput struct

+ AggregateElements *AggregationElements

+ CorrelateFields []string

+ MessageChan chan *entities.Message

+ WorkerNum int

v0.3.2

Dec 14, 2020

Changes in this version

type AggregationProcess

+ func (a *AggregationProcess) DeleteFlowKeyFromMapWithLock(flowKey FlowKey)

+ func (a *AggregationProcess) DeleteFlowKeyFromMapWithoutLock(flowKey FlowKey)

v0.3.1

Nov 23, 2020

Changes in this version

+ type AggregationProcess struct

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

+ func (a *AggregationProcess) DeleteFlowKeyFromMap(flowKey FlowKey)

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

+ func (a *AggregationProcess) Start()

+ func (a *AggregationProcess) Stop()

+ type FlowKey struct

+ DestinationAddress string

+ DestinationPort uint16

+ Protocol uint8

+ SourceAddress string

+ SourcePort uint16

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

v0.3.0

Nov 9, 2020

Changes in this version

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

+ type Tuple struct

+ DestinationAddress string

+ DestinationPort uint16

+ Protocol uint8

+ SourceAddress string

+ SourcePort uint16

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