rollup

Documentation

Index

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

Constants

const (
	GorouterHttpMetricName = "http"
	GorouterSourceId       = "gorouter"
)

Functions

func NewCounterRollup

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

func NewHistogramRollup

func NewHistogramRollup(log *logger.Logger, nodeIndex 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
}