rollup

Documentation

Index

• func NanosecondsToSeconds(ns int64) float64
• func NewCounterRollup(log *logger.Logger, nodeIndex, metricName string, rollupTags []string) *counterRollup
• func NewHistogramRollup(log *logger.Logger, nodeIndex, metricName string, rollupTags []string) *histogramRollup
• func NewNullRollup() *nullRollup
• type PointsBatch
• type Rollup

Functions

func NanosecondsToSeconds

func NanosecondsToSeconds(ns int64) float64

func NewCounterRollup

func NewCounterRollup(log *logger.Logger, nodeIndex, metricName string, rollupTags []string) *counterRollup

func NewHistogramRollup

func NewHistogramRollup(log *logger.Logger, nodeIndex, metricName string, rollupTags []string) *histogramRollup

func NewNullRollup

func NewNullRollup() *nullRollup

Types

type PointsBatch

type PointsBatch struct {
	Points []*rpc.Point
	Size   int
}

type Rollup

type Rollup interface {
	Record(sourceId string, tags map[string]string, value int64)
	Rollup(timestamp int64) []*PointsBatch
}