timeheap

package

v1.0.0-beta.4 Latest Latest Go to latest Published: Aug 29, 2022 License: Apache-2.0, BSD-2-Clause Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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() *TimeHeap

NewTimeHeap creates a new TimeHeap object.

func (h *TimeHeap) Add(count uint64)

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

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 (h *TimeHeap) Clear()

Clear removes all elements from the container.