Versions in this module Expand all Collapse all v0 v0.8.0 Jun 24, 2017 Changes in this version + type DiskQueue struct + func (this DiskQueue) Close(k QueueKey) error + func (this DiskQueue) Name() string + func (this DiskQueue) Pop(k QueueKey, timeoutInSeconds time.Duration) (error, []byte) + func (this DiskQueue) Push(k QueueKey, v []byte) error + func (this DiskQueue) ReadChan(k QueueKey) chan []byte + func (this DiskQueue) Start(cfg *Config) + func (this DiskQueue) Stop() error
Go to main page