goflow

Documentation

Index

• func Parse(message *flowmessage.FlowMessage) (map[string]interface{}, time.Time, error)
• type GoflowInput
  • func (n *GoflowInput) Printf(format string, args ...interface{})
  • func (n *GoflowInput) Publish(messages []*flowmessage.FlowMessage)
  • func (n *GoflowInput) Start() error
  • func (n *GoflowInput) Stop() error
• type GoflowInputConfig
  • func NewGoflowInputConfig(operatorID string) *GoflowInputConfig
  • func (c *GoflowInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Functions

func Parse

func Parse(message *flowmessage.FlowMessage) (map[string]interface{}, time.Time, error)

Parse parses a netflow message into an entry. It is assumed that Proto, InIf, and OutIf are always set because 0 values are valid.

Types

type GoflowInput

type GoflowInput struct {
	helper.InputOperator
	// contains filtered or unexported fields
}

GoflowInput is an operator that receives network traffic information from network devices.

func (*GoflowInput) Printf

func (n *GoflowInput) Printf(format string, args ...interface{})

Printf is required by goflows logging interface

func (*GoflowInput) Publish

func (n *GoflowInput) Publish(messages []*flowmessage.FlowMessage)

Publish writes entries and satisfies GoFlow's util.Transport interface

func (*GoflowInput) Start

func (n *GoflowInput) Start() error

Start will start generating log entries.

func (*GoflowInput) Stop

func (n *GoflowInput) Stop() error

Stop will stop generating logs.

type GoflowInputConfig

type GoflowInputConfig struct {
	helper.InputConfig `yaml:",inline"`

	Mode          string `json:"mode,omitempty"           yaml:"mode,omitempty"`
	ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
	Workers       uint   `json:"workers,omitempty"        yaml:"workers,omitempty"`
}

GoflowInputConfig is the configuration of a goflow input operator.

func NewGoflowInputConfig

func NewGoflowInputConfig(operatorID string) *GoflowInputConfig

NewGoflowInputConfig creates a new goflow input config with default values

func (*GoflowInputConfig) Build

func (c *GoflowInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a goflow input operator.