Versions in this module Expand all Collapse all v1 v1.0.0 Mar 10, 2015 Changes in this version + var DefaultSleepTime = time.Second + var ErrNoOverflowItems = errors.New("no overflow items") + type Item struct + Key []byte + Value []byte + type Queue struct + DefaultCh chan Item + DefaultDB *leveldb.DB + OverflowCh chan Item + OverflowDB *leveldb.DB + SleepTime time.Duration + func New(size int, defaultDBPath, overflowDBPath string) (q Queue, err error) + func (q *Queue) Completed(key []byte) (err error) + func (q *Queue) Dequeue() (item Item, err error) + func (q *Queue) Enqueue(value []byte) (err error) Incompatible versions in this module v2.0.0+incompatible Mar 12, 2015
Go to main page