queue

Documentation

Index

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

Types

type BackendQueue

type BackendQueue interface {
	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,
	syncEvery int64, syncTimeout time.Duration, readBufferSize int) BackendQueue

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