Documentation
¶
Index ¶
Constants ¶
View Source
const ( StatusInit int32 = iota StatusClosed )
View Source
const ( FROM_NONE = iota FROM_DISK FROM_MEMORY )
Variables ¶
This section is empty.
Functions ¶
func AtomicRename ¶
Types ¶
type BackendQueue ¶
type BackendQueue interface {
Name() string
Put([]byte) error
ReadChan() <-chan []byte // this is expected to be an *unbuffered* channel
Close() error
Delete() error
Depth() int64
Empty() error
}
BackendQueue represents the behavior for the secondary message storage system
func NewDirectQueue ¶ added in v1.3.1
func NewDirectQueue(name string) BackendQueue
func NewDiskQueue ¶
func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64, minMsgSize int32, maxMsgSize int32, syncEveryWrite, syncEveryRead int64, syncTimeout time.Duration, writeLimit int, enableMemory bool, maxMemoryLength int) BackendQueue
newDiskQueue instantiates a new instance of diskQueue, retrieving metadata from the filesystem and starting the read ahead goroutine
Source Files
Click to show internal directories.
Click to hide internal directories.