diskqueue

README

diskqueue

diskqueue forked from NSQ.io

Documentation

Index

• type DiskQueue
  • func New(opts Options) DiskQueue
• type Options

Types

type DiskQueue

type DiskQueue interface {
	Put([]byte) error
	ReadChan() chan []byte // this is expected to be an *unbuffered* channel
	Close() error
	Delete() error
	Depth() int64
	Empty() error
}

DiskQueue interface for disk queue

func New

func New(opts Options) DiskQueue

New instantiates an instance of diskQueue, retrieving metadata from the filesystem and starting the read ahead goroutine

type Options

type Options struct {
	Name            string
	DataPath        string
	MaxBytesPerFile int64
	MinMsgSize      int32
	MaxMsgSize      int32
	SyncEvery       int64
	SyncTimeout     time.Duration
	Logger          sugar.Logger
}

Options disk queue options