Versions in this module Expand all Collapse all v1 v1.0.1 Aug 18, 2015 v1.0.0 Aug 4, 2015 Changes in this version + var ErrDisposed = errors.New(`queue: disposed`) + var ErrTimeout = errors.New(`queue: poll timed out`) + func ExecuteInParallel(q *Queue, fn func(interface{})) + type Item interface + Compare func(other Item) int + type PriorityQueue struct + func NewPriorityQueue(hint int, allowDuplicates bool) *PriorityQueue + func (pq *PriorityQueue) Dispose() + func (pq *PriorityQueue) Disposed() bool + func (pq *PriorityQueue) Empty() bool + func (pq *PriorityQueue) Get(number int) ([]Item, error) + func (pq *PriorityQueue) Len() int + func (pq *PriorityQueue) Peek() Item + func (pq *PriorityQueue) Put(items ...Item) error + type Queue struct + func New(hint int64) *Queue + func (q *Queue) Dispose() []interface{} + func (q *Queue) Disposed() bool + func (q *Queue) Empty() bool + func (q *Queue) Get(number int64) ([]interface{}, error) + func (q *Queue) Len() int64 + func (q *Queue) Poll(number int64, timeout time.Duration) ([]interface{}, error) + func (q *Queue) Put(items ...interface{}) error + func (q *Queue) TakeUntil(checker func(item interface{}) bool) ([]interface{}, error) + type RingBuffer struct + func NewRingBuffer(size uint64) *RingBuffer + func (rb *RingBuffer) Cap() uint64 + func (rb *RingBuffer) Dispose() + func (rb *RingBuffer) Get() (interface{}, error) + func (rb *RingBuffer) IsDisposed() bool + func (rb *RingBuffer) Len() uint64 + func (rb *RingBuffer) Offer(item interface{}) (bool, error) + func (rb *RingBuffer) Put(item interface{}) error
Go to main page