queue

Documentation

Index

• Constants
• func AtomicRename(sourceFile, targetFile string) error
• type BackendQueue
  • func NewDirectQueue(name string) BackendQueue
  • func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64, minMsgSize int32, ...) BackendQueue

Constants

const (
	StatusInit int32 = iota
	StatusClosed
)

const (
	FROM_NONE = iota
	FROM_DISK
	FROM_MEMORY
)

Functions

func AtomicRename

func AtomicRename(sourceFile, targetFile string) error

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

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