diskqueue

Documentation

Index

• Variables
• type DiskQueue
  • func NewDiskQueue(opts ...Option) (DiskQueue, error)
• type Option
  • func WithDataPath(dataPath string) Option
  • func WithMaxBytesPerFile(max int64) Option
  • func WithMaxMsgSize(size int32) Option
  • func WithMinMsgSize(size int32) Option
  • func WithName(name string) Option
  • func WithSyncEvery(count int64) Option
  • func WithSyncTimeout(timeout time.Duration) Option

Variables

var (
	ErrExited = errors.New("diskqueue has been exited")
)

Types

type DiskQueue

type DiskQueue interface {
	Len() int64
	Push([]byte) error
	Pop() chan []byte
	Clear() error
	Close() error
	DeleteAndExit() error
}

func NewDiskQueue

func NewDiskQueue(opts ...Option) (DiskQueue, error)

type Option

type Option func(*diskQueue)

func WithDataPath

func WithDataPath(dataPath string) Option

func WithMaxBytesPerFile

func WithMaxBytesPerFile(max int64) Option

func WithMaxMsgSize

func WithMaxMsgSize(size int32) Option

func WithMinMsgSize

func WithMinMsgSize(size int32) Option

func WithName

func WithName(name string) Option

func WithSyncEvery

func WithSyncEvery(count int64) Option

func WithSyncTimeout

func WithSyncTimeout(timeout time.Duration) Option