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
• type DataQueue

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

type DataQueue

type DataQueue interface {
	// PutDatas 用于存放一组数据
	PutDatas([]Data) error
	// ReadDatasChan 用于获取直接读取 Data 的管道
	ReadDatasChan() <-chan []Data
}

DataQueue 代表了无需编解码可直接放取 Data 的队列