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) VisibilityTimeout(ctx context.Context) int32
  • func (_m *Router) WorkerPoolSize(ctx context.Context) int32
• type SNSClient
  • func NewSNSClient(t interface{ ... }) *SNSClient
  • func (_m *SNSClient) Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
  • func (_m *SNSClient) PublishBatch(ctx context.Context, params *sns.PublishBatchInput, ...) (*sns.PublishBatchOutput, error)
• 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) VisibilityTimeout

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

VisibilityTimeout provides a mock function with given fields: ctx

func (*Router) WorkerPoolSize

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

WorkerPoolSize provides a mock function with given fields: ctx

type SNSClient

type SNSClient struct {
	mock.Mock
}

SNSClient is an autogenerated mock type for the SNSClient type

func NewSNSClient

func NewSNSClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *SNSClient

NewSNSClient creates a new instance of SNSClient. 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 (*SNSClient) Publish

func (_m *SNSClient) Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)

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

func (*SNSClient) PublishBatch

func (_m *SNSClient) PublishBatch(ctx context.Context, params *sns.PublishBatchInput, optFns ...func(*sns.Options)) (*sns.PublishBatchOutput, error)

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

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