sliding_window

Documentation

Index

• type SlidingWindow
  • func MustNew(window, granularity time.Duration) *SlidingWindow
  • func New(window, granularity time.Duration) (*SlidingWindow, error)
  • func (sw *SlidingWindow) Add(v int64)
  • func (sw *SlidingWindow) Average(window time.Duration) float64
  • func (sw *SlidingWindow) Stop()
  • func (sw *SlidingWindow) Total(window time.Duration) (int64, int)

Types

type SlidingWindow

type SlidingWindow struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func MustNew

func MustNew(window, granularity time.Duration) *SlidingWindow

func New

func New(window, granularity time.Duration) (*SlidingWindow, error)

func (*SlidingWindow) Add

func (sw *SlidingWindow) Add(v int64)

Add increments the value of the current sample.

func (*SlidingWindow) Average

func (sw *SlidingWindow) Average(window time.Duration) float64

Average returns the unweighted mean of the specified window.

func (*SlidingWindow) Stop

func (sw *SlidingWindow) Stop()

Stop the shifter of this sliding time window. A stopped SlidingWindow cannot be started again.

func (*SlidingWindow) Total

func (sw *SlidingWindow) Total(window time.Duration) (int64, int)

Total returns the sum of all values over the specified window, as well as the number of samples.