queue

Documentation

Index

• type DiskQueue
  • func (module DiskQueue) Close(k string) error
  • func (module DiskQueue) Depth(k string) int64
  • func (module DiskQueue) GetQueues() []string
  • func (module DiskQueue) Name() string
  • func (module DiskQueue) Pop(k string, timeoutInSeconds time.Duration) ([]byte, error)
  • func (module DiskQueue) Push(k string, v []byte) error
  • func (module DiskQueue) ReadChan(k string) chan []byte
  • func (module DiskQueue) Setup(cfg *config.Config)
  • func (module DiskQueue) Start() error
  • 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) GetQueues

func (module DiskQueue) GetQueues() []string

func (DiskQueue) Name

func (module DiskQueue) Name() string

func (DiskQueue) Pop

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

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) Setup

func (module DiskQueue) Setup(cfg *config.Config)

func (DiskQueue) Start

func (module DiskQueue) Start() error

func (DiskQueue) Stop

func (module DiskQueue) Stop() error