testqueue

Documentation

Overview

Package testqueue contains queue utilities for testing

Index

• type PassthroughQueue
  • func NewPassthroughQueue(t *testing.T) *PassthroughQueue
  • func (q *PassthroughQueue) Close() error
  • func (q *PassthroughQueue) GetQueue() <-chan *message.Message
  • func (q *PassthroughQueue) Pass(msg *message.Message) error

Types

type PassthroughQueue

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

PassthroughQueue is a queue that passes messages through. It's only useful for testing.

func NewPassthroughQueue

func NewPassthroughQueue(t *testing.T) *PassthroughQueue

NewPassthroughQueue creates a new PassthroughQueue

func (*PassthroughQueue) Close

func (q *PassthroughQueue) Close() error

Close frees closes the channel used as queue.

func (*PassthroughQueue) GetQueue

func (q *PassthroughQueue) GetQueue() <-chan *message.Message

GetQueue returns the queue

func (*PassthroughQueue) Pass

func (q *PassthroughQueue) Pass(msg *message.Message) error

Pass passes a message through the queue