diskqueue

Documentation

Index

• Variables
• type DiskQueue
  • func New(fpath string, options ...Option) (DiskQueue, error)
• type Option
  • func SetBucketByte(n int) Option
  • func SetDynamicMemBucket(n int) Option
  • func SetMaxBucket(n int) Option
  • func SetMemBucket(n int) Option

Variables

var ErrQueueFull = errors.New("error queue is full, can't create new membucket")

ErrQueueFull .

Types

type DiskQueue

type DiskQueue interface {
	Push(p []byte) error
	Pop() ([]byte, error)
	Close() error
}

DiskQueue disk queue

func New

func New(fpath string, options ...Option) (DiskQueue, error)

New Ringbuffer

type Option

type Option func(opt *option)

Option Ringbuffer option

func SetBucketByte

func SetBucketByte(n int) Option

SetBucketByte bucketbyte

func SetDynamicMemBucket

func SetDynamicMemBucket(n int) Option

SetDynamicMemBucket set the number of dynamic mem bucket

func SetMaxBucket

func SetMaxBucket(n int) Option

SetMaxBucket set the number of max bucket 0 represent unlimit

func SetMemBucket

func SetMemBucket(n int) Option

SetMemBucket set the number of mem bucket