queuestest

Documentation

Index

• type FakeQueueWriter
  • func (d *FakeQueueWriter) CreateQueue(context.Context, *persistence.CreateQueueRequest) (*persistence.CreateQueueResponse, error)
  • func (d *FakeQueueWriter) EnqueueTask(_ context.Context, request *persistence.EnqueueTaskRequest) (*persistence.EnqueueTaskResponse, error)

Types

type FakeQueueWriter

type FakeQueueWriter struct {
	EnqueueTaskRequests []*persistence.EnqueueTaskRequest
	EnqueueTaskErr      error
	CreateQueueErr      error
}

FakeQueueWriter is a queues.QueueWriter which records the requests it receives and returns the provided errors.

func (*FakeQueueWriter) CreateQueue

func (d *FakeQueueWriter) CreateQueue(
	context.Context,
	*persistence.CreateQueueRequest,
) (*persistence.CreateQueueResponse, error)

func (*FakeQueueWriter) EnqueueTask

func (d *FakeQueueWriter) EnqueueTask(
	_ context.Context,
	request *persistence.EnqueueTaskRequest,
) (*persistence.EnqueueTaskResponse, error)