disk

Documentation

Index

• type Queue
  • func New(dataDir string, fileSize int) (*Queue, error)
  • func (q *Queue) Close() error
  • func (q *Queue) Put(data []byte) error
  • func (q *Queue) ReadChan() <-chan []byte

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue implements on-disk buffering queue

func New

func New(dataDir string, fileSize int) (*Queue, error)

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Put

func (q *Queue) Put(data []byte) error

func (*Queue) ReadChan

func (q *Queue) ReadChan() <-chan []byte