aggregator

Documentation

Index

• Variables
• func NewBasicAggregator(name string) *basicAggregator
• func NewCustomAggregator(kv map[string]interface{}) *customAggregator
• func NewPercentileAggregator(percentile float64, value int, unit utils.TimeUnit) *percentileAggregator
• func NewRateAggregator(unit utils.TimeUnit) *rateAggregator
• func NewSamplingAggregator(name string, value int, unit utils.TimeUnit) *samplingAggregator

Variables

var (
	ErrorAggrNameInvalid = errors.New("Aggregator name empty")

	ErrorPercentileInvalid = errors.New("Percentile value must > 0 and <= 1")

	ErrorSamplingAggrValueInvalid     = errors.New("Sampling Aggregator value must be > 0")
	ErrorSamplingAggrStartTimeInvalid = errors.New("Sampling Aggregator start time must be > 0")
)

Functions

func NewBasicAggregator

func NewBasicAggregator(name string) *basicAggregator

func NewCustomAggregator

func NewCustomAggregator(kv map[string]interface{}) *customAggregator

func NewPercentileAggregator

func NewPercentileAggregator(percentile float64, value int, unit utils.TimeUnit) *percentileAggregator

func NewRateAggregator

func NewRateAggregator(unit utils.TimeUnit) *rateAggregator

func NewSamplingAggregator

func NewSamplingAggregator(name string, value int, unit utils.TimeUnit) *samplingAggregator