consumer

Documentation

Overview

Package consumer is a generated GoMock package.

Index

• type Consumer
  • func New(opts Options) Consumer
• type Message
• type MessageBody
• type MockConsumer
  • func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
  • func (m *MockConsumer) DeleteMessage(messageReceipt *string) error
  • func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
  • func (m *MockConsumer) Run(ctx context.Context, chResponse chan Response)
• type MockConsumerMockRecorder
  • func (mr *MockConsumerMockRecorder) DeleteMessage(messageReceipt interface{}) *gomock.Call
  • func (mr *MockConsumerMockRecorder) Run(ctx, chResponse interface{}) *gomock.Call
• type Options
• type Response

Types

type Consumer

type Consumer interface {
	Run(ctx context.Context, chResponse chan Response)
	DeleteMessage(messageReceipt *string) error
}

func New

func New(opts Options) Consumer

type Message

type Message sqs.Message

type MessageBody

type MessageBody struct {
	Type           string `json:"Type"`
	TopicARN       string `json:"TopicArn"`
	Message        string `json:"Message"`
	MessageID      string `json:"MessageId"`
	Timestamp      string `json:"Timestamp"`
	UnsubscribeURL string `json:"UnsubscribeURL"`
}

type MockConsumer

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

MockConsumer is a mock of Consumer interface.

func NewMockConsumer

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance.

func (*MockConsumer) DeleteMessage

func (m *MockConsumer) DeleteMessage(messageReceipt *string) error

DeleteMessage mocks base method.

func (*MockConsumer) EXPECT

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumer) Run

func (m *MockConsumer) Run(ctx context.Context, chResponse chan Response)

Run mocks base method.

type MockConsumerMockRecorder

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

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) DeleteMessage

func (mr *MockConsumerMockRecorder) DeleteMessage(messageReceipt interface{}) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockConsumerMockRecorder) Run

func (mr *MockConsumerMockRecorder) Run(ctx, chResponse interface{}) *gomock.Call

Run indicates an expected call of Run.

type Options

type Options struct {
	QueueURL            *string
	MaxNumberOfMessages *int64
	Session             session.Session
	ReadMessageDelay    time.Duration
}

type Response

type Response struct {
	Error       error
	Message     *Message
	MessageBody *MessageBody
}