queuetesting

Documentation

Index

• func RunBenchmarkPush(b *testing.B, queue blobqueue.Queue)
• func RunTests(t *testing.T, queue blobqueue.Queue, shouldAlwaysFail bool)
• type Failing
  • func (q Failing) Empty() error
  • func (q Failing) Len() (int, error)
  • func (q Failing) List() ([][]byte, error)
  • func (q Failing) Pop() ([]byte, error)
  • func (q Failing) Push(val []byte) error
  • func (q Failing) Shift() ([]byte, error)
  • func (q Failing) Unshift(val []byte) error

Functions

func RunBenchmarkPush

func RunBenchmarkPush(b *testing.B, queue blobqueue.Queue)

func RunTests

func RunTests(t *testing.T, queue blobqueue.Queue, shouldAlwaysFail bool)

RunTests runs a list of predefined actions on a implementation of blobqueue.Queue. If you're dependant of an external data storage (redis, db, etc..) and you want to test client specific error (e.g. a wrong redis connection) you can set shouldAlwaysFail to true.

Types

type Failing

type Failing struct {
	blobqueue.Queue
	NextError error
}

Failing wraps a queue to mock errors returned by a blobqueue.Queue.

func (Failing) Empty

func (q Failing) Empty() error

Empty implements Queue interface.

func (Failing) Len

func (q Failing) Len() (int, error)

Len implements Queue interface.

func (Failing) List

func (q Failing) List() ([][]byte, error)

List implements Queue interface.

func (Failing) Pop

func (q Failing) Pop() ([]byte, error)

Pop implements Queue interface.

func (Failing) Push

func (q Failing) Push(val []byte) error

Push implements Queue interface.

func (Failing) Shift

func (q Failing) Shift() ([]byte, error)

Shift implements Queue interface.

func (Failing) Unshift

func (q Failing) Unshift(val []byte) error

Unshift implements Queue interface.