Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockQueue ¶
func NewBlockQueue ¶
func NewBlockQueue[V any](constraint HeapConstraint[V]) BlockQueue[V]
type DelayingQueue ¶
type DelayingQueue[V any] interface { BlockQueue[V] AddAfter(value V, duration time.Duration) Refresh(obj V) error }
func NewDelayingQueue ¶
func NewDelayingQueue[V any](constraint HeapConstraint[V]) DelayingQueue[V]
type HeapConstraint ¶
type HeapConstraint[VALUE any] interface { heap.Constraint[string, VALUE] }
Click to show internal directories.
Click to hide internal directories.