config

type ConfigList []ConfigPlus

type ConfigPlus struct {
	// One of these pointer fields must be non-nil
	Kafka    *kafka.Config  `yaml:"kafka"`
	Influx   *influx.Config `yaml:"influx"`
	OpenTSDB *tsdb.Config   `yaml:"openTSDB"`
	LMM      *lmm.Config    `yaml:"lmm"`
	Mock     *mock.Config   `yaml:"mock"`
	Consumer ConsumerConfig `yaml:"consumer"`
}

type ConsumerConfig struct {
	// The name of the consumer. Required.
	Name string `yaml:"name"`
	// The number of goroutines doing writing. Optional.
	// A zero value means 1.
	Concurrency uint `yaml:"concurrency"`
	// The number of values written each time. Optional.
	// A zero value means 1000.
	BatchSize uint `yaml:"batchSize"`
	// The length of time for rolling up values when writing. Optional.
	// Zero means write every value and do no rollup.
	RollUpSpan time.Duration `yaml:"rollUpSpan"`
	// Maximum reocrds to write per second. Optional.
	// 0 means no limit.
	RecordsPerSecond uint `yaml:"recordsPerSecond"`
	// Metrics whose name matches DebugMetricRegex AND whose host matches
	// DebugHostRegex are written to the debug file. Empty values in
	// both of these fields means no debugging. An empty value in
	// one of these fields means ignore it when deciding if a metric
	// matches.
	DebugMetricRegex string `yaml:"debugMetricRegex"`
	DebugHostRegex   string `yaml:"debugHostRegex"`
	// The full path of the debug file. Optional.
	// If empty, debug goes to stdout.
	DebugFilePath string `yaml:"debugFilePath"`
	// If true, this consumer is paused
	Paused                    bool     `yaml:"paused"`
	RegexesOfMetricsToExclude []string `yaml:"regexesOfMetricsToExclude"`
}

type WriterFactory interface {
	NewWriter() (pstore.LimitedRecordWriter, error)
}