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) Len() int
  • func (h TimeHeap) Less(i, j int) bool
  • func (h *TimeHeap) Pop() interface{}
  • func (h *TimeHeap) Push(x interface{})
  • func (h TimeHeap) Swap(i, j int)

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) Len

func (h TimeHeap) Len() int

func (TimeHeap) Less

func (h TimeHeap) Less(i, j int) bool

func (*TimeHeap) Pop

func (h *TimeHeap) Pop() interface{}

func (*TimeHeap) Push

func (h *TimeHeap) Push(x interface{})

func (TimeHeap) Swap

func (h TimeHeap) Swap(i, j int)