queue

Sep 13, 2017

Changes in this version

type BackendQueue

+ func NewDirectQueue(name string) BackendQueue

Sep 5, 2017

Changes in this version

+ const FROM_DISK

+ const FROM_MEMORY

+ const FROM_NONE

Aug 1, 2017

Changes in this version

+ const StatusClosed

+ const StatusInit

type BackendQueue

+ func NewMemoryQueue(name string, maxQueueLength int) BackendQueue

Jun 27, 2017

Changes in this version

+ func AtomicRename(sourceFile, targetFile string) error

+ type BackendQueue interface

+ Close func() error

+ Delete func() error

+ Depth func() int64

+ Empty func() error

+ Name func() string

+ Put func([]byte) error

+ ReadChan func() chan []byte

+ func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64, minMsgSize int32, ...) BackendQueue