exporters

Documentation

Index

• Constants
• func GetTagFilters(field string, tagFilters []config.TagFilter) []config.TagFilter
• func IsExportField(tag *config.StructTags, exportFieldCategoryBits uint64, ...) bool
• type Exporter
• type Exporters
  • func NewExporters(cfg *config.Config) *Exporters
  • func (es *Exporters) Close() error
  • func (es *Exporters) Flush(dataSourceId, decoderIndex int)
  • func (es *Exporters) IsExportItem(item common.ExportItem, dataSourceId uint32, exporterCfg *config.ExporterCfg) bool
  • func (es *Exporters) Put(dataSourceId uint32, decoderIndex int, item common.ExportItem)
  • func (es *Exporters) Start()
• type ExportersCache

Constants

const (
	PUT_BATCH_SIZE               = 1024
	MAX_EXPORTERS_PER_DATASOURCE = 8
)

Functions

func GetTagFilters

func GetTagFilters(field string, tagFilters []config.TagFilter) []config.TagFilter

func IsExportField

func IsExportField(tag *config.StructTags, exportFieldCategoryBits uint64, exportFieldNames []string) bool

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

type Exporters

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

func NewExporters

func NewExporters(cfg *config.Config) *Exporters

func (*Exporters) Close

func (es *Exporters) Close() error

func (*Exporters) Flush

func (es *Exporters) Flush(dataSourceId, decoderIndex int)

func (*Exporters) IsExportItem

func (es *Exporters) IsExportItem(item common.ExportItem, dataSourceId uint32, exporterCfg *config.ExporterCfg) bool

func (*Exporters) Put

func (es *Exporters) Put(dataSourceId uint32, decoderIndex int, item common.ExportItem)

func (*Exporters) Start

func (es *Exporters) Start()

type ExportersCache

type ExportersCache []interface{}