flow

Documentation

Index

• Constants
• Variables
• type FlowMetric
• type FlowSource
• type KentikDriver
  • func NewFlowSource(ctx context.Context, proto FlowSource, maxBatchSize int, log logger.Underlying, ...) (*KentikDriver, error)
  • func NewKentikDriver(ctx context.Context, proto FlowSource, maxBatchSize int, log logger.Underlying, ...) *KentikDriver
  • func (t *KentikDriver) Close()
  • func (t *KentikDriver) Format(data interface{}) ([]byte, []byte, error)
  • func (t *KentikDriver) HttpInfo() map[string]float64
  • func (t *KentikDriver) Init(ctx context.Context) error
  • func (t *KentikDriver) Prepare() error
• type KentikLog
  • func (l *KentikLog) Debug(vars ...interface{})
  • func (l *KentikLog) Debugf(f string, vars ...interface{})
  • func (l *KentikLog) Error(vars ...interface{})
  • func (l *KentikLog) Errorf(f string, vars ...interface{})
  • func (l *KentikLog) Fatalf(f string, vars ...interface{})
  • func (l *KentikLog) Infof(f string, vars ...interface{})
  • func (l *KentikLog) Printf(f string, vars ...interface{})
  • func (l *KentikLog) Warn(vars ...interface{})
  • func (l *KentikLog) Warnf(f string, vars ...interface{})

Constants

const (
	Ipfix    FlowSource = "ipfix"
	Sflow               = "sflow"
	Netflow5            = "netflow5"
	Netflow9            = "netflow9"
)

const (
	DeviceUpdateDuration = 1 * time.Hour
)

Variables

var (
	Addr          = flag.String("nf.addr", "0.0.0.0", "Sflow/NetFlow/IPFIX listening address")
	Port          = flag.Int("nf.port", 9995, "Sflow/NetFlow/IPFIX listening port")
	Reuse         = flag.Bool("nf.reuserport", false, "Enable so_reuseport for Sflow/NetFlow/IPFIX")
	Workers       = flag.Int("nf.workers", 1, "Number of workers per flow collector")
	MessageFields = flag.String("nf.message.fields", defaultFields, "The list of fields to include in flow messages. Can be any of "+fullFieldList)
	PromPath      = flag.String("nf.prom.listen", "", "Run a promethues metrics collector here")
	MappingFile   = flag.String("nf.mapping", "", "Configuration file for custom netflow mappings")
)

Types

type FlowMetric

type FlowMetric struct {
	Flows go_metrics.Meter
}

type FlowSource

type FlowSource string

type KentikDriver

type KentikDriver struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewFlowSource

func NewFlowSource(ctx context.Context, proto FlowSource, maxBatchSize int, log logger.Underlying, registry go_metrics.Registry, jchfChan chan []*kt.JCHF, apic *api.KentikApi, resolv *resolv.Resolver) (*KentikDriver, error)

func NewKentikDriver

func NewKentikDriver(ctx context.Context, proto FlowSource, maxBatchSize int, log logger.Underlying, registry go_metrics.Registry, jchfChan chan []*kt.JCHF, apic *api.KentikApi, fields string, resolv *resolv.Resolver) *KentikDriver

func (*KentikDriver) Close

func (t *KentikDriver) Close()

func (*KentikDriver) Format

func (t *KentikDriver) Format(data interface{}) ([]byte, []byte, error)

func (*KentikDriver) HttpInfo

func (t *KentikDriver) HttpInfo() map[string]float64

func (*KentikDriver) Init

func (t *KentikDriver) Init(ctx context.Context) error

func (*KentikDriver) Prepare

func (t *KentikDriver) Prepare() error

type KentikLog

type KentikLog struct {
	// contains filtered or unexported fields
}

func (*KentikLog) Debug

func (l *KentikLog) Debug(vars ...interface{})

func (*KentikLog) Debugf

func (l *KentikLog) Debugf(f string, vars ...interface{})

func (*KentikLog) Error

func (l *KentikLog) Error(vars ...interface{})

func (*KentikLog) Errorf

func (l *KentikLog) Errorf(f string, vars ...interface{})

func (*KentikLog) Fatalf

func (l *KentikLog) Fatalf(f string, vars ...interface{})

func (*KentikLog) Infof

func (l *KentikLog) Infof(f string, vars ...interface{})

func (*KentikLog) Printf

func (l *KentikLog) Printf(f string, vars ...interface{})

func (*KentikLog) Warn

func (l *KentikLog) Warn(vars ...interface{})

func (*KentikLog) Warnf

func (l *KentikLog) Warnf(f string, vars ...interface{})