collect

Documentation

Index

• type TimedQueue
  • func NewTimedQueue(updateInterval int) *TimedQueue
  • func (queue *TimedQueue) Add(value interface{}, time2Remove int64)
  • func (queue *TimedQueue) RemovedEntries() <-chan interface{}

Types

type TimedQueue

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

TimedQueue is a priority queue that entries with oldest timestamp get removed first.

func NewTimedQueue

func NewTimedQueue(updateInterval int) *TimedQueue

func (*TimedQueue) Add

func (queue *TimedQueue) Add(value interface{}, time2Remove int64)

func (*TimedQueue) RemovedEntries

func (queue *TimedQueue) RemovedEntries() <-chan interface{}