queue

Documentation

Index

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

Constants

const (
	StatusInit int32 = iota
	StatusClosed
)

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 NewDiskQueue

func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64,
	minMsgSize int32, maxMsgSize int32,
	syncEveryWrite, syncEveryRead int64, syncTimeout time.Duration, writeLimit int) BackendQueue

newDiskQueue instantiates a new instance of diskQueue, retrieving metadata from the filesystem and starting the read ahead goroutine

func NewMemoryQueue

func NewMemoryQueue(name string, maxQueueLength int) BackendQueue