fake

Documentation

Index

• type Router
  • func NewRouter(t interface{ ... }) *Router
  • func (_m *Router) Commit(ctx context.Context, m loafergo.Message) error
  • func (_m *Router) Configure(ctx context.Context) error
  • func (_m *Router) GetMessages(ctx context.Context) ([]loafergo.Message, error)
  • func (_m *Router) HandlerMessage(ctx context.Context, msg loafergo.Message) error
  • func (_m *Router) WorkerPoolSize(ctx context.Context) int32
• type SQSClient
  • func NewSQSClient(t interface{ ... }) *SQSClient
  • func (_m *SQSClient) ChangeMessageVisibility(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, ...) (*sqs.ChangeMessageVisibilityOutput, error)
  • func (_m *SQSClient) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)
  • func (_m *SQSClient) GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)
  • func (_m *SQSClient) ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)

Types

type Router

type Router struct {
	mock.Mock
}

Router is an autogenerated mock type for the Router type

func NewRouter

func NewRouter(t interface {
	mock.TestingT
	Cleanup(func())
}) *Router

NewRouter creates a new instance of Router. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Router) Commit

func (_m *Router) Commit(ctx context.Context, m loafergo.Message) error

Commit provides a mock function with given fields: ctx, m

func (*Router) Configure

func (_m *Router) Configure(ctx context.Context) error

Configure provides a mock function with given fields: ctx

func (*Router) GetMessages

func (_m *Router) GetMessages(ctx context.Context) ([]loafergo.Message, error)

GetMessages provides a mock function with given fields: ctx

func (*Router) HandlerMessage

func (_m *Router) HandlerMessage(ctx context.Context, msg loafergo.Message) error

HandlerMessage provides a mock function with given fields: ctx, msg

func (*Router) WorkerPoolSize

func (_m *Router) WorkerPoolSize(ctx context.Context) int32

WorkerPoolSize provides a mock function with given fields: ctx

type SQSClient

type SQSClient struct {
	mock.Mock
}

SQSClient is an autogenerated mock type for the SQSClient type

func NewSQSClient

func NewSQSClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *SQSClient

NewSQSClient creates a new instance of SQSClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SQSClient) ChangeMessageVisibility

func (_m *SQSClient) ChangeMessageVisibility(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, optFns ...func(*sqs.Options)) (*sqs.ChangeMessageVisibilityOutput, error)

ChangeMessageVisibility provides a mock function with given fields: ctx, params, optFns

func (*SQSClient) DeleteMessage

func (_m *SQSClient) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)

DeleteMessage provides a mock function with given fields: ctx, params, optFns

func (*SQSClient) GetQueueUrl

func (_m *SQSClient) GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

GetQueueUrl provides a mock function with given fields: ctx, params, optFns

func (*SQSClient) ReceiveMessage

func (_m *SQSClient) ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)

ReceiveMessage provides a mock function with given fields: ctx, params, optFns