mocks_sqs

Documentation

Index

• type Message
• type MockSqs
  • func NewMockSqs(opts *MockSqsOptions) *MockSqs
  • func (s *MockSqs) DeleteMessage(req *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
  • func (s *MockSqs) ListQueues(in *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)
  • func (s *MockSqs) ReceiveMessage(in *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
  • func (s *MockSqs) SendMessageBatch(in *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
• type MockSqsOptions

Types

type Message

type Message struct {
	Id            *string
	ReceiptHandle *string
	Body          *string
}

type MockSqs

type MockSqs struct {
	sqsiface.SQSAPI
	// contains filtered or unexported fields
}

func NewMockSqs

func NewMockSqs(opts *MockSqsOptions) *MockSqs

func (*MockSqs) DeleteMessage

func (s *MockSqs) DeleteMessage(req *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

func (*MockSqs) ListQueues

func (s *MockSqs) ListQueues(in *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)

func (*MockSqs) ReceiveMessage

func (s *MockSqs) ReceiveMessage(in *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func (*MockSqs) SendMessageBatch

func (s *MockSqs) SendMessageBatch(in *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

type MockSqsOptions

type MockSqsOptions struct {
	Queues        []string
	Messages      map[string][]*Message
	CompleteError error
}