exporters

Documentation

Index

• Constants
• type Exporter
• type Exporters
  • func NewExporters(flowlogCfg *config.Config) *Exporters
  • func (es *Exporters) Close()
  • func (es *Exporters) Flush(decoderIndex int)
  • func (es *Exporters) Put(l *log_data.L7FlowLog, decoderIndex int)
  • func (es *Exporters) Start()
• type ExportersCache

Constants

const (
	PUT_BATCH_SIZE = 1024
)

Types

type Exporter

type Exporter interface {
	// Starts an exporter worker
	Start()
	// Close an exporter worker
	Close()

	// Put sends data to the exporter worker. Worker could decide what to do next. e.g.:
	// - send it out synchronously.
	// - store it in a queue and handle it later.
	Put(items ...interface{})

	// IsExportData tell the decoder if data need to be sended to specific exporter.
	IsExportData(l *log_data.L7FlowLog) bool
}

type Exporters

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

func NewExporters

func NewExporters(flowlogCfg *config.Config) *Exporters

func (*Exporters) Close

func (es *Exporters) Close()

func (*Exporters) Flush

func (es *Exporters) Flush(decoderIndex int)

func (*Exporters) Put

func (es *Exporters) Put(l *log_data.L7FlowLog, decoderIndex int)

parallel put

func (*Exporters) Start

func (es *Exporters) Start()

type ExportersCache

type ExportersCache [][]interface{}