mockqueue

Documentation

Index

• type MockQueue
  • func NewMockQueue() *MockQueue
  • func (mq *MockQueue) Close() error
  • func (mq *MockQueue) ConsumeMessages(ctx context.Context, handler pubsub.ConsumerMessageHandler, ...) error
  • func (mq *MockQueue) PutMessage(m pubsub.ProducerMessage) error
  • func (mq *MockQueue) Status() (*pubsub.Status, error)

Types

type MockQueue

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

MockQueue is intended for testing purposes. It provides a simple in-memory sink and source

func NewMockQueue

func NewMockQueue() *MockQueue

func (*MockQueue) Close

func (mq *MockQueue) Close() error

func (*MockQueue) ConsumeMessages

func (mq *MockQueue) ConsumeMessages(ctx context.Context, handler pubsub.ConsumerMessageHandler, onError pubsub.ConsumerErrorHandler) error

func (*MockQueue) PutMessage

func (mq *MockQueue) PutMessage(m pubsub.ProducerMessage) error

func (*MockQueue) Status

func (mq *MockQueue) Status() (*pubsub.Status, error)

Status reports the status of the queue