flow

Documentation

Index

• Constants
• type EntConfig
• 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
  • func (t *KentikDriver) SetConfig(c EntConfig)
• 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"
	NBar                = "nbar"
	ASA                 = "asa"
	PAN                 = "pan"
	JFlow               = "jflow"
	CFlow               = "cflow"
)

const (
	DeviceUpdateDuration = 1 * time.Hour
)

Types

type EntConfig

type EntConfig struct {
	FlowConfig producer.ProducerConfig `json:"flow_config"`
	NameMap    map[string]string       `json:"name_map"`
}

type FlowMetric

type FlowMetric struct {
	Flows go_metrics.Meter
}

type FlowSource

type FlowSource string

type KentikDriver

type KentikDriver struct {
	logger.ContextL
	sync.RWMutex
	// 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, cfg *ktranslate.FlowInputConfig) (*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, cfg *ktranslate.FlowInputConfig) *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

func (*KentikDriver) SetConfig

func (t *KentikDriver) SetConfig(c EntConfig)

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{})