Versions in this module Expand all Collapse all v0 v0.8.0 Jun 24, 2017 Changes in this version + func Close(k QueueKey) error + func Pop(k QueueKey) (error, []byte) + func PopTimeout(k QueueKey, timeoutInSeconds time.Duration) (error, []byte) + func Push(k QueueKey, v []byte) error + func ReadChan(k QueueKey) chan []byte + func Register(h Queue) + type Queue interface + Close func(QueueKey) error + Pop func(QueueKey, time.Duration) (error, []byte) + Push func(QueueKey, []byte) error + ReadChan func(k QueueKey) chan []byte + type QueueKey string