v1

Documentation

Index

• type Bucket
• type ReduceFn
• type RollingWindow
  • func New(size int, eachBucketTime time.Duration) *RollingWindow
  • func (r *RollingWindow) Add(v float64)
  • func (r *RollingWindow) Reduce(fn ReduceFn)

Types

type Bucket

type Bucket struct {
	Sum   float64
	Count int64
	// contains filtered or unexported fields
}

type ReduceFn

type ReduceFn func(*Bucket)

type RollingWindow

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

func New

func New(size int, eachBucketTime time.Duration) *RollingWindow

New 计算当前时间所属window的开始时间, 以此时间为截止时间(采用时间bucket.startTime当标准), 返回之前一个窗口周期内的bucket

func (*RollingWindow) Add

func (r *RollingWindow) Add(v float64)

func (*RollingWindow) Reduce

func (r *RollingWindow) Reduce(fn ReduceFn)