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 CounterRollupOption
  • func WithCounterRollupExpiration(expiration time.Duration) CounterRollupOption
• type HistogramRollupOption
  • func WithHistogramRollupExpiration(expiration time.Duration) HistogramRollupOption
• type PointsBatch
• type Rollup

Constants

const (
	EXPIRATION             = 10 * time.Minute
	GorouterHttpMetricName = "http"
)

Functions

func NewCounterRollup

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

func NewHistogramRollup

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

func NewNullRollup

func NewNullRollup() *nullRollup

Types

type CounterRollupOption

type CounterRollupOption func(*counterRollup)

func WithCounterRollupExpiration

func WithCounterRollupExpiration(expiration time.Duration) CounterRollupOption

type HistogramRollupOption

type HistogramRollupOption func(*histogramRollup)

func WithHistogramRollupExpiration

func WithHistogramRollupExpiration(expiration time.Duration) HistogramRollupOption

type PointsBatch

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

type Rollup

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