aggregate

Documentation

Index

• type MovingWindowAverage
• type MovingWindowAvgImpl
  • func NewMovingWindowAvgImpl(windowSize time.Duration, maxBufferSize int) *MovingWindowAvgImpl
  • func (a *MovingWindowAvgImpl) Average() float64
  • func (a *MovingWindowAvgImpl) Record(val int64)

Types

type MovingWindowAverage

type MovingWindowAverage interface {
	Record(val int64)
	Average() float64
}

var NoopMovingWindowAverage MovingWindowAverage = newNoopMovingWindowAverage()

type MovingWindowAvgImpl

type MovingWindowAvgImpl struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMovingWindowAvgImpl

func NewMovingWindowAvgImpl(
	windowSize time.Duration,
	maxBufferSize int,
) *MovingWindowAvgImpl

func (*MovingWindowAvgImpl) Average

func (a *MovingWindowAvgImpl) Average() float64

func (*MovingWindowAvgImpl) Record

func (a *MovingWindowAvgImpl) Record(val int64)