processor

type AggregatedConfig struct {
	KindMap map[string][]KindConfig
}

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

type Aggregator interface {
	Aggregate(data *model.DataBlock, selectors *LabelSelectors)
	Dump() []*model.DataBlock
}

type AggregatorKind int

type Config struct {
	TickerInterval   int                               `mapstructure:"ticker_interval"`
	SessionInfos     []Session                         `mapstructure:"sessioninfo"`
	AggregateKindMap map[string][]AggregatedKindConfig `mapstructure:"aggregate_kind_map"`
}

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

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

type KindConfig struct {
	OutputName string
	Kind       AggregatorKind
	// Only HistogramKind has this value
	ExplicitBoundaries []int64
}

type LabelKey struct {
	Name  string
	Value string
	VType vType
	sort.Interface
}

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

type LabelSelector struct {
	Name  string
	VType vType
}

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

type Processor interface {
	consumer.Consumer
}

type Session struct {
	Class  string            `mapstructure:"class"`
	Name   string            `mapstructure:"name"`
	Params map[string]string `mapstructure:"params"`
}