Versions in this module Expand all Collapse all v0 v0.12.0 Sep 18, 2019 Changes in this version + type Table struct + In chan []byte + SpoolDir string + func InitFromConfig(config cfg.Config, meta toml.MetaData) (*Table, error) + func New(config cfg.Config) *Table + func (table *Table) AddAggregator(agg *aggregator.Aggregator) + func (table *Table) AddBlacklist(matcher *matcher.Matcher) + func (table *Table) AddRewriter(rw rewriter.RW) + func (table *Table) AddRoute(route route.Route) + func (table *Table) Bad() *badmetrics.BadMetrics + func (table *Table) DelAggregator(id int) error + func (table *Table) DelBlacklist(index int) error + func (table *Table) DelDestination(key string, index int) error + func (table *Table) DelRewriter(id int) error + func (table *Table) DelRoute(key string) error + func (table *Table) Dispatch(buf []byte) + func (table *Table) DispatchAggregate(buf []byte) + func (table *Table) Flush() error + func (table *Table) GetIn() chan []byte + func (table *Table) GetRoute(key string) route.Route + func (table *Table) GetSpoolDir() string + func (table *Table) IncNumInvalid() + func (table *Table) InitAggregation(config cfg.Config) error + func (table *Table) InitBadMetrics(config cfg.Config) error + func (table *Table) InitBlacklist(config cfg.Config) error + func (table *Table) InitCmd(config cfg.Config) error + func (table *Table) InitRewrite(config cfg.Config) error + func (table *Table) InitRoutes(config cfg.Config, meta toml.MetaData) error + func (table *Table) Print() (str string) + func (table *Table) Shutdown() error + func (table *Table) Snapshot() TableSnapshot + func (table *Table) UpdateDestination(key string, index int, opts map[string]string) error + func (table *Table) UpdateRoute(key string, opts map[string]string) error + type TableConfig struct + Validate_order bool + Validation_level_legacy validate.LevelLegacy + Validation_level_m20 validate.LevelM20 + type TableSnapshot struct + Aggregators []*aggregator.Aggregator + Blacklist []*matcher.Matcher + Rewriters []rewriter.RW + Routes []route.Snapshot + SpoolDir string