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 + var DecoderErrors = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var DecoderProcessTime = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... }) + var DecoderStats = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var DecoderTime = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... }) + var MetricPacketSizeSum = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... }) + var MetricTrafficBytes = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var MetricTrafficPackets = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowErrors = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowSetRecordsStatsSum = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowSetStatsSum = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowStats = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowTemplatesStats = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var NetFlowTimeStatsSum = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... }) + var SFlowErrors = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var SFlowSampleRecordsStatsSum = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var SFlowSampleStatsSum = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var SFlowStats = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + func DefaultAccountCallback(name string, id int, start, end time.Time) + func FlowMessageToJSON(fmsg *flowmessage.FlowMessage) string + func FlowMessageToString(fmsg *flowmessage.FlowMessage) string + func GetServiceAddresses(srv string) (addrs []string, err error) + func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr string, ...) error + type BaseMessage struct + Payload []byte + Port int + RecvTime time.Time + SetTime bool + Src net.IP + type DefaultErrorCallback struct + Logger Logger + func (cb *DefaultErrorCallback) Callback(name string, id int, start, end time.Time, err error) + type DefaultJSONTransport struct + func (s *DefaultJSONTransport) Publish(msgs []*flowmessage.FlowMessage) + type DefaultLogTransport struct + func (s *DefaultLogTransport) Publish(msgs []*flowmessage.FlowMessage) + type Logger interface + Debug func(...interface{}) + Debugf func(string, ...interface{}) + Error func(...interface{}) + Errorf func(string, ...interface{}) + Fatalf func(string, ...interface{}) + Infof func(string, ...interface{}) + Printf func(string, ...interface{}) + Warn func(...interface{}) + Warnf func(string, ...interface{}) + type StateNFLegacy struct + Logger Logger + Transport Transport + func (s *StateNFLegacy) DecodeFlow(msg interface{}) error + func (s *StateNFLegacy) FlowRoutine(workers int, addr string, port int, reuseport bool) error + type StateNetFlow struct + Logger Logger + Transport Transport + func (s *StateNetFlow) DecodeFlow(msg interface{}) error + func (s *StateNetFlow) FlowRoutine(workers int, addr string, port int, reuseport bool) error + func (s *StateNetFlow) InitTemplates() + func (s *StateNetFlow) ServeHTTPTemplates(w http.ResponseWriter, r *http.Request) + type StateSFlow struct + Config *producer.SFlowProducerConfig + Logger Logger + Transport Transport + func (s *StateSFlow) DecodeFlow(msg interface{}) error + func (s *StateSFlow) FlowRoutine(workers int, addr string, port int, reuseport bool) error + type TemplateSystem struct + func (s *TemplateSystem) AddTemplate(version uint16, obsDomainId uint32, template interface{}) + func (s *TemplateSystem) GetTemplate(version uint16, obsDomainId uint32, templateId uint16) (interface{}, error) + type Transport interface + Publish func([]*flowmessage.FlowMessage)