Versions in this module Expand all Collapse all v3 v3.4.4 Jun 18, 2020 v3.4.3 Jun 18, 2020 Changes in this version + func ConvertNetFlowDataSet(version uint16, baseTime uint32, uptime uint32, record []netflow.DataField) *flowmessage.FlowMessage + func ConvertNetFlowLegacyRecord(baseTime uint32, uptime uint32, record netflowlegacy.RecordsNetFlowV5) *flowmessage.FlowMessage + func DecodeUNumber(b []byte, out interface{}) error + func EnrichWithAsn(fmsg *flowmessage.FlowMessage, config *SFlowProducerConfig) + func GetSFlowFlowSamples(packet *sflow.Packet) []interface + func NetFlowLookFor(dataFields []netflow.DataField, typeId uint16) (bool, interface{}) + func NetFlowPopulate(dataFields []netflow.DataField, typeId uint16, addr interface{}) bool + func ParseSampledHeader(flowMessage *flowmessage.FlowMessage, sampledHeader *sflow.SampledHeader) error + func ParseSampledHeaderConfig(flowMessage *flowmessage.FlowMessage, sampledHeader *sflow.SampledHeader, ...) error + func ProcessMessageNetFlow(msgDec interface{}, samplingRateSys SamplingRateSystem) ([]*flowmessage.FlowMessage, error) + func ProcessMessageNetFlowLegacy(msgDec interface{}) ([]*flowmessage.FlowMessage, error) + func ProcessMessageSFlow(msgDec interface{}) ([]*flowmessage.FlowMessage, error) + func ProcessMessageSFlowConfig(msgDec interface{}, config *SFlowProducerConfig) ([]*flowmessage.FlowMessage, error) + func SearchNetFlowDataSets(version uint16, baseTime uint32, uptime uint32, ...) []*flowmessage.FlowMessage + func SearchNetFlowDataSetsRecords(version uint16, baseTime uint32, uptime uint32, ...) []*flowmessage.FlowMessage + func SearchNetFlowLegacyRecords(baseTime uint32, uptime uint32, dataRecords []netflowlegacy.RecordsNetFlowV5) []*flowmessage.FlowMessage + func SearchNetFlowOptionDataSets(dataFlowSet []netflow.OptionsDataFlowSet) (uint32, bool) + func SearchSFlowSamples(samples []interface{}) []*flowmessage.FlowMessage + func SearchSFlowSamplesConfig(samples []interface{}, config *SFlowProducerConfig) []*flowmessage.FlowMessage + func SplitIPFIXSets(packetIPFIX netflow.IPFIXPacket) ([]netflow.DataFlowSet, []netflow.TemplateFlowSet, ...) + func SplitNetFlowSets(packetNFv9 netflow.NFv9Packet) ([]netflow.DataFlowSet, []netflow.TemplateFlowSet, ...) + type SFlowProducerConfig struct + DecodeGRE bool + EnrichWithASN bool + GeoIpAsnMapper geoip2.Reader + type SamplingRateSystem interface + AddSamplingRate func(version uint16, obsDomainId uint32, samplingRate uint32) + GetSamplingRate func(version uint16, obsDomainId uint32) (uint32, error) + func CreateSamplingSystem() SamplingRateSystem + type SingleSamplingRateSystem struct + Sampling uint32 + func (s *SingleSamplingRateSystem) AddSamplingRate(version uint16, obsDomainId uint32, samplingRate uint32) + func (s *SingleSamplingRateSystem) GetSamplingRate(version uint16, obsDomainId uint32) (uint32, error) Other modules containing this package github.com/Scorcher/goflow
Go to main page