xcollection

Documentation

Index

• type Bucket
• type RollingWindow
  • func NewRollingWindow(bucketSize int, bucketDuration time.Duration) *RollingWindow
  • func (rw *RollingWindow) Add(v float64)
  • func (rw *RollingWindow) Reduce(fn func(*Bucket))

Types

type Bucket

type Bucket struct {
	Sum   float64
	Count int64
}

type RollingWindow

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

func NewRollingWindow

func NewRollingWindow(bucketSize int, bucketDuration time.Duration) *RollingWindow

func (*RollingWindow) Add

func (rw *RollingWindow) Add(v float64)

func (*RollingWindow) Reduce

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