Versions in this module Expand all Collapse all v0 v0.1.0 Aug 5, 2024 Changes in this version + const BooleanType + const IntType + const ProcessorDefaultType + const StringType + type AggregatedConfig struct + KindMap map[string][]KindConfig + type AggregatedKindConfig struct + ExplicitBoundaries []int64 + Kind string + OutputName string + type Aggregator interface + Aggregate func(data *model.DataBlock, selectors *LabelSelectors) + Dump func() []*model.DataBlock + type AggregatorKind int + const AvgKind + const CountKind + const HistogramKind + const LastKind + const MaxKind + const SumKind + func GetAggregatorKind(kind string) AggregatorKind + type Config struct + AggregateKindMap map[string][]AggregatedKindConfig + SessionInfos []Session + TickerInterval int + func NewConfig() *Config + type DefaultAggregator struct + func NewDefaultAggregator(config *AggregatedConfig) *DefaultAggregator + func (d *DefaultAggregator) Aggregate(data *model.DataBlock, selectors *LabelSelectors) + func (d *DefaultAggregator) Dump() []*model.DataBlock + type DefaultProcessor struct + func (d *DefaultProcessor) Consume(data *model.DataBlock) error + type KindConfig struct + ExplicitBoundaries []int64 + Kind AggregatorKind + OutputName string + type LabelKey struct + Name string + VType vType + Value string + type LabelKeys struct + func GetLabelsKeys(attributeMap *model.AttributeMap) *LabelKeys + func NewLabelKeys(keys ...LabelKey) *LabelKeys + func (k *LabelKeys) GetLabels() *model.AttributeMap + func (k *LabelKeys) Len() int + func (k *LabelKeys) Less(i, j int) bool + func (k *LabelKeys) Swap(i, j int) + type LabelSelector struct + Name string + VType vType + type LabelSelectors struct + func NewLabelSelectors(selectors ...LabelSelector) *LabelSelectors + func (s *LabelSelectors) AppendSelectors(selectors ...LabelSelector) + func (s *LabelSelectors) GetLabelKeys(labels *model.AttributeMap) *LabelKeys + type Processor interface + func NewDefaultProcessor(cfg any, con consumer.Consumer) Processor + type Session struct + Class string + Name string + Params map[string]string
Go to main page