Versions in this module Expand all Collapse all v1 v1.3.0 Sep 22, 2019 v1.2.0 Aug 20, 2019 Changes in this version + var ErrDisposed = errors.New(`queue: disposed`) + var ErrEmptyQueue = errors.New(`queue: empty queue`) + var ErrTimeout = errors.New(`queue: poll timed out`) + func ExecuteInParallel(q *Queue, fn func(interface{})) + 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) GetUntil(checker func(item interface{}) bool) ([]interface{}, error) + func (q *Queue) Len() int64 + func (q *Queue) Peek() (interface{}, error) + func (q *Queue) Poll(number int64, timeout time.Duration) ([]interface{}, error) + func (q *Queue) Put(items ...interface{}) error
Go to main page