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 (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 ¶
View Source
const ( PUT_BATCH_SIZE = 1024 MAX_EXPORTERS_PER_DATASOURCE = 8 )
Variables ¶
This section is empty.
Functions ¶
func GetTagFilters ¶
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 (*Exporters) IsExportItem ¶
func (es *Exporters) IsExportItem(item common.ExportItem, dataSourceId uint32, exporterCfg *config.ExporterCfg) bool
type ExportersCache ¶
type ExportersCache []interface{}
Click to show internal directories.
Click to hide internal directories.