flowrecords

Documentation

Index

• type FlowRecords
  • func NewFlowRecords(connStore *connections.ConnectionStore) *FlowRecords
  • func (fr *FlowRecords) BuildFlowRecords() error
  • func (fr *FlowRecords) ForAllFlowRecordsDo(callback flowexporter.FlowRecordCallBack) error
  • func (fr *FlowRecords) GetFlowRecordByConnKey(connKey flowexporter.ConnectionKey) (*flowexporter.FlowRecord, bool)
  • func (fr *FlowRecords) ValidateAndUpdateStats(connKey flowexporter.ConnectionKey, record flowexporter.FlowRecord) error

Types

type FlowRecords

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

func NewFlowRecords

func NewFlowRecords(connStore *connections.ConnectionStore) *FlowRecords

func (*FlowRecords) BuildFlowRecords

func (fr *FlowRecords) BuildFlowRecords() error

BuildFlowRecords builds the flow record map from connection map in connection store

func (*FlowRecords) ForAllFlowRecordsDo

func (fr *FlowRecords) ForAllFlowRecordsDo(callback flowexporter.FlowRecordCallBack) error

ForAllFlowRecordsDo executes the callback for all records in the flow record map

func (*FlowRecords) GetFlowRecordByConnKey

func (fr *FlowRecords) GetFlowRecordByConnKey(connKey flowexporter.ConnectionKey) (*flowexporter.FlowRecord, bool)

GetFlowRecordByConnKey gets the record from the flow record map given the connection key

func (*FlowRecords) ValidateAndUpdateStats

func (fr *FlowRecords) ValidateAndUpdateStats(connKey flowexporter.ConnectionKey, record flowexporter.FlowRecord) error

ValidateAndUpdateStats validates and updates the flow record given the connection key