timeheap

Documentation

Index

• type TimeHeap
  • func NewTimeHeap() *TimeHeap
  • func (h *TimeHeap) Add(count uint64)
  • func (h *TimeHeap) AveragePerSecond(timeBefore time.Duration) float32
  • func (h *TimeHeap) Clear()

Types

type TimeHeap

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

TimeHeap implements a heap sorted by time, where older elements are popped during AveragePerSecond call.

func NewTimeHeap

func NewTimeHeap() *TimeHeap

NewTimeHeap creates a new TimeHeap object.

func (*TimeHeap) Add

func (h *TimeHeap) Add(count uint64)

Add a new entry to the container with a count for the average calculation.

func (*TimeHeap) AveragePerSecond

func (h *TimeHeap) AveragePerSecond(timeBefore time.Duration) float32

AveragePerSecond calculates the average per second of all entries in the given duration. older elements are removed from the container.

func (*TimeHeap) Clear

func (h *TimeHeap) Clear()

Clear removes all elements from the container.