collection

Documentation

Index

• type Bucket
• type RollingWindow
  • func NewRollingWindow(size int, interval time.Duration, opts ...RollingWindowOption) *RollingWindow
  • func (rw *RollingWindow) Add(v float64)
  • func (rw *RollingWindow) Reduce(fn func(b *Bucket))
• type RollingWindowOption
  • func IgnoreCurrentBucket() RollingWindowOption

Types

type Bucket

type Bucket struct {
	Sum   float64
	Count int64
}

type RollingWindow

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

func NewRollingWindow

func NewRollingWindow(size int, interval time.Duration, opts ...RollingWindowOption) *RollingWindow

func (*RollingWindow) Add

func (rw *RollingWindow) Add(v float64)

func (*RollingWindow) Reduce

func (rw *RollingWindow) Reduce(fn func(b *Bucket))

type RollingWindowOption

type RollingWindowOption func(rollingWindow *RollingWindow)

func IgnoreCurrentBucket

func IgnoreCurrentBucket() RollingWindowOption