utils

Apr 16, 2023

Changes in this version

type StateNFLegacy

+ func NewStateNFLegacy() *StateNFLegacy

type StateNetFlow

+ TemplateSystem templates.TemplateInterface

+ func NewStateNetFlow() *StateNetFlow

type StateSFlow

+ func NewStateSFlow() *StateSFlow

Mar 14, 2022

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 ErrAlreadyStarted = errors.New("the routine is already started")

+ 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 GetServiceAddresses(srv string) (addrs []string, err error)

+ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr string, ...) error

+ func UDPStoppableRoutine(stopCh <-chan struct{}, name string, decodeFunc decoder.DecoderFunc, ...) 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 Formatter interface

+ Format func([]*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 ProducerConfig *producer.ProducerConfig

+ func LoadMapping(f io.Reader) (ProducerConfig, error)

+ type StateNFLegacy struct

+ Format format.FormatInterface

+ Logger Logger

+ Transport transport.TransportInterface

+ func (s *StateNFLegacy) DecodeFlow(msg interface{}) error

+ func (s *StateNFLegacy) FlowRoutine(workers int, addr string, port int, reuseport bool) error

+ func (s *StateNFLegacy) Shutdown()

+ type StateNetFlow struct

+ Config *producer.ProducerConfig

+ Format format.FormatInterface

+ Logger Logger

+ Transport transport.TransportInterface

+ 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)

+ func (s *StateNetFlow) Shutdown()

+ type StateSFlow struct

+ Config *producer.ProducerConfig

+ Format format.FormatInterface

+ Logger Logger

+ Transport transport.TransportInterface

+ func (s *StateSFlow) DecodeFlow(msg interface{}) error

+ func (s *StateSFlow) FlowRoutine(workers int, addr string, port int, reuseport bool) error

+ func (s *StateSFlow) Shutdown()

+ 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

+ Send func([]*flowmessage.FlowMessage)