queue

Documentation

Index

• type DiskQueue
  • func (module DiskQueue) Close(k string) error
  • func (module DiskQueue) Depth(k string) int64
  • func (module DiskQueue) Name() string
  • func (module DiskQueue) Pop(k string, timeoutInSeconds time.Duration) (error, []byte)
  • func (module DiskQueue) Push(k string, v []byte) error
  • func (module DiskQueue) ReadChan(k string) chan []byte
  • func (module DiskQueue) Start(cfg *Config)
  • func (module DiskQueue) Stop() error

Types

type DiskQueue

type DiskQueue struct {
}

func (DiskQueue) Close

func (module DiskQueue) Close(k string) error

func (DiskQueue) Depth

func (module DiskQueue) Depth(k string) int64

func (DiskQueue) Name

func (module DiskQueue) Name() string

func (DiskQueue) Pop

func (module DiskQueue) Pop(k string, timeoutInSeconds time.Duration) (error, []byte)

func (DiskQueue) Push

func (module DiskQueue) Push(k string, v []byte) error

func (DiskQueue) ReadChan

func (module DiskQueue) ReadChan(k string) chan []byte

func (DiskQueue) Start

func (module DiskQueue) Start(cfg *Config)

func (DiskQueue) Stop

func (module DiskQueue) Stop() error