Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 2018 Changes in this version + type DelayHeap struct + func NewDelayHeap() *DelayHeap + func (p *DelayHeap) Contains(heapNode HeapNode) bool + func (p *DelayHeap) Length() int + func (p *DelayHeap) Peek() *delayHeapNode + func (p *DelayHeap) Pop() *delayHeapNode + func (p *DelayHeap) Push(dataNode HeapNode, next time.Time) error + func (p *DelayHeap) Remove(heapNode HeapNode) error + func (p *DelayHeap) Update(heapNode HeapNode, waitUntil time.Time) error + type HeapNode interface + Data func() interface{} + ID func() string + Namespace func() string