Versions in this module Expand all Collapse all v0 v0.1.0 Oct 14, 2018 Changes in this version + var ErrEmptyQueue = errors.New("queue is empty") + type Arena struct + func NewArena(file string, size int) (*Arena, error) + type BigQueue struct + func NewBigQueue(dir string) (*BigQueue, error) + func (bq *BigQueue) Close() + func (bq *BigQueue) Dequeue() ([]byte, error) + func (bq *BigQueue) Enqueue(message []byte) error + func (bq *BigQueue) IsEmpty() bool + func (bq *BigQueue) Peek() ([]byte, error) + type IBigQueue interface + Close func() + Dequeue func() ([]byte, error) + Enqueue func(elem []byte) error + IsEmpty func() bool + Peek func() []byte + type QueueIndex struct + func NewQueueIndex(dataDir string) (*QueueIndex, error) + func (i *QueueIndex) Flush() + func (i *QueueIndex) GetHead() (int, int) + func (i *QueueIndex) GetTail() (int, int) + func (i *QueueIndex) UpdateHead(aid, pos int) + func (i *QueueIndex) UpdateTail(aid, pos int)
Go to main page