defaultaggregator

package

v0.0.0-...-51da36d Latest Latest Go to latest Published: Feb 20, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

type AggregatorKind int

const (
	SumKind AggregatorKind = iota
	MaxKind
	AvgKind
	LastKind
	CountKind
	HistogramKind
)

func GetAggregatorKind(kind string) AggregatorKind

type CumulativeAggregator struct {
	*DefaultAggregator
	MetricExpiration time.Duration
}

func NewCumulativeAggregator(config *AggregatedConfig, metricExpiration time.Duration) *CumulativeAggregator

func (c *CumulativeAggregator) AggregatorWithAllLabelsAndMetric(g *model.DataGroup, now time.Time)

func (c *CumulativeAggregator) DumpAndRemoveExpired(now time.Time) []*model.DataGroup

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

func NewDefaultAggregator(config *AggregatedConfig) *DefaultAggregator

func (s *DefaultAggregator) Aggregate(g *model.DataGroup, selectors *aggregator.LabelSelectors)

func (s *DefaultAggregator) CheckExist(dataGroupName string) bool

func (s *DefaultAggregator) Dump() []*model.DataGroup

func (s *DefaultAggregator) DumpSingle(dataGroupName string) []*model.DataGroup

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