Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrDisposed is returned when an operation is performed on a disposed // queue. ErrDisposed = errors.New(`queue: disposed`) // ErrTimeout is returned when an applicable queue operation times out. ErrTimeout = errors.New(`queue: poll timed out`) // ErrEmptyQueue is returned when an non-applicable queue operation was called // due to the queue's empty item state ErrEmptyQueue = errors.New(`queue: empty queue`) )
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue interface {
// Put put items to queue
Put(items ...interface{}) error
// Get batch get items from queue
Get(number int64, items []interface{}) (int64, error)
// Dispose dispose queue
Dispose() []interface{}
// Disposed returns a bool indicating if this queue
// has had disposed called on it.
Disposed() bool
}
Queue queue
Source Files
Click to show internal directories.
Click to hide internal directories.