aggregateprocessor

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

type AggregatedKindConfig struct {
	OutputName         string  `mapstructure:"output_name"`
	Kind               string  `mapstructure:"kind"`
	ExplicitBoundaries []int64 `mapstructure:"explicit_boundaries"`
}

type Config struct {
	// The unit is second.
	TickerInterval int `mapstructure:"ticker_interval"`

	AggregateKindMap map[string][]AggregatedKindConfig `mapstructure:"aggregate_kind_map"`
	SamplingRate     *SampleConfig                     `mapstructure:"sampling_rate"`
}

type SampleConfig struct {
	NormalData int `mapstructure:"normal_data"`
	SlowData   int `mapstructure:"slow_data"`
	ErrorData  int `mapstructure:"error_data"`
}