testqueue

Documentation

Index

• type Queue
  • func New() *Queue
  • func (q *Queue) Close() error
  • func (q *Queue) Dequeue() (storage.Value, error)
  • func (q *Queue) Enqueue(value storage.Value) error
  • func (q *Queue) Peekqueue(limit int) ([]storage.Value, error)

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue is a threadsafe FIFO queue implementing storage.Queue

func New

func New() *Queue

New returns a queue suitable for testing

func (*Queue) Close

func (q *Queue) Close() error

Close closes the queue

func (*Queue) Dequeue

func (q *Queue) Dequeue() (storage.Value, error)

Dequeue removes a FIFO element

func (*Queue) Enqueue

func (q *Queue) Enqueue(value storage.Value) error

Enqueue add a FIFO element

func (*Queue) Peekqueue

func (q *Queue) Peekqueue(limit int) ([]storage.Value, error)

Peekqueue gets upto 'limit' entries from the list queue