Documentation
¶
Overview ¶
Package netflowstate provides a Netflow state manager on top of goflow default producer, to allow additional fields collection.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAlreadyStarted = errors.New("the routine is already started")
ErrAlreadyStarted error happens when you try to start twice a flow routine
Functions ¶
This section is empty.
Types ¶
type StateNetFlow ¶
type StateNetFlow struct {
Format format.FormatInterface
Transport transport.TransportInterface
Logger utils.Logger
Config *producer.ProducerConfig
TemplateSystem templates.TemplateInterface
// contains filtered or unexported fields
}
StateNetFlow holds a NetflowV9/IPFIX producer
func NewStateNetFlow ¶
func NewStateNetFlow(mappingConfs []config.Mapping) *StateNetFlow
NewStateNetFlow initializes a new Netflow/IPFIX producer, with the goflow default producer and the additional fields producer
func (*StateNetFlow) DecodeFlow ¶
func (s *StateNetFlow) DecodeFlow(msg interface{}) error
DecodeFlow decodes a flow into common.FlowMessageWithAdditionalFields
func (*StateNetFlow) FlowRoutine ¶
FlowRoutine starts a goflow flow routine
Source Files
Click to show internal directories.
Click to hide internal directories.