fake

package

v0.0.0-...-692109b Latest Latest Go to latest Published: Jun 27, 2023 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/phogolabs/theta

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated by counterfeiter. DO NOT EDIT.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type FakeEventDecoder ¶

type FakeEventDecoder struct {
	DecodeStub func([]byte, interface{}) error
	// contains filtered or unexported fields
}

func (*FakeEventDecoder) Decode ¶

func (fake *FakeEventDecoder) Decode(arg1 []byte, arg2 interface{}) error

func (*FakeEventDecoder) DecodeArgsForCall ¶

func (fake *FakeEventDecoder) DecodeArgsForCall(i int) ([]byte, interface{})

func (*FakeEventDecoder) DecodeCallCount ¶

func (fake *FakeEventDecoder) DecodeCallCount() int

func (*FakeEventDecoder) DecodeCalls ¶

func (fake *FakeEventDecoder) DecodeCalls(stub func([]byte, interface{}) error)

func (*FakeEventDecoder) DecodeReturns ¶

func (fake *FakeEventDecoder) DecodeReturns(result1 error)

func (*FakeEventDecoder) DecodeReturnsOnCall ¶

func (fake *FakeEventDecoder) DecodeReturnsOnCall(i int, result1 error)

func (*FakeEventDecoder) Invocations ¶

func (fake *FakeEventDecoder) Invocations() map[string][][]interface{}

type FakeEventEncoder ¶

type FakeEventEncoder struct {
	EncodeStub func(interface{}) ([]byte, error)
	// contains filtered or unexported fields
}

func (*FakeEventEncoder) Encode ¶

func (fake *FakeEventEncoder) Encode(arg1 interface{}) ([]byte, error)

func (*FakeEventEncoder) EncodeArgsForCall ¶

func (fake *FakeEventEncoder) EncodeArgsForCall(i int) interface{}

func (*FakeEventEncoder) EncodeCallCount ¶

func (fake *FakeEventEncoder) EncodeCallCount() int

func (*FakeEventEncoder) EncodeCalls ¶

func (fake *FakeEventEncoder) EncodeCalls(stub func(interface{}) ([]byte, error))

func (*FakeEventEncoder) EncodeReturns ¶

func (fake *FakeEventEncoder) EncodeReturns(result1 []byte, result2 error)

func (*FakeEventEncoder) EncodeReturnsOnCall ¶

func (fake *FakeEventEncoder) EncodeReturnsOnCall(i int, result1 []byte, result2 error)

func (*FakeEventEncoder) Invocations ¶

func (fake *FakeEventEncoder) Invocations() map[string][][]interface{}

type FakeEventHandler ¶

type FakeEventHandler struct {
	HandleContextStub func(context.Context, *theta.EventArgs) error
	// contains filtered or unexported fields
}

func (*FakeEventHandler) HandleContext ¶

func (fake *FakeEventHandler) HandleContext(arg1 context.Context, arg2 *theta.EventArgs) error

func (*FakeEventHandler) HandleContextArgsForCall ¶

func (fake *FakeEventHandler) HandleContextArgsForCall(i int) (context.Context, *theta.EventArgs)

func (*FakeEventHandler) HandleContextCallCount ¶

func (fake *FakeEventHandler) HandleContextCallCount() int

func (*FakeEventHandler) HandleContextCalls ¶

func (fake *FakeEventHandler) HandleContextCalls(stub func(context.Context, *theta.EventArgs) error)

func (*FakeEventHandler) HandleContextReturns ¶

func (fake *FakeEventHandler) HandleContextReturns(result1 error)

func (*FakeEventHandler) HandleContextReturnsOnCall ¶

func (fake *FakeEventHandler) HandleContextReturnsOnCall(i int, result1 error)

func (*FakeEventHandler) Invocations ¶

func (fake *FakeEventHandler) Invocations() map[string][][]interface{}

type FakeKinesisClient ¶

type FakeKinesisClient struct {
	AddTagsToStreamStub func(*kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)

	AddTagsToStreamRequestStub func(*kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)

	AddTagsToStreamWithContextStub func(context.Context, *kinesis.AddTagsToStreamInput, ...request.Option) (*kinesis.AddTagsToStreamOutput, error)

	CreateStreamStub func(*kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

	CreateStreamRequestStub func(*kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)

	CreateStreamWithContextStub func(context.Context, *kinesis.CreateStreamInput, ...request.Option) (*kinesis.CreateStreamOutput, error)

	DecreaseStreamRetentionPeriodStub func(*kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

	DecreaseStreamRetentionPeriodRequestStub func(*kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)

	DecreaseStreamRetentionPeriodWithContextStub func(context.Context, *kinesis.DecreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

	DeleteStreamStub func(*kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)

	DeleteStreamRequestStub func(*kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)

	DeleteStreamWithContextStub func(context.Context, *kinesis.DeleteStreamInput, ...request.Option) (*kinesis.DeleteStreamOutput, error)

	DeregisterStreamConsumerStub func(*kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error)

	DeregisterStreamConsumerRequestStub func(*kinesis.DeregisterStreamConsumerInput) (*request.Request, *kinesis.DeregisterStreamConsumerOutput)

	DeregisterStreamConsumerWithContextStub func(context.Context, *kinesis.DeregisterStreamConsumerInput, ...request.Option) (*kinesis.DeregisterStreamConsumerOutput, error)

	DescribeLimitsStub func(*kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)

	DescribeLimitsRequestStub func(*kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)

	DescribeLimitsWithContextStub func(context.Context, *kinesis.DescribeLimitsInput, ...request.Option) (*kinesis.DescribeLimitsOutput, error)

	DescribeStreamStub func(*kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

	DescribeStreamConsumerStub func(*kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error)

	DescribeStreamConsumerRequestStub func(*kinesis.DescribeStreamConsumerInput) (*request.Request, *kinesis.DescribeStreamConsumerOutput)

	DescribeStreamConsumerWithContextStub func(context.Context, *kinesis.DescribeStreamConsumerInput, ...request.Option) (*kinesis.DescribeStreamConsumerOutput, error)

	DescribeStreamPagesStub func(*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool) error

	DescribeStreamPagesWithContextStub func(context.Context, *kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool, ...request.Option) error

	DescribeStreamRequestStub func(*kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)

	DescribeStreamSummaryStub func(*kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)

	DescribeStreamSummaryRequestStub func(*kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput)

	DescribeStreamSummaryWithContextStub func(context.Context, *kinesis.DescribeStreamSummaryInput, ...request.Option) (*kinesis.DescribeStreamSummaryOutput, error)

	DescribeStreamWithContextStub func(context.Context, *kinesis.DescribeStreamInput, ...request.Option) (*kinesis.DescribeStreamOutput, error)

	DisableEnhancedMonitoringStub func(*kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

	DisableEnhancedMonitoringRequestStub func(*kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

	DisableEnhancedMonitoringWithContextStub func(context.Context, *kinesis.DisableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

	EnableEnhancedMonitoringStub func(*kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

	EnableEnhancedMonitoringRequestStub func(*kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

	EnableEnhancedMonitoringWithContextStub func(context.Context, *kinesis.EnableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

	GetRecordsStub func(*kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

	GetRecordsRequestStub func(*kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)

	GetRecordsWithContextStub func(context.Context, *kinesis.GetRecordsInput, ...request.Option) (*kinesis.GetRecordsOutput, error)

	GetShardIteratorStub func(*kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)

	GetShardIteratorRequestStub func(*kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)

	GetShardIteratorWithContextStub func(context.Context, *kinesis.GetShardIteratorInput, ...request.Option) (*kinesis.GetShardIteratorOutput, error)

	IncreaseStreamRetentionPeriodStub func(*kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

	IncreaseStreamRetentionPeriodRequestStub func(*kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)

	IncreaseStreamRetentionPeriodWithContextStub func(context.Context, *kinesis.IncreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

	ListShardsStub func(*kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)

	ListShardsRequestStub func(*kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput)

	ListShardsWithContextStub func(context.Context, *kinesis.ListShardsInput, ...request.Option) (*kinesis.ListShardsOutput, error)

	ListStreamConsumersStub func(*kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error)

	ListStreamConsumersPagesStub func(*kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool) error

	ListStreamConsumersPagesWithContextStub func(context.Context, *kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool, ...request.Option) error

	ListStreamConsumersRequestStub func(*kinesis.ListStreamConsumersInput) (*request.Request, *kinesis.ListStreamConsumersOutput)

	ListStreamConsumersWithContextStub func(context.Context, *kinesis.ListStreamConsumersInput, ...request.Option) (*kinesis.ListStreamConsumersOutput, error)

	ListStreamsStub func(*kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

	ListStreamsPagesStub func(*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool) error

	ListStreamsPagesWithContextStub func(context.Context, *kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool, ...request.Option) error

	ListStreamsRequestStub func(*kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)

	ListStreamsWithContextStub func(context.Context, *kinesis.ListStreamsInput, ...request.Option) (*kinesis.ListStreamsOutput, error)

	ListTagsForStreamStub func(*kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)

	ListTagsForStreamRequestStub func(*kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)

	ListTagsForStreamWithContextStub func(context.Context, *kinesis.ListTagsForStreamInput, ...request.Option) (*kinesis.ListTagsForStreamOutput, error)

	MergeShardsStub func(*kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)

	MergeShardsRequestStub func(*kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)

	MergeShardsWithContextStub func(context.Context, *kinesis.MergeShardsInput, ...request.Option) (*kinesis.MergeShardsOutput, error)

	PutRecordStub func(*kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

	PutRecordRequestStub func(*kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)

	PutRecordWithContextStub func(context.Context, *kinesis.PutRecordInput, ...request.Option) (*kinesis.PutRecordOutput, error)

	PutRecordsStub func(*kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

	PutRecordsRequestStub func(*kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)

	PutRecordsWithContextStub func(context.Context, *kinesis.PutRecordsInput, ...request.Option) (*kinesis.PutRecordsOutput, error)

	RegisterStreamConsumerStub func(*kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error)

	RegisterStreamConsumerRequestStub func(*kinesis.RegisterStreamConsumerInput) (*request.Request, *kinesis.RegisterStreamConsumerOutput)

	RegisterStreamConsumerWithContextStub func(context.Context, *kinesis.RegisterStreamConsumerInput, ...request.Option) (*kinesis.RegisterStreamConsumerOutput, error)

	RemoveTagsFromStreamStub func(*kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)

	RemoveTagsFromStreamRequestStub func(*kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)

	RemoveTagsFromStreamWithContextStub func(context.Context, *kinesis.RemoveTagsFromStreamInput, ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error)

	SplitShardStub func(*kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)

	SplitShardRequestStub func(*kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)

	SplitShardWithContextStub func(context.Context, *kinesis.SplitShardInput, ...request.Option) (*kinesis.SplitShardOutput, error)

	StartStreamEncryptionStub func(*kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)

	StartStreamEncryptionRequestStub func(*kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)

	StartStreamEncryptionWithContextStub func(context.Context, *kinesis.StartStreamEncryptionInput, ...request.Option) (*kinesis.StartStreamEncryptionOutput, error)

	StopStreamEncryptionStub func(*kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)

	StopStreamEncryptionRequestStub func(*kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)

	StopStreamEncryptionWithContextStub func(context.Context, *kinesis.StopStreamEncryptionInput, ...request.Option) (*kinesis.StopStreamEncryptionOutput, error)

	SubscribeToShardStub func(*kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)

	SubscribeToShardRequestStub func(*kinesis.SubscribeToShardInput) (*request.Request, *kinesis.SubscribeToShardOutput)

	SubscribeToShardWithContextStub func(context.Context, *kinesis.SubscribeToShardInput, ...request.Option) (*kinesis.SubscribeToShardOutput, error)

	UpdateShardCountStub func(*kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)

	UpdateShardCountRequestStub func(*kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)

	UpdateShardCountWithContextStub func(context.Context, *kinesis.UpdateShardCountInput, ...request.Option) (*kinesis.UpdateShardCountOutput, error)

	UpdateStreamModeStub func(*kinesis.UpdateStreamModeInput) (*kinesis.UpdateStreamModeOutput, error)

	UpdateStreamModeRequestStub func(*kinesis.UpdateStreamModeInput) (*request.Request, *kinesis.UpdateStreamModeOutput)

	UpdateStreamModeWithContextStub func(context.Context, *kinesis.UpdateStreamModeInput, ...request.Option) (*kinesis.UpdateStreamModeOutput, error)

	WaitUntilStreamExistsStub func(*kinesis.DescribeStreamInput) error

	WaitUntilStreamExistsWithContextStub func(context.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error

	WaitUntilStreamNotExistsStub func(*kinesis.DescribeStreamInput) error

	WaitUntilStreamNotExistsWithContextStub func(context.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error
	// contains filtered or unexported fields
}

func (*FakeKinesisClient) AddTagsToStream ¶

func (fake *FakeKinesisClient) AddTagsToStream(arg1 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)

func (*FakeKinesisClient) AddTagsToStreamArgsForCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamArgsForCall(i int) *kinesis.AddTagsToStreamInput

func (*FakeKinesisClient) AddTagsToStreamCallCount ¶

func (fake *FakeKinesisClient) AddTagsToStreamCallCount() int

func (*FakeKinesisClient) AddTagsToStreamCalls ¶

func (fake *FakeKinesisClient) AddTagsToStreamCalls(stub func(*kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error))

func (*FakeKinesisClient) AddTagsToStreamRequest ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequest(arg1 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)

func (*FakeKinesisClient) AddTagsToStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequestArgsForCall(i int) *kinesis.AddTagsToStreamInput

func (*FakeKinesisClient) AddTagsToStreamRequestCallCount ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequestCallCount() int

func (*FakeKinesisClient) AddTagsToStreamRequestCalls ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequestCalls(stub func(*kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput))

func (*FakeKinesisClient) AddTagsToStreamRequestReturns ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequestReturns(result1 *request.Request, result2 *kinesis.AddTagsToStreamOutput)

func (*FakeKinesisClient) AddTagsToStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.AddTagsToStreamOutput)

func (*FakeKinesisClient) AddTagsToStreamReturns ¶

func (fake *FakeKinesisClient) AddTagsToStreamReturns(result1 *kinesis.AddTagsToStreamOutput, result2 error)

func (*FakeKinesisClient) AddTagsToStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamReturnsOnCall(i int, result1 *kinesis.AddTagsToStreamOutput, result2 error)

func (*FakeKinesisClient) AddTagsToStreamWithContext ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContext(arg1 context.Context, arg2 *kinesis.AddTagsToStreamInput, arg3 ...request.Option) (*kinesis.AddTagsToStreamOutput, error)

func (*FakeKinesisClient) AddTagsToStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContextArgsForCall(i int) (context.Context, *kinesis.AddTagsToStreamInput, []request.Option)

func (*FakeKinesisClient) AddTagsToStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContextCallCount() int

func (*FakeKinesisClient) AddTagsToStreamWithContextCalls ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContextCalls(stub func(context.Context, *kinesis.AddTagsToStreamInput, ...request.Option) (*kinesis.AddTagsToStreamOutput, error))

func (*FakeKinesisClient) AddTagsToStreamWithContextReturns ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContextReturns(result1 *kinesis.AddTagsToStreamOutput, result2 error)

func (*FakeKinesisClient) AddTagsToStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) AddTagsToStreamWithContextReturnsOnCall(i int, result1 *kinesis.AddTagsToStreamOutput, result2 error)

func (*FakeKinesisClient) CreateStream ¶

func (fake *FakeKinesisClient) CreateStream(arg1 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

func (*FakeKinesisClient) CreateStreamArgsForCall ¶

func (fake *FakeKinesisClient) CreateStreamArgsForCall(i int) *kinesis.CreateStreamInput

func (*FakeKinesisClient) CreateStreamCallCount ¶

func (fake *FakeKinesisClient) CreateStreamCallCount() int

func (*FakeKinesisClient) CreateStreamCalls ¶

func (fake *FakeKinesisClient) CreateStreamCalls(stub func(*kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error))

func (*FakeKinesisClient) CreateStreamRequest ¶

func (fake *FakeKinesisClient) CreateStreamRequest(arg1 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)

func (*FakeKinesisClient) CreateStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) CreateStreamRequestArgsForCall(i int) *kinesis.CreateStreamInput

func (*FakeKinesisClient) CreateStreamRequestCallCount ¶

func (fake *FakeKinesisClient) CreateStreamRequestCallCount() int

func (*FakeKinesisClient) CreateStreamRequestCalls ¶

func (fake *FakeKinesisClient) CreateStreamRequestCalls(stub func(*kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput))

func (*FakeKinesisClient) CreateStreamRequestReturns ¶

func (fake *FakeKinesisClient) CreateStreamRequestReturns(result1 *request.Request, result2 *kinesis.CreateStreamOutput)

func (*FakeKinesisClient) CreateStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) CreateStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.CreateStreamOutput)

func (*FakeKinesisClient) CreateStreamReturns ¶

func (fake *FakeKinesisClient) CreateStreamReturns(result1 *kinesis.CreateStreamOutput, result2 error)

func (*FakeKinesisClient) CreateStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) CreateStreamReturnsOnCall(i int, result1 *kinesis.CreateStreamOutput, result2 error)

func (*FakeKinesisClient) CreateStreamWithContext ¶

func (fake *FakeKinesisClient) CreateStreamWithContext(arg1 context.Context, arg2 *kinesis.CreateStreamInput, arg3 ...request.Option) (*kinesis.CreateStreamOutput, error)

func (*FakeKinesisClient) CreateStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) CreateStreamWithContextArgsForCall(i int) (context.Context, *kinesis.CreateStreamInput, []request.Option)

func (*FakeKinesisClient) CreateStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) CreateStreamWithContextCallCount() int

func (*FakeKinesisClient) CreateStreamWithContextCalls ¶

func (fake *FakeKinesisClient) CreateStreamWithContextCalls(stub func(context.Context, *kinesis.CreateStreamInput, ...request.Option) (*kinesis.CreateStreamOutput, error))

func (*FakeKinesisClient) CreateStreamWithContextReturns ¶

func (fake *FakeKinesisClient) CreateStreamWithContextReturns(result1 *kinesis.CreateStreamOutput, result2 error)

func (*FakeKinesisClient) CreateStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) CreateStreamWithContextReturnsOnCall(i int, result1 *kinesis.CreateStreamOutput, result2 error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriod ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriod(arg1 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodArgsForCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodArgsForCall(i int) *kinesis.DecreaseStreamRetentionPeriodInput

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodCallCount ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodCallCount() int

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodCalls ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodCalls(stub func(*kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error))

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequest ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequest(arg1 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequestArgsForCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequestArgsForCall(i int) *kinesis.DecreaseStreamRetentionPeriodInput

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequestCallCount ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequestCallCount() int

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequestCalls ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequestCalls(stub func(*kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput))

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequestReturns ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequestReturns(result1 *request.Request, result2 *kinesis.DecreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DecreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodReturns ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodReturns(result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodReturnsOnCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodReturnsOnCall(i int, result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContext ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContext(arg1 context.Context, arg2 *kinesis.DecreaseStreamRetentionPeriodInput, arg3 ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextArgsForCall(i int) (context.Context, *kinesis.DecreaseStreamRetentionPeriodInput, []request.Option)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextCallCount ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextCallCount() int

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextCalls ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextCalls(stub func(context.Context, *kinesis.DecreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error))

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextReturns ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextReturns(result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DecreaseStreamRetentionPeriodWithContextReturnsOnCall(i int, result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) DeleteStream ¶

func (fake *FakeKinesisClient) DeleteStream(arg1 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)

func (*FakeKinesisClient) DeleteStreamArgsForCall ¶

func (fake *FakeKinesisClient) DeleteStreamArgsForCall(i int) *kinesis.DeleteStreamInput

func (*FakeKinesisClient) DeleteStreamCallCount ¶

func (fake *FakeKinesisClient) DeleteStreamCallCount() int

func (*FakeKinesisClient) DeleteStreamCalls ¶

func (fake *FakeKinesisClient) DeleteStreamCalls(stub func(*kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error))

func (*FakeKinesisClient) DeleteStreamRequest ¶

func (fake *FakeKinesisClient) DeleteStreamRequest(arg1 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)

func (*FakeKinesisClient) DeleteStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) DeleteStreamRequestArgsForCall(i int) *kinesis.DeleteStreamInput

func (*FakeKinesisClient) DeleteStreamRequestCallCount ¶

func (fake *FakeKinesisClient) DeleteStreamRequestCallCount() int

func (*FakeKinesisClient) DeleteStreamRequestCalls ¶

func (fake *FakeKinesisClient) DeleteStreamRequestCalls(stub func(*kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput))

func (*FakeKinesisClient) DeleteStreamRequestReturns ¶

func (fake *FakeKinesisClient) DeleteStreamRequestReturns(result1 *request.Request, result2 *kinesis.DeleteStreamOutput)

func (*FakeKinesisClient) DeleteStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DeleteStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DeleteStreamOutput)

func (*FakeKinesisClient) DeleteStreamReturns ¶

func (fake *FakeKinesisClient) DeleteStreamReturns(result1 *kinesis.DeleteStreamOutput, result2 error)

func (*FakeKinesisClient) DeleteStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) DeleteStreamReturnsOnCall(i int, result1 *kinesis.DeleteStreamOutput, result2 error)

func (*FakeKinesisClient) DeleteStreamWithContext ¶

func (fake *FakeKinesisClient) DeleteStreamWithContext(arg1 context.Context, arg2 *kinesis.DeleteStreamInput, arg3 ...request.Option) (*kinesis.DeleteStreamOutput, error)

func (*FakeKinesisClient) DeleteStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DeleteStreamWithContextArgsForCall(i int) (context.Context, *kinesis.DeleteStreamInput, []request.Option)

func (*FakeKinesisClient) DeleteStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) DeleteStreamWithContextCallCount() int

func (*FakeKinesisClient) DeleteStreamWithContextCalls ¶

func (fake *FakeKinesisClient) DeleteStreamWithContextCalls(stub func(context.Context, *kinesis.DeleteStreamInput, ...request.Option) (*kinesis.DeleteStreamOutput, error))

func (*FakeKinesisClient) DeleteStreamWithContextReturns ¶

func (fake *FakeKinesisClient) DeleteStreamWithContextReturns(result1 *kinesis.DeleteStreamOutput, result2 error)

func (*FakeKinesisClient) DeleteStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DeleteStreamWithContextReturnsOnCall(i int, result1 *kinesis.DeleteStreamOutput, result2 error)

func (*FakeKinesisClient) DeregisterStreamConsumer ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumer(arg1 *kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error)

func (*FakeKinesisClient) DeregisterStreamConsumerArgsForCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerArgsForCall(i int) *kinesis.DeregisterStreamConsumerInput

func (*FakeKinesisClient) DeregisterStreamConsumerCallCount ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerCallCount() int

func (*FakeKinesisClient) DeregisterStreamConsumerCalls ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerCalls(stub func(*kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error))

func (*FakeKinesisClient) DeregisterStreamConsumerRequest ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequest(arg1 *kinesis.DeregisterStreamConsumerInput) (*request.Request, *kinesis.DeregisterStreamConsumerOutput)

func (*FakeKinesisClient) DeregisterStreamConsumerRequestArgsForCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequestArgsForCall(i int) *kinesis.DeregisterStreamConsumerInput

func (*FakeKinesisClient) DeregisterStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequestCallCount() int

func (*FakeKinesisClient) DeregisterStreamConsumerRequestCalls ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequestCalls(stub func(*kinesis.DeregisterStreamConsumerInput) (*request.Request, *kinesis.DeregisterStreamConsumerOutput))

func (*FakeKinesisClient) DeregisterStreamConsumerRequestReturns ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.DeregisterStreamConsumerOutput)

func (*FakeKinesisClient) DeregisterStreamConsumerRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DeregisterStreamConsumerOutput)

func (*FakeKinesisClient) DeregisterStreamConsumerReturns ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerReturns(result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DeregisterStreamConsumerReturnsOnCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerReturnsOnCall(i int, result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DeregisterStreamConsumerWithContext ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.DeregisterStreamConsumerInput, arg3 ...request.Option) (*kinesis.DeregisterStreamConsumerOutput, error)

func (*FakeKinesisClient) DeregisterStreamConsumerWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.DeregisterStreamConsumerInput, []request.Option)

func (*FakeKinesisClient) DeregisterStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContextCallCount() int

func (*FakeKinesisClient) DeregisterStreamConsumerWithContextCalls ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContextCalls(stub func(context.Context, *kinesis.DeregisterStreamConsumerInput, ...request.Option) (*kinesis.DeregisterStreamConsumerOutput, error))

func (*FakeKinesisClient) DeregisterStreamConsumerWithContextReturns ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContextReturns(result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DeregisterStreamConsumerWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DeregisterStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DescribeLimits ¶

func (fake *FakeKinesisClient) DescribeLimits(arg1 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)

func (*FakeKinesisClient) DescribeLimitsArgsForCall ¶

func (fake *FakeKinesisClient) DescribeLimitsArgsForCall(i int) *kinesis.DescribeLimitsInput

func (*FakeKinesisClient) DescribeLimitsCallCount ¶

func (fake *FakeKinesisClient) DescribeLimitsCallCount() int

func (*FakeKinesisClient) DescribeLimitsCalls ¶

func (fake *FakeKinesisClient) DescribeLimitsCalls(stub func(*kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error))

func (*FakeKinesisClient) DescribeLimitsRequest ¶

func (fake *FakeKinesisClient) DescribeLimitsRequest(arg1 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)

func (*FakeKinesisClient) DescribeLimitsRequestArgsForCall ¶

func (fake *FakeKinesisClient) DescribeLimitsRequestArgsForCall(i int) *kinesis.DescribeLimitsInput

func (*FakeKinesisClient) DescribeLimitsRequestCallCount ¶

func (fake *FakeKinesisClient) DescribeLimitsRequestCallCount() int

func (*FakeKinesisClient) DescribeLimitsRequestCalls ¶

func (fake *FakeKinesisClient) DescribeLimitsRequestCalls(stub func(*kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput))

func (*FakeKinesisClient) DescribeLimitsRequestReturns ¶

func (fake *FakeKinesisClient) DescribeLimitsRequestReturns(result1 *request.Request, result2 *kinesis.DescribeLimitsOutput)

func (*FakeKinesisClient) DescribeLimitsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeLimitsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeLimitsOutput)

func (*FakeKinesisClient) DescribeLimitsReturns ¶

func (fake *FakeKinesisClient) DescribeLimitsReturns(result1 *kinesis.DescribeLimitsOutput, result2 error)

func (*FakeKinesisClient) DescribeLimitsReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeLimitsReturnsOnCall(i int, result1 *kinesis.DescribeLimitsOutput, result2 error)

func (*FakeKinesisClient) DescribeLimitsWithContext ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContext(arg1 context.Context, arg2 *kinesis.DescribeLimitsInput, arg3 ...request.Option) (*kinesis.DescribeLimitsOutput, error)

func (*FakeKinesisClient) DescribeLimitsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeLimitsInput, []request.Option)

func (*FakeKinesisClient) DescribeLimitsWithContextCallCount ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContextCallCount() int

func (*FakeKinesisClient) DescribeLimitsWithContextCalls ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContextCalls(stub func(context.Context, *kinesis.DescribeLimitsInput, ...request.Option) (*kinesis.DescribeLimitsOutput, error))

func (*FakeKinesisClient) DescribeLimitsWithContextReturns ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContextReturns(result1 *kinesis.DescribeLimitsOutput, result2 error)

func (*FakeKinesisClient) DescribeLimitsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeLimitsWithContextReturnsOnCall(i int, result1 *kinesis.DescribeLimitsOutput, result2 error)

func (*FakeKinesisClient) DescribeStream ¶

func (fake *FakeKinesisClient) DescribeStream(arg1 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

func (*FakeKinesisClient) DescribeStreamArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamArgsForCall(i int) *kinesis.DescribeStreamInput

func (*FakeKinesisClient) DescribeStreamCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamCallCount() int

func (*FakeKinesisClient) DescribeStreamCalls ¶

func (fake *FakeKinesisClient) DescribeStreamCalls(stub func(*kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error))

func (*FakeKinesisClient) DescribeStreamConsumer ¶

func (fake *FakeKinesisClient) DescribeStreamConsumer(arg1 *kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error)

func (*FakeKinesisClient) DescribeStreamConsumerArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerArgsForCall(i int) *kinesis.DescribeStreamConsumerInput

func (*FakeKinesisClient) DescribeStreamConsumerCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerCallCount() int

func (*FakeKinesisClient) DescribeStreamConsumerCalls ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerCalls(stub func(*kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error))

func (*FakeKinesisClient) DescribeStreamConsumerRequest ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequest(arg1 *kinesis.DescribeStreamConsumerInput) (*request.Request, *kinesis.DescribeStreamConsumerOutput)

func (*FakeKinesisClient) DescribeStreamConsumerRequestArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequestArgsForCall(i int) *kinesis.DescribeStreamConsumerInput

func (*FakeKinesisClient) DescribeStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequestCallCount() int

func (*FakeKinesisClient) DescribeStreamConsumerRequestCalls ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequestCalls(stub func(*kinesis.DescribeStreamConsumerInput) (*request.Request, *kinesis.DescribeStreamConsumerOutput))

func (*FakeKinesisClient) DescribeStreamConsumerRequestReturns ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamConsumerOutput)

func (*FakeKinesisClient) DescribeStreamConsumerRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamConsumerOutput)

func (*FakeKinesisClient) DescribeStreamConsumerReturns ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerReturns(result1 *kinesis.DescribeStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamConsumerReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerReturnsOnCall(i int, result1 *kinesis.DescribeStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamConsumerWithContext ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamConsumerInput, arg3 ...request.Option) (*kinesis.DescribeStreamConsumerOutput, error)

func (*FakeKinesisClient) DescribeStreamConsumerWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamConsumerInput, []request.Option)

func (*FakeKinesisClient) DescribeStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContextCallCount() int

func (*FakeKinesisClient) DescribeStreamConsumerWithContextCalls ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamConsumerInput, ...request.Option) (*kinesis.DescribeStreamConsumerOutput, error))

func (*FakeKinesisClient) DescribeStreamConsumerWithContextReturns ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContextReturns(result1 *kinesis.DescribeStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamConsumerWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamPages ¶

func (fake *FakeKinesisClient) DescribeStreamPages(arg1 *kinesis.DescribeStreamInput, arg2 func(*kinesis.DescribeStreamOutput, bool) bool) error

func (*FakeKinesisClient) DescribeStreamPagesArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamPagesArgsForCall(i int) (*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool)

func (*FakeKinesisClient) DescribeStreamPagesCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamPagesCallCount() int

func (*FakeKinesisClient) DescribeStreamPagesCalls ¶

func (fake *FakeKinesisClient) DescribeStreamPagesCalls(stub func(*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool) error)

func (*FakeKinesisClient) DescribeStreamPagesReturns ¶

func (fake *FakeKinesisClient) DescribeStreamPagesReturns(result1 error)

func (*FakeKinesisClient) DescribeStreamPagesReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamPagesReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) DescribeStreamPagesWithContext ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, arg3 func(*kinesis.DescribeStreamOutput, bool) bool, arg4 ...request.Option) error

func (*FakeKinesisClient) DescribeStreamPagesWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool, []request.Option)

func (*FakeKinesisClient) DescribeStreamPagesWithContextCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContextCallCount() int

func (*FakeKinesisClient) DescribeStreamPagesWithContextCalls ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool, ...request.Option) error)

func (*FakeKinesisClient) DescribeStreamPagesWithContextReturns ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContextReturns(result1 error)

func (*FakeKinesisClient) DescribeStreamPagesWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamPagesWithContextReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) DescribeStreamRequest ¶

func (fake *FakeKinesisClient) DescribeStreamRequest(arg1 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)

func (*FakeKinesisClient) DescribeStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamRequestArgsForCall(i int) *kinesis.DescribeStreamInput

func (*FakeKinesisClient) DescribeStreamRequestCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamRequestCallCount() int

func (*FakeKinesisClient) DescribeStreamRequestCalls ¶

func (fake *FakeKinesisClient) DescribeStreamRequestCalls(stub func(*kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput))

func (*FakeKinesisClient) DescribeStreamRequestReturns ¶

func (fake *FakeKinesisClient) DescribeStreamRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamOutput)

func (*FakeKinesisClient) DescribeStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamOutput)

func (*FakeKinesisClient) DescribeStreamReturns ¶

func (fake *FakeKinesisClient) DescribeStreamReturns(result1 *kinesis.DescribeStreamOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamReturnsOnCall(i int, result1 *kinesis.DescribeStreamOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamSummary ¶

func (fake *FakeKinesisClient) DescribeStreamSummary(arg1 *kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)

func (*FakeKinesisClient) DescribeStreamSummaryArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryArgsForCall(i int) *kinesis.DescribeStreamSummaryInput

func (*FakeKinesisClient) DescribeStreamSummaryCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryCallCount() int

func (*FakeKinesisClient) DescribeStreamSummaryCalls ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryCalls(stub func(*kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error))

func (*FakeKinesisClient) DescribeStreamSummaryRequest ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequest(arg1 *kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput)

func (*FakeKinesisClient) DescribeStreamSummaryRequestArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequestArgsForCall(i int) *kinesis.DescribeStreamSummaryInput

func (*FakeKinesisClient) DescribeStreamSummaryRequestCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequestCallCount() int

func (*FakeKinesisClient) DescribeStreamSummaryRequestCalls ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequestCalls(stub func(*kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput))

func (*FakeKinesisClient) DescribeStreamSummaryRequestReturns ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamSummaryOutput)

func (*FakeKinesisClient) DescribeStreamSummaryRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamSummaryOutput)

func (*FakeKinesisClient) DescribeStreamSummaryReturns ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryReturns(result1 *kinesis.DescribeStreamSummaryOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamSummaryReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryReturnsOnCall(i int, result1 *kinesis.DescribeStreamSummaryOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamSummaryWithContext ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamSummaryInput, arg3 ...request.Option) (*kinesis.DescribeStreamSummaryOutput, error)

func (*FakeKinesisClient) DescribeStreamSummaryWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamSummaryInput, []request.Option)

func (*FakeKinesisClient) DescribeStreamSummaryWithContextCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContextCallCount() int

func (*FakeKinesisClient) DescribeStreamSummaryWithContextCalls ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamSummaryInput, ...request.Option) (*kinesis.DescribeStreamSummaryOutput, error))

func (*FakeKinesisClient) DescribeStreamSummaryWithContextReturns ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContextReturns(result1 *kinesis.DescribeStreamSummaryOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamSummaryWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamSummaryWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamSummaryOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamWithContext ¶

func (fake *FakeKinesisClient) DescribeStreamWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, arg3 ...request.Option) (*kinesis.DescribeStreamOutput, error)

func (*FakeKinesisClient) DescribeStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DescribeStreamWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.Option)

func (*FakeKinesisClient) DescribeStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) DescribeStreamWithContextCallCount() int

func (*FakeKinesisClient) DescribeStreamWithContextCalls ¶

func (fake *FakeKinesisClient) DescribeStreamWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamInput, ...request.Option) (*kinesis.DescribeStreamOutput, error))

func (*FakeKinesisClient) DescribeStreamWithContextReturns ¶

func (fake *FakeKinesisClient) DescribeStreamWithContextReturns(result1 *kinesis.DescribeStreamOutput, result2 error)

func (*FakeKinesisClient) DescribeStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DescribeStreamWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamOutput, result2 error)

func (*FakeKinesisClient) DisableEnhancedMonitoring ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoring(arg1 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

func (*FakeKinesisClient) DisableEnhancedMonitoringArgsForCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringArgsForCall(i int) *kinesis.DisableEnhancedMonitoringInput

func (*FakeKinesisClient) DisableEnhancedMonitoringCallCount ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringCallCount() int

func (*FakeKinesisClient) DisableEnhancedMonitoringCalls ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringCalls(stub func(*kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error))

func (*FakeKinesisClient) DisableEnhancedMonitoringRequest ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequest(arg1 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) DisableEnhancedMonitoringRequestArgsForCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequestArgsForCall(i int) *kinesis.DisableEnhancedMonitoringInput

func (*FakeKinesisClient) DisableEnhancedMonitoringRequestCallCount ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequestCallCount() int

func (*FakeKinesisClient) DisableEnhancedMonitoringRequestCalls ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequestCalls(stub func(*kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput))

func (*FakeKinesisClient) DisableEnhancedMonitoringRequestReturns ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequestReturns(result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) DisableEnhancedMonitoringRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) DisableEnhancedMonitoringReturns ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) DisableEnhancedMonitoringReturnsOnCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContext ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContext(arg1 context.Context, arg2 *kinesis.DisableEnhancedMonitoringInput, arg3 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContextArgsForCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContextArgsForCall(i int) (context.Context, *kinesis.DisableEnhancedMonitoringInput, []request.Option)

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContextCallCount ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContextCallCount() int

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContextCalls ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContextCalls(stub func(context.Context, *kinesis.DisableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error))

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContextReturns ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContextReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) DisableEnhancedMonitoringWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) DisableEnhancedMonitoringWithContextReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) EnableEnhancedMonitoring ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoring(arg1 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

func (*FakeKinesisClient) EnableEnhancedMonitoringArgsForCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringArgsForCall(i int) *kinesis.EnableEnhancedMonitoringInput

func (*FakeKinesisClient) EnableEnhancedMonitoringCallCount ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringCallCount() int

func (*FakeKinesisClient) EnableEnhancedMonitoringCalls ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringCalls(stub func(*kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error))

func (*FakeKinesisClient) EnableEnhancedMonitoringRequest ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequest(arg1 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) EnableEnhancedMonitoringRequestArgsForCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequestArgsForCall(i int) *kinesis.EnableEnhancedMonitoringInput

func (*FakeKinesisClient) EnableEnhancedMonitoringRequestCallCount ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequestCallCount() int

func (*FakeKinesisClient) EnableEnhancedMonitoringRequestCalls ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequestCalls(stub func(*kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput))

func (*FakeKinesisClient) EnableEnhancedMonitoringRequestReturns ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequestReturns(result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) EnableEnhancedMonitoringRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)

func (*FakeKinesisClient) EnableEnhancedMonitoringReturns ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) EnableEnhancedMonitoringReturnsOnCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContext ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContext(arg1 context.Context, arg2 *kinesis.EnableEnhancedMonitoringInput, arg3 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContextArgsForCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContextArgsForCall(i int) (context.Context, *kinesis.EnableEnhancedMonitoringInput, []request.Option)

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContextCallCount ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContextCallCount() int

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContextCalls ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContextCalls(stub func(context.Context, *kinesis.EnableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error))

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContextReturns ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContextReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) EnableEnhancedMonitoringWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) EnableEnhancedMonitoringWithContextReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)

func (*FakeKinesisClient) GetRecords ¶

func (fake *FakeKinesisClient) GetRecords(arg1 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

func (*FakeKinesisClient) GetRecordsArgsForCall ¶

func (fake *FakeKinesisClient) GetRecordsArgsForCall(i int) *kinesis.GetRecordsInput

func (*FakeKinesisClient) GetRecordsCallCount ¶

func (fake *FakeKinesisClient) GetRecordsCallCount() int

func (*FakeKinesisClient) GetRecordsCalls ¶

func (fake *FakeKinesisClient) GetRecordsCalls(stub func(*kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error))

func (*FakeKinesisClient) GetRecordsRequest ¶

func (fake *FakeKinesisClient) GetRecordsRequest(arg1 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)

func (*FakeKinesisClient) GetRecordsRequestArgsForCall ¶

func (fake *FakeKinesisClient) GetRecordsRequestArgsForCall(i int) *kinesis.GetRecordsInput

func (*FakeKinesisClient) GetRecordsRequestCallCount ¶

func (fake *FakeKinesisClient) GetRecordsRequestCallCount() int

func (*FakeKinesisClient) GetRecordsRequestCalls ¶

func (fake *FakeKinesisClient) GetRecordsRequestCalls(stub func(*kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput))

func (*FakeKinesisClient) GetRecordsRequestReturns ¶

func (fake *FakeKinesisClient) GetRecordsRequestReturns(result1 *request.Request, result2 *kinesis.GetRecordsOutput)

func (*FakeKinesisClient) GetRecordsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) GetRecordsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.GetRecordsOutput)

func (*FakeKinesisClient) GetRecordsReturns ¶

func (fake *FakeKinesisClient) GetRecordsReturns(result1 *kinesis.GetRecordsOutput, result2 error)

func (*FakeKinesisClient) GetRecordsReturnsOnCall ¶

func (fake *FakeKinesisClient) GetRecordsReturnsOnCall(i int, result1 *kinesis.GetRecordsOutput, result2 error)

func (*FakeKinesisClient) GetRecordsWithContext ¶

func (fake *FakeKinesisClient) GetRecordsWithContext(arg1 context.Context, arg2 *kinesis.GetRecordsInput, arg3 ...request.Option) (*kinesis.GetRecordsOutput, error)

func (*FakeKinesisClient) GetRecordsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) GetRecordsWithContextArgsForCall(i int) (context.Context, *kinesis.GetRecordsInput, []request.Option)

func (*FakeKinesisClient) GetRecordsWithContextCallCount ¶

func (fake *FakeKinesisClient) GetRecordsWithContextCallCount() int

func (*FakeKinesisClient) GetRecordsWithContextCalls ¶

func (fake *FakeKinesisClient) GetRecordsWithContextCalls(stub func(context.Context, *kinesis.GetRecordsInput, ...request.Option) (*kinesis.GetRecordsOutput, error))

func (*FakeKinesisClient) GetRecordsWithContextReturns ¶

func (fake *FakeKinesisClient) GetRecordsWithContextReturns(result1 *kinesis.GetRecordsOutput, result2 error)

func (*FakeKinesisClient) GetRecordsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) GetRecordsWithContextReturnsOnCall(i int, result1 *kinesis.GetRecordsOutput, result2 error)

func (*FakeKinesisClient) GetShardIterator ¶

func (fake *FakeKinesisClient) GetShardIterator(arg1 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)

func (*FakeKinesisClient) GetShardIteratorArgsForCall ¶

func (fake *FakeKinesisClient) GetShardIteratorArgsForCall(i int) *kinesis.GetShardIteratorInput

func (*FakeKinesisClient) GetShardIteratorCallCount ¶

func (fake *FakeKinesisClient) GetShardIteratorCallCount() int

func (*FakeKinesisClient) GetShardIteratorCalls ¶

func (fake *FakeKinesisClient) GetShardIteratorCalls(stub func(*kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error))

func (*FakeKinesisClient) GetShardIteratorRequest ¶

func (fake *FakeKinesisClient) GetShardIteratorRequest(arg1 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)

func (*FakeKinesisClient) GetShardIteratorRequestArgsForCall ¶

func (fake *FakeKinesisClient) GetShardIteratorRequestArgsForCall(i int) *kinesis.GetShardIteratorInput

func (*FakeKinesisClient) GetShardIteratorRequestCallCount ¶

func (fake *FakeKinesisClient) GetShardIteratorRequestCallCount() int

func (*FakeKinesisClient) GetShardIteratorRequestCalls ¶

func (fake *FakeKinesisClient) GetShardIteratorRequestCalls(stub func(*kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput))

func (*FakeKinesisClient) GetShardIteratorRequestReturns ¶

func (fake *FakeKinesisClient) GetShardIteratorRequestReturns(result1 *request.Request, result2 *kinesis.GetShardIteratorOutput)

func (*FakeKinesisClient) GetShardIteratorRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) GetShardIteratorRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.GetShardIteratorOutput)

func (*FakeKinesisClient) GetShardIteratorReturns ¶

func (fake *FakeKinesisClient) GetShardIteratorReturns(result1 *kinesis.GetShardIteratorOutput, result2 error)

func (*FakeKinesisClient) GetShardIteratorReturnsOnCall ¶

func (fake *FakeKinesisClient) GetShardIteratorReturnsOnCall(i int, result1 *kinesis.GetShardIteratorOutput, result2 error)

func (*FakeKinesisClient) GetShardIteratorWithContext ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContext(arg1 context.Context, arg2 *kinesis.GetShardIteratorInput, arg3 ...request.Option) (*kinesis.GetShardIteratorOutput, error)

func (*FakeKinesisClient) GetShardIteratorWithContextArgsForCall ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContextArgsForCall(i int) (context.Context, *kinesis.GetShardIteratorInput, []request.Option)

func (*FakeKinesisClient) GetShardIteratorWithContextCallCount ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContextCallCount() int

func (*FakeKinesisClient) GetShardIteratorWithContextCalls ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContextCalls(stub func(context.Context, *kinesis.GetShardIteratorInput, ...request.Option) (*kinesis.GetShardIteratorOutput, error))

func (*FakeKinesisClient) GetShardIteratorWithContextReturns ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContextReturns(result1 *kinesis.GetShardIteratorOutput, result2 error)

func (*FakeKinesisClient) GetShardIteratorWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) GetShardIteratorWithContextReturnsOnCall(i int, result1 *kinesis.GetShardIteratorOutput, result2 error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriod ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriod(arg1 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodArgsForCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodArgsForCall(i int) *kinesis.IncreaseStreamRetentionPeriodInput

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodCallCount ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodCallCount() int

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodCalls ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodCalls(stub func(*kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error))

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequest ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequest(arg1 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequestArgsForCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequestArgsForCall(i int) *kinesis.IncreaseStreamRetentionPeriodInput

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequestCallCount ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequestCallCount() int

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequestCalls ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequestCalls(stub func(*kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput))

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequestReturns ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequestReturns(result1 *request.Request, result2 *kinesis.IncreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.IncreaseStreamRetentionPeriodOutput)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodReturns ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodReturns(result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodReturnsOnCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodReturnsOnCall(i int, result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContext ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContext(arg1 context.Context, arg2 *kinesis.IncreaseStreamRetentionPeriodInput, arg3 ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextArgsForCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextArgsForCall(i int) (context.Context, *kinesis.IncreaseStreamRetentionPeriodInput, []request.Option)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextCallCount ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextCallCount() int

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextCalls ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextCalls(stub func(context.Context, *kinesis.IncreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error))

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextReturns ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextReturns(result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) IncreaseStreamRetentionPeriodWithContextReturnsOnCall(i int, result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)

func (*FakeKinesisClient) Invocations ¶

func (fake *FakeKinesisClient) Invocations() map[string][][]interface{}

func (*FakeKinesisClient) ListShards ¶

func (fake *FakeKinesisClient) ListShards(arg1 *kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)

func (*FakeKinesisClient) ListShardsArgsForCall ¶

func (fake *FakeKinesisClient) ListShardsArgsForCall(i int) *kinesis.ListShardsInput

func (*FakeKinesisClient) ListShardsCallCount ¶

func (fake *FakeKinesisClient) ListShardsCallCount() int

func (*FakeKinesisClient) ListShardsCalls ¶

func (fake *FakeKinesisClient) ListShardsCalls(stub func(*kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error))

func (*FakeKinesisClient) ListShardsRequest ¶

func (fake *FakeKinesisClient) ListShardsRequest(arg1 *kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput)

func (*FakeKinesisClient) ListShardsRequestArgsForCall ¶

func (fake *FakeKinesisClient) ListShardsRequestArgsForCall(i int) *kinesis.ListShardsInput

func (*FakeKinesisClient) ListShardsRequestCallCount ¶

func (fake *FakeKinesisClient) ListShardsRequestCallCount() int

func (*FakeKinesisClient) ListShardsRequestCalls ¶

func (fake *FakeKinesisClient) ListShardsRequestCalls(stub func(*kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput))

func (*FakeKinesisClient) ListShardsRequestReturns ¶

func (fake *FakeKinesisClient) ListShardsRequestReturns(result1 *request.Request, result2 *kinesis.ListShardsOutput)

func (*FakeKinesisClient) ListShardsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) ListShardsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListShardsOutput)

func (*FakeKinesisClient) ListShardsReturns ¶

func (fake *FakeKinesisClient) ListShardsReturns(result1 *kinesis.ListShardsOutput, result2 error)

func (*FakeKinesisClient) ListShardsReturnsOnCall ¶

func (fake *FakeKinesisClient) ListShardsReturnsOnCall(i int, result1 *kinesis.ListShardsOutput, result2 error)

func (*FakeKinesisClient) ListShardsWithContext ¶

func (fake *FakeKinesisClient) ListShardsWithContext(arg1 context.Context, arg2 *kinesis.ListShardsInput, arg3 ...request.Option) (*kinesis.ListShardsOutput, error)

func (*FakeKinesisClient) ListShardsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListShardsWithContextArgsForCall(i int) (context.Context, *kinesis.ListShardsInput, []request.Option)

func (*FakeKinesisClient) ListShardsWithContextCallCount ¶

func (fake *FakeKinesisClient) ListShardsWithContextCallCount() int

func (*FakeKinesisClient) ListShardsWithContextCalls ¶

func (fake *FakeKinesisClient) ListShardsWithContextCalls(stub func(context.Context, *kinesis.ListShardsInput, ...request.Option) (*kinesis.ListShardsOutput, error))

func (*FakeKinesisClient) ListShardsWithContextReturns ¶

func (fake *FakeKinesisClient) ListShardsWithContextReturns(result1 *kinesis.ListShardsOutput, result2 error)

func (*FakeKinesisClient) ListShardsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListShardsWithContextReturnsOnCall(i int, result1 *kinesis.ListShardsOutput, result2 error)

func (*FakeKinesisClient) ListStreamConsumers ¶

func (fake *FakeKinesisClient) ListStreamConsumers(arg1 *kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error)

func (*FakeKinesisClient) ListStreamConsumersArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersArgsForCall(i int) *kinesis.ListStreamConsumersInput

func (*FakeKinesisClient) ListStreamConsumersCallCount ¶

func (fake *FakeKinesisClient) ListStreamConsumersCallCount() int

func (*FakeKinesisClient) ListStreamConsumersCalls ¶

func (fake *FakeKinesisClient) ListStreamConsumersCalls(stub func(*kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error))

func (*FakeKinesisClient) ListStreamConsumersPages ¶

func (fake *FakeKinesisClient) ListStreamConsumersPages(arg1 *kinesis.ListStreamConsumersInput, arg2 func(*kinesis.ListStreamConsumersOutput, bool) bool) error

func (*FakeKinesisClient) ListStreamConsumersPagesArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesArgsForCall(i int) (*kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool)

func (*FakeKinesisClient) ListStreamConsumersPagesCallCount ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesCallCount() int

func (*FakeKinesisClient) ListStreamConsumersPagesCalls ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesCalls(stub func(*kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool) error)

func (*FakeKinesisClient) ListStreamConsumersPagesReturns ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesReturns(result1 error)

func (*FakeKinesisClient) ListStreamConsumersPagesReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) ListStreamConsumersPagesWithContext ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContext(arg1 context.Context, arg2 *kinesis.ListStreamConsumersInput, arg3 func(*kinesis.ListStreamConsumersOutput, bool) bool, arg4 ...request.Option) error

func (*FakeKinesisClient) ListStreamConsumersPagesWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool, []request.Option)

func (*FakeKinesisClient) ListStreamConsumersPagesWithContextCallCount ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContextCallCount() int

func (*FakeKinesisClient) ListStreamConsumersPagesWithContextCalls ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContextCalls(stub func(context.Context, *kinesis.ListStreamConsumersInput, func(*kinesis.ListStreamConsumersOutput, bool) bool, ...request.Option) error)

func (*FakeKinesisClient) ListStreamConsumersPagesWithContextReturns ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContextReturns(result1 error)

func (*FakeKinesisClient) ListStreamConsumersPagesWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersPagesWithContextReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) ListStreamConsumersRequest ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequest(arg1 *kinesis.ListStreamConsumersInput) (*request.Request, *kinesis.ListStreamConsumersOutput)

func (*FakeKinesisClient) ListStreamConsumersRequestArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequestArgsForCall(i int) *kinesis.ListStreamConsumersInput

func (*FakeKinesisClient) ListStreamConsumersRequestCallCount ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequestCallCount() int

func (*FakeKinesisClient) ListStreamConsumersRequestCalls ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequestCalls(stub func(*kinesis.ListStreamConsumersInput) (*request.Request, *kinesis.ListStreamConsumersOutput))

func (*FakeKinesisClient) ListStreamConsumersRequestReturns ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequestReturns(result1 *request.Request, result2 *kinesis.ListStreamConsumersOutput)

func (*FakeKinesisClient) ListStreamConsumersRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListStreamConsumersOutput)

func (*FakeKinesisClient) ListStreamConsumersReturns ¶

func (fake *FakeKinesisClient) ListStreamConsumersReturns(result1 *kinesis.ListStreamConsumersOutput, result2 error)

func (*FakeKinesisClient) ListStreamConsumersReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersReturnsOnCall(i int, result1 *kinesis.ListStreamConsumersOutput, result2 error)

func (*FakeKinesisClient) ListStreamConsumersWithContext ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContext(arg1 context.Context, arg2 *kinesis.ListStreamConsumersInput, arg3 ...request.Option) (*kinesis.ListStreamConsumersOutput, error)

func (*FakeKinesisClient) ListStreamConsumersWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamConsumersInput, []request.Option)

func (*FakeKinesisClient) ListStreamConsumersWithContextCallCount ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContextCallCount() int

func (*FakeKinesisClient) ListStreamConsumersWithContextCalls ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContextCalls(stub func(context.Context, *kinesis.ListStreamConsumersInput, ...request.Option) (*kinesis.ListStreamConsumersOutput, error))

func (*FakeKinesisClient) ListStreamConsumersWithContextReturns ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContextReturns(result1 *kinesis.ListStreamConsumersOutput, result2 error)

func (*FakeKinesisClient) ListStreamConsumersWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamConsumersWithContextReturnsOnCall(i int, result1 *kinesis.ListStreamConsumersOutput, result2 error)

func (*FakeKinesisClient) ListStreams ¶

func (fake *FakeKinesisClient) ListStreams(arg1 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

func (*FakeKinesisClient) ListStreamsArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamsArgsForCall(i int) *kinesis.ListStreamsInput

func (*FakeKinesisClient) ListStreamsCallCount ¶

func (fake *FakeKinesisClient) ListStreamsCallCount() int

func (*FakeKinesisClient) ListStreamsCalls ¶

func (fake *FakeKinesisClient) ListStreamsCalls(stub func(*kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error))

func (*FakeKinesisClient) ListStreamsPages ¶

func (fake *FakeKinesisClient) ListStreamsPages(arg1 *kinesis.ListStreamsInput, arg2 func(*kinesis.ListStreamsOutput, bool) bool) error

func (*FakeKinesisClient) ListStreamsPagesArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamsPagesArgsForCall(i int) (*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool)

func (*FakeKinesisClient) ListStreamsPagesCallCount ¶

func (fake *FakeKinesisClient) ListStreamsPagesCallCount() int

func (*FakeKinesisClient) ListStreamsPagesCalls ¶

func (fake *FakeKinesisClient) ListStreamsPagesCalls(stub func(*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool) error)

func (*FakeKinesisClient) ListStreamsPagesReturns ¶

func (fake *FakeKinesisClient) ListStreamsPagesReturns(result1 error)

func (*FakeKinesisClient) ListStreamsPagesReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamsPagesReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) ListStreamsPagesWithContext ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContext(arg1 context.Context, arg2 *kinesis.ListStreamsInput, arg3 func(*kinesis.ListStreamsOutput, bool) bool, arg4 ...request.Option) error

func (*FakeKinesisClient) ListStreamsPagesWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool, []request.Option)

func (*FakeKinesisClient) ListStreamsPagesWithContextCallCount ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContextCallCount() int

func (*FakeKinesisClient) ListStreamsPagesWithContextCalls ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContextCalls(stub func(context.Context, *kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool, ...request.Option) error)

func (*FakeKinesisClient) ListStreamsPagesWithContextReturns ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContextReturns(result1 error)

func (*FakeKinesisClient) ListStreamsPagesWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamsPagesWithContextReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) ListStreamsRequest ¶

func (fake *FakeKinesisClient) ListStreamsRequest(arg1 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)

func (*FakeKinesisClient) ListStreamsRequestArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamsRequestArgsForCall(i int) *kinesis.ListStreamsInput

func (*FakeKinesisClient) ListStreamsRequestCallCount ¶

func (fake *FakeKinesisClient) ListStreamsRequestCallCount() int

func (*FakeKinesisClient) ListStreamsRequestCalls ¶

func (fake *FakeKinesisClient) ListStreamsRequestCalls(stub func(*kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput))

func (*FakeKinesisClient) ListStreamsRequestReturns ¶

func (fake *FakeKinesisClient) ListStreamsRequestReturns(result1 *request.Request, result2 *kinesis.ListStreamsOutput)

func (*FakeKinesisClient) ListStreamsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListStreamsOutput)

func (*FakeKinesisClient) ListStreamsReturns ¶

func (fake *FakeKinesisClient) ListStreamsReturns(result1 *kinesis.ListStreamsOutput, result2 error)

func (*FakeKinesisClient) ListStreamsReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamsReturnsOnCall(i int, result1 *kinesis.ListStreamsOutput, result2 error)

func (*FakeKinesisClient) ListStreamsWithContext ¶

func (fake *FakeKinesisClient) ListStreamsWithContext(arg1 context.Context, arg2 *kinesis.ListStreamsInput, arg3 ...request.Option) (*kinesis.ListStreamsOutput, error)

func (*FakeKinesisClient) ListStreamsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListStreamsWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamsInput, []request.Option)

func (*FakeKinesisClient) ListStreamsWithContextCallCount ¶

func (fake *FakeKinesisClient) ListStreamsWithContextCallCount() int

func (*FakeKinesisClient) ListStreamsWithContextCalls ¶

func (fake *FakeKinesisClient) ListStreamsWithContextCalls(stub func(context.Context, *kinesis.ListStreamsInput, ...request.Option) (*kinesis.ListStreamsOutput, error))

func (*FakeKinesisClient) ListStreamsWithContextReturns ¶

func (fake *FakeKinesisClient) ListStreamsWithContextReturns(result1 *kinesis.ListStreamsOutput, result2 error)

func (*FakeKinesisClient) ListStreamsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListStreamsWithContextReturnsOnCall(i int, result1 *kinesis.ListStreamsOutput, result2 error)

func (*FakeKinesisClient) ListTagsForStream ¶

func (fake *FakeKinesisClient) ListTagsForStream(arg1 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)

func (*FakeKinesisClient) ListTagsForStreamArgsForCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamArgsForCall(i int) *kinesis.ListTagsForStreamInput

func (*FakeKinesisClient) ListTagsForStreamCallCount ¶

func (fake *FakeKinesisClient) ListTagsForStreamCallCount() int

func (*FakeKinesisClient) ListTagsForStreamCalls ¶

func (fake *FakeKinesisClient) ListTagsForStreamCalls(stub func(*kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error))

func (*FakeKinesisClient) ListTagsForStreamRequest ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequest(arg1 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)

func (*FakeKinesisClient) ListTagsForStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequestArgsForCall(i int) *kinesis.ListTagsForStreamInput

func (*FakeKinesisClient) ListTagsForStreamRequestCallCount ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequestCallCount() int

func (*FakeKinesisClient) ListTagsForStreamRequestCalls ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequestCalls(stub func(*kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput))

func (*FakeKinesisClient) ListTagsForStreamRequestReturns ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequestReturns(result1 *request.Request, result2 *kinesis.ListTagsForStreamOutput)

func (*FakeKinesisClient) ListTagsForStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListTagsForStreamOutput)

func (*FakeKinesisClient) ListTagsForStreamReturns ¶

func (fake *FakeKinesisClient) ListTagsForStreamReturns(result1 *kinesis.ListTagsForStreamOutput, result2 error)

func (*FakeKinesisClient) ListTagsForStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamReturnsOnCall(i int, result1 *kinesis.ListTagsForStreamOutput, result2 error)

func (*FakeKinesisClient) ListTagsForStreamWithContext ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContext(arg1 context.Context, arg2 *kinesis.ListTagsForStreamInput, arg3 ...request.Option) (*kinesis.ListTagsForStreamOutput, error)

func (*FakeKinesisClient) ListTagsForStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContextArgsForCall(i int) (context.Context, *kinesis.ListTagsForStreamInput, []request.Option)

func (*FakeKinesisClient) ListTagsForStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContextCallCount() int

func (*FakeKinesisClient) ListTagsForStreamWithContextCalls ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContextCalls(stub func(context.Context, *kinesis.ListTagsForStreamInput, ...request.Option) (*kinesis.ListTagsForStreamOutput, error))

func (*FakeKinesisClient) ListTagsForStreamWithContextReturns ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContextReturns(result1 *kinesis.ListTagsForStreamOutput, result2 error)

func (*FakeKinesisClient) ListTagsForStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) ListTagsForStreamWithContextReturnsOnCall(i int, result1 *kinesis.ListTagsForStreamOutput, result2 error)

func (*FakeKinesisClient) MergeShards ¶

func (fake *FakeKinesisClient) MergeShards(arg1 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)

func (*FakeKinesisClient) MergeShardsArgsForCall ¶

func (fake *FakeKinesisClient) MergeShardsArgsForCall(i int) *kinesis.MergeShardsInput

func (*FakeKinesisClient) MergeShardsCallCount ¶

func (fake *FakeKinesisClient) MergeShardsCallCount() int

func (*FakeKinesisClient) MergeShardsCalls ¶

func (fake *FakeKinesisClient) MergeShardsCalls(stub func(*kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error))

func (*FakeKinesisClient) MergeShardsRequest ¶

func (fake *FakeKinesisClient) MergeShardsRequest(arg1 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)

func (*FakeKinesisClient) MergeShardsRequestArgsForCall ¶

func (fake *FakeKinesisClient) MergeShardsRequestArgsForCall(i int) *kinesis.MergeShardsInput

func (*FakeKinesisClient) MergeShardsRequestCallCount ¶

func (fake *FakeKinesisClient) MergeShardsRequestCallCount() int

func (*FakeKinesisClient) MergeShardsRequestCalls ¶

func (fake *FakeKinesisClient) MergeShardsRequestCalls(stub func(*kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput))

func (*FakeKinesisClient) MergeShardsRequestReturns ¶

func (fake *FakeKinesisClient) MergeShardsRequestReturns(result1 *request.Request, result2 *kinesis.MergeShardsOutput)

func (*FakeKinesisClient) MergeShardsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) MergeShardsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.MergeShardsOutput)

func (*FakeKinesisClient) MergeShardsReturns ¶

func (fake *FakeKinesisClient) MergeShardsReturns(result1 *kinesis.MergeShardsOutput, result2 error)

func (*FakeKinesisClient) MergeShardsReturnsOnCall ¶

func (fake *FakeKinesisClient) MergeShardsReturnsOnCall(i int, result1 *kinesis.MergeShardsOutput, result2 error)

func (*FakeKinesisClient) MergeShardsWithContext ¶

func (fake *FakeKinesisClient) MergeShardsWithContext(arg1 context.Context, arg2 *kinesis.MergeShardsInput, arg3 ...request.Option) (*kinesis.MergeShardsOutput, error)

func (*FakeKinesisClient) MergeShardsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) MergeShardsWithContextArgsForCall(i int) (context.Context, *kinesis.MergeShardsInput, []request.Option)

func (*FakeKinesisClient) MergeShardsWithContextCallCount ¶

func (fake *FakeKinesisClient) MergeShardsWithContextCallCount() int

func (*FakeKinesisClient) MergeShardsWithContextCalls ¶

func (fake *FakeKinesisClient) MergeShardsWithContextCalls(stub func(context.Context, *kinesis.MergeShardsInput, ...request.Option) (*kinesis.MergeShardsOutput, error))

func (*FakeKinesisClient) MergeShardsWithContextReturns ¶

func (fake *FakeKinesisClient) MergeShardsWithContextReturns(result1 *kinesis.MergeShardsOutput, result2 error)

func (*FakeKinesisClient) MergeShardsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) MergeShardsWithContextReturnsOnCall(i int, result1 *kinesis.MergeShardsOutput, result2 error)

func (*FakeKinesisClient) PutRecord ¶

func (fake *FakeKinesisClient) PutRecord(arg1 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

func (*FakeKinesisClient) PutRecordArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordArgsForCall(i int) *kinesis.PutRecordInput

func (*FakeKinesisClient) PutRecordCallCount ¶

func (fake *FakeKinesisClient) PutRecordCallCount() int

func (*FakeKinesisClient) PutRecordCalls ¶

func (fake *FakeKinesisClient) PutRecordCalls(stub func(*kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error))

func (*FakeKinesisClient) PutRecordRequest ¶

func (fake *FakeKinesisClient) PutRecordRequest(arg1 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)

func (*FakeKinesisClient) PutRecordRequestArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordRequestArgsForCall(i int) *kinesis.PutRecordInput

func (*FakeKinesisClient) PutRecordRequestCallCount ¶

func (fake *FakeKinesisClient) PutRecordRequestCallCount() int

func (*FakeKinesisClient) PutRecordRequestCalls ¶

func (fake *FakeKinesisClient) PutRecordRequestCalls(stub func(*kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput))

func (*FakeKinesisClient) PutRecordRequestReturns ¶

func (fake *FakeKinesisClient) PutRecordRequestReturns(result1 *request.Request, result2 *kinesis.PutRecordOutput)

func (*FakeKinesisClient) PutRecordRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.PutRecordOutput)

func (*FakeKinesisClient) PutRecordReturns ¶

func (fake *FakeKinesisClient) PutRecordReturns(result1 *kinesis.PutRecordOutput, result2 error)

func (*FakeKinesisClient) PutRecordReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordReturnsOnCall(i int, result1 *kinesis.PutRecordOutput, result2 error)

func (*FakeKinesisClient) PutRecordWithContext ¶

func (fake *FakeKinesisClient) PutRecordWithContext(arg1 context.Context, arg2 *kinesis.PutRecordInput, arg3 ...request.Option) (*kinesis.PutRecordOutput, error)

func (*FakeKinesisClient) PutRecordWithContextArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordWithContextArgsForCall(i int) (context.Context, *kinesis.PutRecordInput, []request.Option)

func (*FakeKinesisClient) PutRecordWithContextCallCount ¶

func (fake *FakeKinesisClient) PutRecordWithContextCallCount() int

func (*FakeKinesisClient) PutRecordWithContextCalls ¶

func (fake *FakeKinesisClient) PutRecordWithContextCalls(stub func(context.Context, *kinesis.PutRecordInput, ...request.Option) (*kinesis.PutRecordOutput, error))

func (*FakeKinesisClient) PutRecordWithContextReturns ¶

func (fake *FakeKinesisClient) PutRecordWithContextReturns(result1 *kinesis.PutRecordOutput, result2 error)

func (*FakeKinesisClient) PutRecordWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordWithContextReturnsOnCall(i int, result1 *kinesis.PutRecordOutput, result2 error)

func (*FakeKinesisClient) PutRecords ¶

func (fake *FakeKinesisClient) PutRecords(arg1 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

func (*FakeKinesisClient) PutRecordsArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordsArgsForCall(i int) *kinesis.PutRecordsInput

func (*FakeKinesisClient) PutRecordsCallCount ¶

func (fake *FakeKinesisClient) PutRecordsCallCount() int

func (*FakeKinesisClient) PutRecordsCalls ¶

func (fake *FakeKinesisClient) PutRecordsCalls(stub func(*kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error))

func (*FakeKinesisClient) PutRecordsRequest ¶

func (fake *FakeKinesisClient) PutRecordsRequest(arg1 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)

func (*FakeKinesisClient) PutRecordsRequestArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordsRequestArgsForCall(i int) *kinesis.PutRecordsInput

func (*FakeKinesisClient) PutRecordsRequestCallCount ¶

func (fake *FakeKinesisClient) PutRecordsRequestCallCount() int

func (*FakeKinesisClient) PutRecordsRequestCalls ¶

func (fake *FakeKinesisClient) PutRecordsRequestCalls(stub func(*kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput))

func (*FakeKinesisClient) PutRecordsRequestReturns ¶

func (fake *FakeKinesisClient) PutRecordsRequestReturns(result1 *request.Request, result2 *kinesis.PutRecordsOutput)

func (*FakeKinesisClient) PutRecordsRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.PutRecordsOutput)

func (*FakeKinesisClient) PutRecordsReturns ¶

func (fake *FakeKinesisClient) PutRecordsReturns(result1 *kinesis.PutRecordsOutput, result2 error)

func (*FakeKinesisClient) PutRecordsReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordsReturnsOnCall(i int, result1 *kinesis.PutRecordsOutput, result2 error)

func (*FakeKinesisClient) PutRecordsWithContext ¶

func (fake *FakeKinesisClient) PutRecordsWithContext(arg1 context.Context, arg2 *kinesis.PutRecordsInput, arg3 ...request.Option) (*kinesis.PutRecordsOutput, error)

func (*FakeKinesisClient) PutRecordsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) PutRecordsWithContextArgsForCall(i int) (context.Context, *kinesis.PutRecordsInput, []request.Option)

func (*FakeKinesisClient) PutRecordsWithContextCallCount ¶

func (fake *FakeKinesisClient) PutRecordsWithContextCallCount() int

func (*FakeKinesisClient) PutRecordsWithContextCalls ¶

func (fake *FakeKinesisClient) PutRecordsWithContextCalls(stub func(context.Context, *kinesis.PutRecordsInput, ...request.Option) (*kinesis.PutRecordsOutput, error))

func (*FakeKinesisClient) PutRecordsWithContextReturns ¶

func (fake *FakeKinesisClient) PutRecordsWithContextReturns(result1 *kinesis.PutRecordsOutput, result2 error)

func (*FakeKinesisClient) PutRecordsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) PutRecordsWithContextReturnsOnCall(i int, result1 *kinesis.PutRecordsOutput, result2 error)

func (*FakeKinesisClient) RegisterStreamConsumer ¶

func (fake *FakeKinesisClient) RegisterStreamConsumer(arg1 *kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error)

func (*FakeKinesisClient) RegisterStreamConsumerArgsForCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerArgsForCall(i int) *kinesis.RegisterStreamConsumerInput

func (*FakeKinesisClient) RegisterStreamConsumerCallCount ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerCallCount() int

func (*FakeKinesisClient) RegisterStreamConsumerCalls ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerCalls(stub func(*kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error))

func (*FakeKinesisClient) RegisterStreamConsumerRequest ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequest(arg1 *kinesis.RegisterStreamConsumerInput) (*request.Request, *kinesis.RegisterStreamConsumerOutput)

func (*FakeKinesisClient) RegisterStreamConsumerRequestArgsForCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequestArgsForCall(i int) *kinesis.RegisterStreamConsumerInput

func (*FakeKinesisClient) RegisterStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequestCallCount() int

func (*FakeKinesisClient) RegisterStreamConsumerRequestCalls ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequestCalls(stub func(*kinesis.RegisterStreamConsumerInput) (*request.Request, *kinesis.RegisterStreamConsumerOutput))

func (*FakeKinesisClient) RegisterStreamConsumerRequestReturns ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.RegisterStreamConsumerOutput)

func (*FakeKinesisClient) RegisterStreamConsumerRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.RegisterStreamConsumerOutput)

func (*FakeKinesisClient) RegisterStreamConsumerReturns ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerReturns(result1 *kinesis.RegisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) RegisterStreamConsumerReturnsOnCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerReturnsOnCall(i int, result1 *kinesis.RegisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) RegisterStreamConsumerWithContext ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.RegisterStreamConsumerInput, arg3 ...request.Option) (*kinesis.RegisterStreamConsumerOutput, error)

func (*FakeKinesisClient) RegisterStreamConsumerWithContextArgsForCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.RegisterStreamConsumerInput, []request.Option)

func (*FakeKinesisClient) RegisterStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContextCallCount() int

func (*FakeKinesisClient) RegisterStreamConsumerWithContextCalls ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContextCalls(stub func(context.Context, *kinesis.RegisterStreamConsumerInput, ...request.Option) (*kinesis.RegisterStreamConsumerOutput, error))

func (*FakeKinesisClient) RegisterStreamConsumerWithContextReturns ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContextReturns(result1 *kinesis.RegisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) RegisterStreamConsumerWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) RegisterStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.RegisterStreamConsumerOutput, result2 error)

func (*FakeKinesisClient) RemoveTagsFromStream ¶

func (fake *FakeKinesisClient) RemoveTagsFromStream(arg1 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)

func (*FakeKinesisClient) RemoveTagsFromStreamArgsForCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamArgsForCall(i int) *kinesis.RemoveTagsFromStreamInput

func (*FakeKinesisClient) RemoveTagsFromStreamCallCount ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamCallCount() int

func (*FakeKinesisClient) RemoveTagsFromStreamCalls ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamCalls(stub func(*kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error))

func (*FakeKinesisClient) RemoveTagsFromStreamRequest ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequest(arg1 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)

func (*FakeKinesisClient) RemoveTagsFromStreamRequestArgsForCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequestArgsForCall(i int) *kinesis.RemoveTagsFromStreamInput

func (*FakeKinesisClient) RemoveTagsFromStreamRequestCallCount ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequestCallCount() int

func (*FakeKinesisClient) RemoveTagsFromStreamRequestCalls ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequestCalls(stub func(*kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput))

func (*FakeKinesisClient) RemoveTagsFromStreamRequestReturns ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequestReturns(result1 *request.Request, result2 *kinesis.RemoveTagsFromStreamOutput)

func (*FakeKinesisClient) RemoveTagsFromStreamRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.RemoveTagsFromStreamOutput)

func (*FakeKinesisClient) RemoveTagsFromStreamReturns ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamReturns(result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)

func (*FakeKinesisClient) RemoveTagsFromStreamReturnsOnCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamReturnsOnCall(i int, result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)

func (*FakeKinesisClient) RemoveTagsFromStreamWithContext ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContext(arg1 context.Context, arg2 *kinesis.RemoveTagsFromStreamInput, arg3 ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error)

func (*FakeKinesisClient) RemoveTagsFromStreamWithContextArgsForCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContextArgsForCall(i int) (context.Context, *kinesis.RemoveTagsFromStreamInput, []request.Option)

func (*FakeKinesisClient) RemoveTagsFromStreamWithContextCallCount ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContextCallCount() int

func (*FakeKinesisClient) RemoveTagsFromStreamWithContextCalls ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContextCalls(stub func(context.Context, *kinesis.RemoveTagsFromStreamInput, ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error))

func (*FakeKinesisClient) RemoveTagsFromStreamWithContextReturns ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContextReturns(result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)

func (*FakeKinesisClient) RemoveTagsFromStreamWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) RemoveTagsFromStreamWithContextReturnsOnCall(i int, result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)

func (*FakeKinesisClient) SplitShard ¶

func (fake *FakeKinesisClient) SplitShard(arg1 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)

func (*FakeKinesisClient) SplitShardArgsForCall ¶

func (fake *FakeKinesisClient) SplitShardArgsForCall(i int) *kinesis.SplitShardInput

func (*FakeKinesisClient) SplitShardCallCount ¶

func (fake *FakeKinesisClient) SplitShardCallCount() int

func (*FakeKinesisClient) SplitShardCalls ¶

func (fake *FakeKinesisClient) SplitShardCalls(stub func(*kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error))

func (*FakeKinesisClient) SplitShardRequest ¶

func (fake *FakeKinesisClient) SplitShardRequest(arg1 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)

func (*FakeKinesisClient) SplitShardRequestArgsForCall ¶

func (fake *FakeKinesisClient) SplitShardRequestArgsForCall(i int) *kinesis.SplitShardInput

func (*FakeKinesisClient) SplitShardRequestCallCount ¶

func (fake *FakeKinesisClient) SplitShardRequestCallCount() int

func (*FakeKinesisClient) SplitShardRequestCalls ¶

func (fake *FakeKinesisClient) SplitShardRequestCalls(stub func(*kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput))

func (*FakeKinesisClient) SplitShardRequestReturns ¶

func (fake *FakeKinesisClient) SplitShardRequestReturns(result1 *request.Request, result2 *kinesis.SplitShardOutput)

func (*FakeKinesisClient) SplitShardRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) SplitShardRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.SplitShardOutput)

func (*FakeKinesisClient) SplitShardReturns ¶

func (fake *FakeKinesisClient) SplitShardReturns(result1 *kinesis.SplitShardOutput, result2 error)

func (*FakeKinesisClient) SplitShardReturnsOnCall ¶

func (fake *FakeKinesisClient) SplitShardReturnsOnCall(i int, result1 *kinesis.SplitShardOutput, result2 error)

func (*FakeKinesisClient) SplitShardWithContext ¶

func (fake *FakeKinesisClient) SplitShardWithContext(arg1 context.Context, arg2 *kinesis.SplitShardInput, arg3 ...request.Option) (*kinesis.SplitShardOutput, error)

func (*FakeKinesisClient) SplitShardWithContextArgsForCall ¶

func (fake *FakeKinesisClient) SplitShardWithContextArgsForCall(i int) (context.Context, *kinesis.SplitShardInput, []request.Option)

func (*FakeKinesisClient) SplitShardWithContextCallCount ¶

func (fake *FakeKinesisClient) SplitShardWithContextCallCount() int

func (*FakeKinesisClient) SplitShardWithContextCalls ¶

func (fake *FakeKinesisClient) SplitShardWithContextCalls(stub func(context.Context, *kinesis.SplitShardInput, ...request.Option) (*kinesis.SplitShardOutput, error))

func (*FakeKinesisClient) SplitShardWithContextReturns ¶

func (fake *FakeKinesisClient) SplitShardWithContextReturns(result1 *kinesis.SplitShardOutput, result2 error)

func (*FakeKinesisClient) SplitShardWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) SplitShardWithContextReturnsOnCall(i int, result1 *kinesis.SplitShardOutput, result2 error)

func (*FakeKinesisClient) StartStreamEncryption ¶

func (fake *FakeKinesisClient) StartStreamEncryption(arg1 *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)

func (*FakeKinesisClient) StartStreamEncryptionArgsForCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionArgsForCall(i int) *kinesis.StartStreamEncryptionInput

func (*FakeKinesisClient) StartStreamEncryptionCallCount ¶

func (fake *FakeKinesisClient) StartStreamEncryptionCallCount() int

func (*FakeKinesisClient) StartStreamEncryptionCalls ¶

func (fake *FakeKinesisClient) StartStreamEncryptionCalls(stub func(*kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error))

func (*FakeKinesisClient) StartStreamEncryptionRequest ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequest(arg1 *kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)

func (*FakeKinesisClient) StartStreamEncryptionRequestArgsForCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequestArgsForCall(i int) *kinesis.StartStreamEncryptionInput

func (*FakeKinesisClient) StartStreamEncryptionRequestCallCount ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequestCallCount() int

func (*FakeKinesisClient) StartStreamEncryptionRequestCalls ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequestCalls(stub func(*kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput))

func (*FakeKinesisClient) StartStreamEncryptionRequestReturns ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequestReturns(result1 *request.Request, result2 *kinesis.StartStreamEncryptionOutput)

func (*FakeKinesisClient) StartStreamEncryptionRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.StartStreamEncryptionOutput)

func (*FakeKinesisClient) StartStreamEncryptionReturns ¶

func (fake *FakeKinesisClient) StartStreamEncryptionReturns(result1 *kinesis.StartStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StartStreamEncryptionReturnsOnCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionReturnsOnCall(i int, result1 *kinesis.StartStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StartStreamEncryptionWithContext ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContext(arg1 context.Context, arg2 *kinesis.StartStreamEncryptionInput, arg3 ...request.Option) (*kinesis.StartStreamEncryptionOutput, error)

func (*FakeKinesisClient) StartStreamEncryptionWithContextArgsForCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContextArgsForCall(i int) (context.Context, *kinesis.StartStreamEncryptionInput, []request.Option)

func (*FakeKinesisClient) StartStreamEncryptionWithContextCallCount ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContextCallCount() int

func (*FakeKinesisClient) StartStreamEncryptionWithContextCalls ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContextCalls(stub func(context.Context, *kinesis.StartStreamEncryptionInput, ...request.Option) (*kinesis.StartStreamEncryptionOutput, error))

func (*FakeKinesisClient) StartStreamEncryptionWithContextReturns ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContextReturns(result1 *kinesis.StartStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StartStreamEncryptionWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) StartStreamEncryptionWithContextReturnsOnCall(i int, result1 *kinesis.StartStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StopStreamEncryption ¶

func (fake *FakeKinesisClient) StopStreamEncryption(arg1 *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)

func (*FakeKinesisClient) StopStreamEncryptionArgsForCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionArgsForCall(i int) *kinesis.StopStreamEncryptionInput

func (*FakeKinesisClient) StopStreamEncryptionCallCount ¶

func (fake *FakeKinesisClient) StopStreamEncryptionCallCount() int

func (*FakeKinesisClient) StopStreamEncryptionCalls ¶

func (fake *FakeKinesisClient) StopStreamEncryptionCalls(stub func(*kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error))

func (*FakeKinesisClient) StopStreamEncryptionRequest ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequest(arg1 *kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)

func (*FakeKinesisClient) StopStreamEncryptionRequestArgsForCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequestArgsForCall(i int) *kinesis.StopStreamEncryptionInput

func (*FakeKinesisClient) StopStreamEncryptionRequestCallCount ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequestCallCount() int

func (*FakeKinesisClient) StopStreamEncryptionRequestCalls ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequestCalls(stub func(*kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput))

func (*FakeKinesisClient) StopStreamEncryptionRequestReturns ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequestReturns(result1 *request.Request, result2 *kinesis.StopStreamEncryptionOutput)

func (*FakeKinesisClient) StopStreamEncryptionRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.StopStreamEncryptionOutput)

func (*FakeKinesisClient) StopStreamEncryptionReturns ¶

func (fake *FakeKinesisClient) StopStreamEncryptionReturns(result1 *kinesis.StopStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StopStreamEncryptionReturnsOnCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionReturnsOnCall(i int, result1 *kinesis.StopStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StopStreamEncryptionWithContext ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContext(arg1 context.Context, arg2 *kinesis.StopStreamEncryptionInput, arg3 ...request.Option) (*kinesis.StopStreamEncryptionOutput, error)

func (*FakeKinesisClient) StopStreamEncryptionWithContextArgsForCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContextArgsForCall(i int) (context.Context, *kinesis.StopStreamEncryptionInput, []request.Option)

func (*FakeKinesisClient) StopStreamEncryptionWithContextCallCount ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContextCallCount() int

func (*FakeKinesisClient) StopStreamEncryptionWithContextCalls ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContextCalls(stub func(context.Context, *kinesis.StopStreamEncryptionInput, ...request.Option) (*kinesis.StopStreamEncryptionOutput, error))

func (*FakeKinesisClient) StopStreamEncryptionWithContextReturns ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContextReturns(result1 *kinesis.StopStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) StopStreamEncryptionWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) StopStreamEncryptionWithContextReturnsOnCall(i int, result1 *kinesis.StopStreamEncryptionOutput, result2 error)

func (*FakeKinesisClient) SubscribeToShard ¶

func (fake *FakeKinesisClient) SubscribeToShard(arg1 *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)

func (*FakeKinesisClient) SubscribeToShardArgsForCall ¶

func (fake *FakeKinesisClient) SubscribeToShardArgsForCall(i int) *kinesis.SubscribeToShardInput

func (*FakeKinesisClient) SubscribeToShardCallCount ¶

func (fake *FakeKinesisClient) SubscribeToShardCallCount() int

func (*FakeKinesisClient) SubscribeToShardCalls ¶

func (fake *FakeKinesisClient) SubscribeToShardCalls(stub func(*kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error))

func (*FakeKinesisClient) SubscribeToShardRequest ¶

func (fake *FakeKinesisClient) SubscribeToShardRequest(arg1 *kinesis.SubscribeToShardInput) (*request.Request, *kinesis.SubscribeToShardOutput)

func (*FakeKinesisClient) SubscribeToShardRequestArgsForCall ¶

func (fake *FakeKinesisClient) SubscribeToShardRequestArgsForCall(i int) *kinesis.SubscribeToShardInput

func (*FakeKinesisClient) SubscribeToShardRequestCallCount ¶

func (fake *FakeKinesisClient) SubscribeToShardRequestCallCount() int

func (*FakeKinesisClient) SubscribeToShardRequestCalls ¶

func (fake *FakeKinesisClient) SubscribeToShardRequestCalls(stub func(*kinesis.SubscribeToShardInput) (*request.Request, *kinesis.SubscribeToShardOutput))

func (*FakeKinesisClient) SubscribeToShardRequestReturns ¶

func (fake *FakeKinesisClient) SubscribeToShardRequestReturns(result1 *request.Request, result2 *kinesis.SubscribeToShardOutput)

func (*FakeKinesisClient) SubscribeToShardRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) SubscribeToShardRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.SubscribeToShardOutput)

func (*FakeKinesisClient) SubscribeToShardReturns ¶

func (fake *FakeKinesisClient) SubscribeToShardReturns(result1 *kinesis.SubscribeToShardOutput, result2 error)

func (*FakeKinesisClient) SubscribeToShardReturnsOnCall ¶

func (fake *FakeKinesisClient) SubscribeToShardReturnsOnCall(i int, result1 *kinesis.SubscribeToShardOutput, result2 error)

func (*FakeKinesisClient) SubscribeToShardWithContext ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContext(arg1 context.Context, arg2 *kinesis.SubscribeToShardInput, arg3 ...request.Option) (*kinesis.SubscribeToShardOutput, error)

func (*FakeKinesisClient) SubscribeToShardWithContextArgsForCall ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContextArgsForCall(i int) (context.Context, *kinesis.SubscribeToShardInput, []request.Option)

func (*FakeKinesisClient) SubscribeToShardWithContextCallCount ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContextCallCount() int

func (*FakeKinesisClient) SubscribeToShardWithContextCalls ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContextCalls(stub func(context.Context, *kinesis.SubscribeToShardInput, ...request.Option) (*kinesis.SubscribeToShardOutput, error))

func (*FakeKinesisClient) SubscribeToShardWithContextReturns ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContextReturns(result1 *kinesis.SubscribeToShardOutput, result2 error)

func (*FakeKinesisClient) SubscribeToShardWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) SubscribeToShardWithContextReturnsOnCall(i int, result1 *kinesis.SubscribeToShardOutput, result2 error)

func (*FakeKinesisClient) UpdateShardCount ¶

func (fake *FakeKinesisClient) UpdateShardCount(arg1 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)

func (*FakeKinesisClient) UpdateShardCountArgsForCall ¶

func (fake *FakeKinesisClient) UpdateShardCountArgsForCall(i int) *kinesis.UpdateShardCountInput

func (*FakeKinesisClient) UpdateShardCountCallCount ¶

func (fake *FakeKinesisClient) UpdateShardCountCallCount() int

func (*FakeKinesisClient) UpdateShardCountCalls ¶

func (fake *FakeKinesisClient) UpdateShardCountCalls(stub func(*kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error))

func (*FakeKinesisClient) UpdateShardCountRequest ¶

func (fake *FakeKinesisClient) UpdateShardCountRequest(arg1 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)

func (*FakeKinesisClient) UpdateShardCountRequestArgsForCall ¶

func (fake *FakeKinesisClient) UpdateShardCountRequestArgsForCall(i int) *kinesis.UpdateShardCountInput

func (*FakeKinesisClient) UpdateShardCountRequestCallCount ¶

func (fake *FakeKinesisClient) UpdateShardCountRequestCallCount() int

func (*FakeKinesisClient) UpdateShardCountRequestCalls ¶

func (fake *FakeKinesisClient) UpdateShardCountRequestCalls(stub func(*kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput))

func (*FakeKinesisClient) UpdateShardCountRequestReturns ¶

func (fake *FakeKinesisClient) UpdateShardCountRequestReturns(result1 *request.Request, result2 *kinesis.UpdateShardCountOutput)

func (*FakeKinesisClient) UpdateShardCountRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateShardCountRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.UpdateShardCountOutput)

func (*FakeKinesisClient) UpdateShardCountReturns ¶

func (fake *FakeKinesisClient) UpdateShardCountReturns(result1 *kinesis.UpdateShardCountOutput, result2 error)

func (*FakeKinesisClient) UpdateShardCountReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateShardCountReturnsOnCall(i int, result1 *kinesis.UpdateShardCountOutput, result2 error)

func (*FakeKinesisClient) UpdateShardCountWithContext ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContext(arg1 context.Context, arg2 *kinesis.UpdateShardCountInput, arg3 ...request.Option) (*kinesis.UpdateShardCountOutput, error)

func (*FakeKinesisClient) UpdateShardCountWithContextArgsForCall ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContextArgsForCall(i int) (context.Context, *kinesis.UpdateShardCountInput, []request.Option)

func (*FakeKinesisClient) UpdateShardCountWithContextCallCount ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContextCallCount() int

func (*FakeKinesisClient) UpdateShardCountWithContextCalls ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContextCalls(stub func(context.Context, *kinesis.UpdateShardCountInput, ...request.Option) (*kinesis.UpdateShardCountOutput, error))

func (*FakeKinesisClient) UpdateShardCountWithContextReturns ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContextReturns(result1 *kinesis.UpdateShardCountOutput, result2 error)

func (*FakeKinesisClient) UpdateShardCountWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateShardCountWithContextReturnsOnCall(i int, result1 *kinesis.UpdateShardCountOutput, result2 error)

func (*FakeKinesisClient) UpdateStreamMode ¶

func (fake *FakeKinesisClient) UpdateStreamMode(arg1 *kinesis.UpdateStreamModeInput) (*kinesis.UpdateStreamModeOutput, error)

func (*FakeKinesisClient) UpdateStreamModeArgsForCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeArgsForCall(i int) *kinesis.UpdateStreamModeInput

func (*FakeKinesisClient) UpdateStreamModeCallCount ¶

func (fake *FakeKinesisClient) UpdateStreamModeCallCount() int

func (*FakeKinesisClient) UpdateStreamModeCalls ¶

func (fake *FakeKinesisClient) UpdateStreamModeCalls(stub func(*kinesis.UpdateStreamModeInput) (*kinesis.UpdateStreamModeOutput, error))

func (*FakeKinesisClient) UpdateStreamModeRequest ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequest(arg1 *kinesis.UpdateStreamModeInput) (*request.Request, *kinesis.UpdateStreamModeOutput)

func (*FakeKinesisClient) UpdateStreamModeRequestArgsForCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequestArgsForCall(i int) *kinesis.UpdateStreamModeInput

func (*FakeKinesisClient) UpdateStreamModeRequestCallCount ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequestCallCount() int

func (*FakeKinesisClient) UpdateStreamModeRequestCalls ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequestCalls(stub func(*kinesis.UpdateStreamModeInput) (*request.Request, *kinesis.UpdateStreamModeOutput))

func (*FakeKinesisClient) UpdateStreamModeRequestReturns ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequestReturns(result1 *request.Request, result2 *kinesis.UpdateStreamModeOutput)

func (*FakeKinesisClient) UpdateStreamModeRequestReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.UpdateStreamModeOutput)

func (*FakeKinesisClient) UpdateStreamModeReturns ¶

func (fake *FakeKinesisClient) UpdateStreamModeReturns(result1 *kinesis.UpdateStreamModeOutput, result2 error)

func (*FakeKinesisClient) UpdateStreamModeReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeReturnsOnCall(i int, result1 *kinesis.UpdateStreamModeOutput, result2 error)

func (*FakeKinesisClient) UpdateStreamModeWithContext ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContext(arg1 context.Context, arg2 *kinesis.UpdateStreamModeInput, arg3 ...request.Option) (*kinesis.UpdateStreamModeOutput, error)

func (*FakeKinesisClient) UpdateStreamModeWithContextArgsForCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContextArgsForCall(i int) (context.Context, *kinesis.UpdateStreamModeInput, []request.Option)

func (*FakeKinesisClient) UpdateStreamModeWithContextCallCount ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContextCallCount() int

func (*FakeKinesisClient) UpdateStreamModeWithContextCalls ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContextCalls(stub func(context.Context, *kinesis.UpdateStreamModeInput, ...request.Option) (*kinesis.UpdateStreamModeOutput, error))

func (*FakeKinesisClient) UpdateStreamModeWithContextReturns ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContextReturns(result1 *kinesis.UpdateStreamModeOutput, result2 error)

func (*FakeKinesisClient) UpdateStreamModeWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) UpdateStreamModeWithContextReturnsOnCall(i int, result1 *kinesis.UpdateStreamModeOutput, result2 error)

func (*FakeKinesisClient) WaitUntilStreamExists ¶

func (fake *FakeKinesisClient) WaitUntilStreamExists(arg1 *kinesis.DescribeStreamInput) error

func (*FakeKinesisClient) WaitUntilStreamExistsArgsForCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsArgsForCall(i int) *kinesis.DescribeStreamInput

func (*FakeKinesisClient) WaitUntilStreamExistsCallCount ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsCallCount() int

func (*FakeKinesisClient) WaitUntilStreamExistsCalls ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsCalls(stub func(*kinesis.DescribeStreamInput) error)

func (*FakeKinesisClient) WaitUntilStreamExistsReturns ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsReturns(result1 error)

func (*FakeKinesisClient) WaitUntilStreamExistsReturnsOnCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) WaitUntilStreamExistsWithContext ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, arg3 ...request.WaiterOption) error

func (*FakeKinesisClient) WaitUntilStreamExistsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)

func (*FakeKinesisClient) WaitUntilStreamExistsWithContextCallCount ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContextCallCount() int

func (*FakeKinesisClient) WaitUntilStreamExistsWithContextCalls ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error)

func (*FakeKinesisClient) WaitUntilStreamExistsWithContextReturns ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContextReturns(result1 error)

func (*FakeKinesisClient) WaitUntilStreamExistsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamExistsWithContextReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) WaitUntilStreamNotExists ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExists(arg1 *kinesis.DescribeStreamInput) error

func (*FakeKinesisClient) WaitUntilStreamNotExistsArgsForCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsArgsForCall(i int) *kinesis.DescribeStreamInput

func (*FakeKinesisClient) WaitUntilStreamNotExistsCallCount ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsCallCount() int

func (*FakeKinesisClient) WaitUntilStreamNotExistsCalls ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsCalls(stub func(*kinesis.DescribeStreamInput) error)

func (*FakeKinesisClient) WaitUntilStreamNotExistsReturns ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsReturns(result1 error)

func (*FakeKinesisClient) WaitUntilStreamNotExistsReturnsOnCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsReturnsOnCall(i int, result1 error)

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContext ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, arg3 ...request.WaiterOption) error

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContextArgsForCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContextCallCount ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContextCallCount() int

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContextCalls ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error)

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContextReturns ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContextReturns(result1 error)

func (*FakeKinesisClient) WaitUntilStreamNotExistsWithContextReturnsOnCall ¶

func (fake *FakeKinesisClient) WaitUntilStreamNotExistsWithContextReturnsOnCall(i int, result1 error)

type FakeKinesisScanner ¶

type FakeKinesisScanner struct {
	ScanStub func(context.Context, consumer.ScanFunc) error
	// contains filtered or unexported fields
}

func (*FakeKinesisScanner) Invocations ¶

func (fake *FakeKinesisScanner) Invocations() map[string][][]interface{}

func (*FakeKinesisScanner) Scan ¶

func (fake *FakeKinesisScanner) Scan(arg1 context.Context, arg2 consumer.ScanFunc) error

func (*FakeKinesisScanner) ScanArgsForCall ¶

func (fake *FakeKinesisScanner) ScanArgsForCall(i int) (context.Context, consumer.ScanFunc)

func (*FakeKinesisScanner) ScanCallCount ¶

func (fake *FakeKinesisScanner) ScanCallCount() int

func (*FakeKinesisScanner) ScanCalls ¶

func (fake *FakeKinesisScanner) ScanCalls(stub func(context.Context, consumer.ScanFunc) error)

func (*FakeKinesisScanner) ScanReturns ¶

func (fake *FakeKinesisScanner) ScanReturns(result1 error)

func (*FakeKinesisScanner) ScanReturnsOnCall ¶

func (fake *FakeKinesisScanner) ScanReturnsOnCall(i int, result1 error)

type FakeSQSClient ¶

type FakeSQSClient struct {
	AddPermissionStub func(*sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error)

	AddPermissionRequestStub func(*sqs.AddPermissionInput) (*request.Request, *sqs.AddPermissionOutput)

	AddPermissionWithContextStub func(context.Context, *sqs.AddPermissionInput, ...request.Option) (*sqs.AddPermissionOutput, error)

	CancelMessageMoveTaskStub func(*sqs.CancelMessageMoveTaskInput) (*sqs.CancelMessageMoveTaskOutput, error)

	CancelMessageMoveTaskRequestStub func(*sqs.CancelMessageMoveTaskInput) (*request.Request, *sqs.CancelMessageMoveTaskOutput)

	CancelMessageMoveTaskWithContextStub func(context.Context, *sqs.CancelMessageMoveTaskInput, ...request.Option) (*sqs.CancelMessageMoveTaskOutput, error)

	ChangeMessageVisibilityStub func(*sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)

	ChangeMessageVisibilityBatchStub func(*sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)

	ChangeMessageVisibilityBatchRequestStub func(*sqs.ChangeMessageVisibilityBatchInput) (*request.Request, *sqs.ChangeMessageVisibilityBatchOutput)

	ChangeMessageVisibilityBatchWithContextStub func(context.Context, *sqs.ChangeMessageVisibilityBatchInput, ...request.Option) (*sqs.ChangeMessageVisibilityBatchOutput, error)

	ChangeMessageVisibilityRequestStub func(*sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput)

	ChangeMessageVisibilityWithContextStub func(context.Context, *sqs.ChangeMessageVisibilityInput, ...request.Option) (*sqs.ChangeMessageVisibilityOutput, error)

	CreateQueueStub func(*sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)

	CreateQueueRequestStub func(*sqs.CreateQueueInput) (*request.Request, *sqs.CreateQueueOutput)

	CreateQueueWithContextStub func(context.Context, *sqs.CreateQueueInput, ...request.Option) (*sqs.CreateQueueOutput, error)

	DeleteMessageStub func(*sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

	DeleteMessageBatchStub func(*sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

	DeleteMessageBatchRequestStub func(*sqs.DeleteMessageBatchInput) (*request.Request, *sqs.DeleteMessageBatchOutput)

	DeleteMessageBatchWithContextStub func(context.Context, *sqs.DeleteMessageBatchInput, ...request.Option) (*sqs.DeleteMessageBatchOutput, error)

	DeleteMessageRequestStub func(*sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput)

	DeleteMessageWithContextStub func(context.Context, *sqs.DeleteMessageInput, ...request.Option) (*sqs.DeleteMessageOutput, error)

	DeleteQueueStub func(*sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error)

	DeleteQueueRequestStub func(*sqs.DeleteQueueInput) (*request.Request, *sqs.DeleteQueueOutput)

	DeleteQueueWithContextStub func(context.Context, *sqs.DeleteQueueInput, ...request.Option) (*sqs.DeleteQueueOutput, error)

	GetQueueAttributesStub func(*sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)

	GetQueueAttributesRequestStub func(*sqs.GetQueueAttributesInput) (*request.Request, *sqs.GetQueueAttributesOutput)

	GetQueueAttributesWithContextStub func(context.Context, *sqs.GetQueueAttributesInput, ...request.Option) (*sqs.GetQueueAttributesOutput, error)

	GetQueueUrlStub func(*sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)

	GetQueueUrlRequestStub func(*sqs.GetQueueUrlInput) (*request.Request, *sqs.GetQueueUrlOutput)

	GetQueueUrlWithContextStub func(context.Context, *sqs.GetQueueUrlInput, ...request.Option) (*sqs.GetQueueUrlOutput, error)

	ListDeadLetterSourceQueuesStub func(*sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error)

	ListDeadLetterSourceQueuesPagesStub func(*sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool) error

	ListDeadLetterSourceQueuesPagesWithContextStub func(context.Context, *sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool, ...request.Option) error

	ListDeadLetterSourceQueuesRequestStub func(*sqs.ListDeadLetterSourceQueuesInput) (*request.Request, *sqs.ListDeadLetterSourceQueuesOutput)

	ListDeadLetterSourceQueuesWithContextStub func(context.Context, *sqs.ListDeadLetterSourceQueuesInput, ...request.Option) (*sqs.ListDeadLetterSourceQueuesOutput, error)

	ListMessageMoveTasksStub func(*sqs.ListMessageMoveTasksInput) (*sqs.ListMessageMoveTasksOutput, error)

	ListMessageMoveTasksRequestStub func(*sqs.ListMessageMoveTasksInput) (*request.Request, *sqs.ListMessageMoveTasksOutput)

	ListMessageMoveTasksWithContextStub func(context.Context, *sqs.ListMessageMoveTasksInput, ...request.Option) (*sqs.ListMessageMoveTasksOutput, error)

	ListQueueTagsStub func(*sqs.ListQueueTagsInput) (*sqs.ListQueueTagsOutput, error)

	ListQueueTagsRequestStub func(*sqs.ListQueueTagsInput) (*request.Request, *sqs.ListQueueTagsOutput)

	ListQueueTagsWithContextStub func(context.Context, *sqs.ListQueueTagsInput, ...request.Option) (*sqs.ListQueueTagsOutput, error)

	ListQueuesStub func(*sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)

	ListQueuesPagesStub func(*sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool) error

	ListQueuesPagesWithContextStub func(context.Context, *sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool, ...request.Option) error

	ListQueuesRequestStub func(*sqs.ListQueuesInput) (*request.Request, *sqs.ListQueuesOutput)

	ListQueuesWithContextStub func(context.Context, *sqs.ListQueuesInput, ...request.Option) (*sqs.ListQueuesOutput, error)

	PurgeQueueStub func(*sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error)

	PurgeQueueRequestStub func(*sqs.PurgeQueueInput) (*request.Request, *sqs.PurgeQueueOutput)

	PurgeQueueWithContextStub func(context.Context, *sqs.PurgeQueueInput, ...request.Option) (*sqs.PurgeQueueOutput, error)

	ReceiveMessageStub func(*sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

	ReceiveMessageRequestStub func(*sqs.ReceiveMessageInput) (*request.Request, *sqs.ReceiveMessageOutput)

	ReceiveMessageWithContextStub func(context.Context, *sqs.ReceiveMessageInput, ...request.Option) (*sqs.ReceiveMessageOutput, error)

	RemovePermissionStub func(*sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error)

	RemovePermissionRequestStub func(*sqs.RemovePermissionInput) (*request.Request, *sqs.RemovePermissionOutput)

	RemovePermissionWithContextStub func(context.Context, *sqs.RemovePermissionInput, ...request.Option) (*sqs.RemovePermissionOutput, error)

	SendMessageStub func(*sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

	SendMessageBatchStub func(*sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

	SendMessageBatchRequestStub func(*sqs.SendMessageBatchInput) (*request.Request, *sqs.SendMessageBatchOutput)

	SendMessageBatchWithContextStub func(context.Context, *sqs.SendMessageBatchInput, ...request.Option) (*sqs.SendMessageBatchOutput, error)

	SendMessageRequestStub func(*sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput)

	SendMessageWithContextStub func(context.Context, *sqs.SendMessageInput, ...request.Option) (*sqs.SendMessageOutput, error)

	SetQueueAttributesStub func(*sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error)

	SetQueueAttributesRequestStub func(*sqs.SetQueueAttributesInput) (*request.Request, *sqs.SetQueueAttributesOutput)

	SetQueueAttributesWithContextStub func(context.Context, *sqs.SetQueueAttributesInput, ...request.Option) (*sqs.SetQueueAttributesOutput, error)

	StartMessageMoveTaskStub func(*sqs.StartMessageMoveTaskInput) (*sqs.StartMessageMoveTaskOutput, error)

	StartMessageMoveTaskRequestStub func(*sqs.StartMessageMoveTaskInput) (*request.Request, *sqs.StartMessageMoveTaskOutput)

	StartMessageMoveTaskWithContextStub func(context.Context, *sqs.StartMessageMoveTaskInput, ...request.Option) (*sqs.StartMessageMoveTaskOutput, error)

	TagQueueStub func(*sqs.TagQueueInput) (*sqs.TagQueueOutput, error)

	TagQueueRequestStub func(*sqs.TagQueueInput) (*request.Request, *sqs.TagQueueOutput)

	TagQueueWithContextStub func(context.Context, *sqs.TagQueueInput, ...request.Option) (*sqs.TagQueueOutput, error)

	UntagQueueStub func(*sqs.UntagQueueInput) (*sqs.UntagQueueOutput, error)

	UntagQueueRequestStub func(*sqs.UntagQueueInput) (*request.Request, *sqs.UntagQueueOutput)

	UntagQueueWithContextStub func(context.Context, *sqs.UntagQueueInput, ...request.Option) (*sqs.UntagQueueOutput, error)
	// contains filtered or unexported fields
}

func (*FakeSQSClient) AddPermission ¶

func (fake *FakeSQSClient) AddPermission(arg1 *sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error)

func (*FakeSQSClient) AddPermissionArgsForCall ¶

func (fake *FakeSQSClient) AddPermissionArgsForCall(i int) *sqs.AddPermissionInput

func (*FakeSQSClient) AddPermissionCallCount ¶

func (fake *FakeSQSClient) AddPermissionCallCount() int

func (*FakeSQSClient) AddPermissionCalls ¶

func (fake *FakeSQSClient) AddPermissionCalls(stub func(*sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error))

func (*FakeSQSClient) AddPermissionRequest ¶

func (fake *FakeSQSClient) AddPermissionRequest(arg1 *sqs.AddPermissionInput) (*request.Request, *sqs.AddPermissionOutput)

func (*FakeSQSClient) AddPermissionRequestArgsForCall ¶

func (fake *FakeSQSClient) AddPermissionRequestArgsForCall(i int) *sqs.AddPermissionInput

func (*FakeSQSClient) AddPermissionRequestCallCount ¶

func (fake *FakeSQSClient) AddPermissionRequestCallCount() int

func (*FakeSQSClient) AddPermissionRequestCalls ¶

func (fake *FakeSQSClient) AddPermissionRequestCalls(stub func(*sqs.AddPermissionInput) (*request.Request, *sqs.AddPermissionOutput))

func (*FakeSQSClient) AddPermissionRequestReturns ¶

func (fake *FakeSQSClient) AddPermissionRequestReturns(result1 *request.Request, result2 *sqs.AddPermissionOutput)

func (*FakeSQSClient) AddPermissionRequestReturnsOnCall ¶

func (fake *FakeSQSClient) AddPermissionRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.AddPermissionOutput)

func (*FakeSQSClient) AddPermissionReturns ¶

func (fake *FakeSQSClient) AddPermissionReturns(result1 *sqs.AddPermissionOutput, result2 error)

func (*FakeSQSClient) AddPermissionReturnsOnCall ¶

func (fake *FakeSQSClient) AddPermissionReturnsOnCall(i int, result1 *sqs.AddPermissionOutput, result2 error)

func (*FakeSQSClient) AddPermissionWithContext ¶

func (fake *FakeSQSClient) AddPermissionWithContext(arg1 context.Context, arg2 *sqs.AddPermissionInput, arg3 ...request.Option) (*sqs.AddPermissionOutput, error)

func (*FakeSQSClient) AddPermissionWithContextArgsForCall ¶

func (fake *FakeSQSClient) AddPermissionWithContextArgsForCall(i int) (context.Context, *sqs.AddPermissionInput, []request.Option)

func (*FakeSQSClient) AddPermissionWithContextCallCount ¶

func (fake *FakeSQSClient) AddPermissionWithContextCallCount() int

func (*FakeSQSClient) AddPermissionWithContextCalls ¶

func (fake *FakeSQSClient) AddPermissionWithContextCalls(stub func(context.Context, *sqs.AddPermissionInput, ...request.Option) (*sqs.AddPermissionOutput, error))

func (*FakeSQSClient) AddPermissionWithContextReturns ¶

func (fake *FakeSQSClient) AddPermissionWithContextReturns(result1 *sqs.AddPermissionOutput, result2 error)

func (*FakeSQSClient) AddPermissionWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) AddPermissionWithContextReturnsOnCall(i int, result1 *sqs.AddPermissionOutput, result2 error)

func (*FakeSQSClient) CancelMessageMoveTask ¶

func (fake *FakeSQSClient) CancelMessageMoveTask(arg1 *sqs.CancelMessageMoveTaskInput) (*sqs.CancelMessageMoveTaskOutput, error)

func (*FakeSQSClient) CancelMessageMoveTaskArgsForCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskArgsForCall(i int) *sqs.CancelMessageMoveTaskInput

func (*FakeSQSClient) CancelMessageMoveTaskCallCount ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskCallCount() int

func (*FakeSQSClient) CancelMessageMoveTaskCalls ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskCalls(stub func(*sqs.CancelMessageMoveTaskInput) (*sqs.CancelMessageMoveTaskOutput, error))

func (*FakeSQSClient) CancelMessageMoveTaskRequest ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequest(arg1 *sqs.CancelMessageMoveTaskInput) (*request.Request, *sqs.CancelMessageMoveTaskOutput)

func (*FakeSQSClient) CancelMessageMoveTaskRequestArgsForCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequestArgsForCall(i int) *sqs.CancelMessageMoveTaskInput

func (*FakeSQSClient) CancelMessageMoveTaskRequestCallCount ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequestCallCount() int

func (*FakeSQSClient) CancelMessageMoveTaskRequestCalls ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequestCalls(stub func(*sqs.CancelMessageMoveTaskInput) (*request.Request, *sqs.CancelMessageMoveTaskOutput))

func (*FakeSQSClient) CancelMessageMoveTaskRequestReturns ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequestReturns(result1 *request.Request, result2 *sqs.CancelMessageMoveTaskOutput)

func (*FakeSQSClient) CancelMessageMoveTaskRequestReturnsOnCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.CancelMessageMoveTaskOutput)

func (*FakeSQSClient) CancelMessageMoveTaskReturns ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskReturns(result1 *sqs.CancelMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) CancelMessageMoveTaskReturnsOnCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskReturnsOnCall(i int, result1 *sqs.CancelMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) CancelMessageMoveTaskWithContext ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContext(arg1 context.Context, arg2 *sqs.CancelMessageMoveTaskInput, arg3 ...request.Option) (*sqs.CancelMessageMoveTaskOutput, error)

func (*FakeSQSClient) CancelMessageMoveTaskWithContextArgsForCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContextArgsForCall(i int) (context.Context, *sqs.CancelMessageMoveTaskInput, []request.Option)

func (*FakeSQSClient) CancelMessageMoveTaskWithContextCallCount ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContextCallCount() int

func (*FakeSQSClient) CancelMessageMoveTaskWithContextCalls ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContextCalls(stub func(context.Context, *sqs.CancelMessageMoveTaskInput, ...request.Option) (*sqs.CancelMessageMoveTaskOutput, error))

func (*FakeSQSClient) CancelMessageMoveTaskWithContextReturns ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContextReturns(result1 *sqs.CancelMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) CancelMessageMoveTaskWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) CancelMessageMoveTaskWithContextReturnsOnCall(i int, result1 *sqs.CancelMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibility ¶

func (fake *FakeSQSClient) ChangeMessageVisibility(arg1 *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)

func (*FakeSQSClient) ChangeMessageVisibilityArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityArgsForCall(i int) *sqs.ChangeMessageVisibilityInput

func (*FakeSQSClient) ChangeMessageVisibilityBatch ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatch(arg1 *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)

func (*FakeSQSClient) ChangeMessageVisibilityBatchArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchArgsForCall(i int) *sqs.ChangeMessageVisibilityBatchInput

func (*FakeSQSClient) ChangeMessageVisibilityBatchCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityBatchCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchCalls(stub func(*sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error))

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequest ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequest(arg1 *sqs.ChangeMessageVisibilityBatchInput) (*request.Request, *sqs.ChangeMessageVisibilityBatchOutput)

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequestArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequestArgsForCall(i int) *sqs.ChangeMessageVisibilityBatchInput

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequestCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequestCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequestCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequestCalls(stub func(*sqs.ChangeMessageVisibilityBatchInput) (*request.Request, *sqs.ChangeMessageVisibilityBatchOutput))

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequestReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequestReturns(result1 *request.Request, result2 *sqs.ChangeMessageVisibilityBatchOutput)

func (*FakeSQSClient) ChangeMessageVisibilityBatchRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ChangeMessageVisibilityBatchOutput)

func (*FakeSQSClient) ChangeMessageVisibilityBatchReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchReturns(result1 *sqs.ChangeMessageVisibilityBatchOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityBatchReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchReturnsOnCall(i int, result1 *sqs.ChangeMessageVisibilityBatchOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContext ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContext(arg1 context.Context, arg2 *sqs.ChangeMessageVisibilityBatchInput, arg3 ...request.Option) (*sqs.ChangeMessageVisibilityBatchOutput, error)

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContextArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContextArgsForCall(i int) (context.Context, *sqs.ChangeMessageVisibilityBatchInput, []request.Option)

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContextCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContextCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContextCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContextCalls(stub func(context.Context, *sqs.ChangeMessageVisibilityBatchInput, ...request.Option) (*sqs.ChangeMessageVisibilityBatchOutput, error))

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContextReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContextReturns(result1 *sqs.ChangeMessageVisibilityBatchOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityBatchWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityBatchWithContextReturnsOnCall(i int, result1 *sqs.ChangeMessageVisibilityBatchOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityCalls(stub func(*sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error))

func (*FakeSQSClient) ChangeMessageVisibilityRequest ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequest(arg1 *sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput)

func (*FakeSQSClient) ChangeMessageVisibilityRequestArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequestArgsForCall(i int) *sqs.ChangeMessageVisibilityInput

func (*FakeSQSClient) ChangeMessageVisibilityRequestCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequestCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityRequestCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequestCalls(stub func(*sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput))

func (*FakeSQSClient) ChangeMessageVisibilityRequestReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequestReturns(result1 *request.Request, result2 *sqs.ChangeMessageVisibilityOutput)

func (*FakeSQSClient) ChangeMessageVisibilityRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ChangeMessageVisibilityOutput)

func (*FakeSQSClient) ChangeMessageVisibilityReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityReturns(result1 *sqs.ChangeMessageVisibilityOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityReturnsOnCall(i int, result1 *sqs.ChangeMessageVisibilityOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityWithContext ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContext(arg1 context.Context, arg2 *sqs.ChangeMessageVisibilityInput, arg3 ...request.Option) (*sqs.ChangeMessageVisibilityOutput, error)

func (*FakeSQSClient) ChangeMessageVisibilityWithContextArgsForCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContextArgsForCall(i int) (context.Context, *sqs.ChangeMessageVisibilityInput, []request.Option)

func (*FakeSQSClient) ChangeMessageVisibilityWithContextCallCount ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContextCallCount() int

func (*FakeSQSClient) ChangeMessageVisibilityWithContextCalls ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContextCalls(stub func(context.Context, *sqs.ChangeMessageVisibilityInput, ...request.Option) (*sqs.ChangeMessageVisibilityOutput, error))

func (*FakeSQSClient) ChangeMessageVisibilityWithContextReturns ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContextReturns(result1 *sqs.ChangeMessageVisibilityOutput, result2 error)

func (*FakeSQSClient) ChangeMessageVisibilityWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ChangeMessageVisibilityWithContextReturnsOnCall(i int, result1 *sqs.ChangeMessageVisibilityOutput, result2 error)

func (*FakeSQSClient) CreateQueue ¶

func (fake *FakeSQSClient) CreateQueue(arg1 *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)

func (*FakeSQSClient) CreateQueueArgsForCall ¶

func (fake *FakeSQSClient) CreateQueueArgsForCall(i int) *sqs.CreateQueueInput

func (*FakeSQSClient) CreateQueueCallCount ¶

func (fake *FakeSQSClient) CreateQueueCallCount() int

func (*FakeSQSClient) CreateQueueCalls ¶

func (fake *FakeSQSClient) CreateQueueCalls(stub func(*sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error))

func (*FakeSQSClient) CreateQueueRequest ¶

func (fake *FakeSQSClient) CreateQueueRequest(arg1 *sqs.CreateQueueInput) (*request.Request, *sqs.CreateQueueOutput)

func (*FakeSQSClient) CreateQueueRequestArgsForCall ¶

func (fake *FakeSQSClient) CreateQueueRequestArgsForCall(i int) *sqs.CreateQueueInput

func (*FakeSQSClient) CreateQueueRequestCallCount ¶

func (fake *FakeSQSClient) CreateQueueRequestCallCount() int

func (*FakeSQSClient) CreateQueueRequestCalls ¶

func (fake *FakeSQSClient) CreateQueueRequestCalls(stub func(*sqs.CreateQueueInput) (*request.Request, *sqs.CreateQueueOutput))

func (*FakeSQSClient) CreateQueueRequestReturns ¶

func (fake *FakeSQSClient) CreateQueueRequestReturns(result1 *request.Request, result2 *sqs.CreateQueueOutput)

func (*FakeSQSClient) CreateQueueRequestReturnsOnCall ¶

func (fake *FakeSQSClient) CreateQueueRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.CreateQueueOutput)

func (*FakeSQSClient) CreateQueueReturns ¶

func (fake *FakeSQSClient) CreateQueueReturns(result1 *sqs.CreateQueueOutput, result2 error)

func (*FakeSQSClient) CreateQueueReturnsOnCall ¶

func (fake *FakeSQSClient) CreateQueueReturnsOnCall(i int, result1 *sqs.CreateQueueOutput, result2 error)

func (*FakeSQSClient) CreateQueueWithContext ¶

func (fake *FakeSQSClient) CreateQueueWithContext(arg1 context.Context, arg2 *sqs.CreateQueueInput, arg3 ...request.Option) (*sqs.CreateQueueOutput, error)

func (*FakeSQSClient) CreateQueueWithContextArgsForCall ¶

func (fake *FakeSQSClient) CreateQueueWithContextArgsForCall(i int) (context.Context, *sqs.CreateQueueInput, []request.Option)

func (*FakeSQSClient) CreateQueueWithContextCallCount ¶

func (fake *FakeSQSClient) CreateQueueWithContextCallCount() int

func (*FakeSQSClient) CreateQueueWithContextCalls ¶

func (fake *FakeSQSClient) CreateQueueWithContextCalls(stub func(context.Context, *sqs.CreateQueueInput, ...request.Option) (*sqs.CreateQueueOutput, error))

func (*FakeSQSClient) CreateQueueWithContextReturns ¶

func (fake *FakeSQSClient) CreateQueueWithContextReturns(result1 *sqs.CreateQueueOutput, result2 error)

func (*FakeSQSClient) CreateQueueWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) CreateQueueWithContextReturnsOnCall(i int, result1 *sqs.CreateQueueOutput, result2 error)

func (*FakeSQSClient) DeleteMessage ¶

func (fake *FakeSQSClient) DeleteMessage(arg1 *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

func (*FakeSQSClient) DeleteMessageArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageArgsForCall(i int) *sqs.DeleteMessageInput

func (*FakeSQSClient) DeleteMessageBatch ¶

func (fake *FakeSQSClient) DeleteMessageBatch(arg1 *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

func (*FakeSQSClient) DeleteMessageBatchArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchArgsForCall(i int) *sqs.DeleteMessageBatchInput

func (*FakeSQSClient) DeleteMessageBatchCallCount ¶

func (fake *FakeSQSClient) DeleteMessageBatchCallCount() int

func (*FakeSQSClient) DeleteMessageBatchCalls ¶

func (fake *FakeSQSClient) DeleteMessageBatchCalls(stub func(*sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error))

func (*FakeSQSClient) DeleteMessageBatchRequest ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequest(arg1 *sqs.DeleteMessageBatchInput) (*request.Request, *sqs.DeleteMessageBatchOutput)

func (*FakeSQSClient) DeleteMessageBatchRequestArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequestArgsForCall(i int) *sqs.DeleteMessageBatchInput

func (*FakeSQSClient) DeleteMessageBatchRequestCallCount ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequestCallCount() int

func (*FakeSQSClient) DeleteMessageBatchRequestCalls ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequestCalls(stub func(*sqs.DeleteMessageBatchInput) (*request.Request, *sqs.DeleteMessageBatchOutput))

func (*FakeSQSClient) DeleteMessageBatchRequestReturns ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequestReturns(result1 *request.Request, result2 *sqs.DeleteMessageBatchOutput)

func (*FakeSQSClient) DeleteMessageBatchRequestReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.DeleteMessageBatchOutput)

func (*FakeSQSClient) DeleteMessageBatchReturns ¶

func (fake *FakeSQSClient) DeleteMessageBatchReturns(result1 *sqs.DeleteMessageBatchOutput, result2 error)

func (*FakeSQSClient) DeleteMessageBatchReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchReturnsOnCall(i int, result1 *sqs.DeleteMessageBatchOutput, result2 error)

func (*FakeSQSClient) DeleteMessageBatchWithContext ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContext(arg1 context.Context, arg2 *sqs.DeleteMessageBatchInput, arg3 ...request.Option) (*sqs.DeleteMessageBatchOutput, error)

func (*FakeSQSClient) DeleteMessageBatchWithContextArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContextArgsForCall(i int) (context.Context, *sqs.DeleteMessageBatchInput, []request.Option)

func (*FakeSQSClient) DeleteMessageBatchWithContextCallCount ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContextCallCount() int

func (*FakeSQSClient) DeleteMessageBatchWithContextCalls ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContextCalls(stub func(context.Context, *sqs.DeleteMessageBatchInput, ...request.Option) (*sqs.DeleteMessageBatchOutput, error))

func (*FakeSQSClient) DeleteMessageBatchWithContextReturns ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContextReturns(result1 *sqs.DeleteMessageBatchOutput, result2 error)

func (*FakeSQSClient) DeleteMessageBatchWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageBatchWithContextReturnsOnCall(i int, result1 *sqs.DeleteMessageBatchOutput, result2 error)

func (*FakeSQSClient) DeleteMessageCallCount ¶

func (fake *FakeSQSClient) DeleteMessageCallCount() int

func (*FakeSQSClient) DeleteMessageCalls ¶

func (fake *FakeSQSClient) DeleteMessageCalls(stub func(*sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error))

func (*FakeSQSClient) DeleteMessageRequest ¶

func (fake *FakeSQSClient) DeleteMessageRequest(arg1 *sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput)

func (*FakeSQSClient) DeleteMessageRequestArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageRequestArgsForCall(i int) *sqs.DeleteMessageInput

func (*FakeSQSClient) DeleteMessageRequestCallCount ¶

func (fake *FakeSQSClient) DeleteMessageRequestCallCount() int

func (*FakeSQSClient) DeleteMessageRequestCalls ¶

func (fake *FakeSQSClient) DeleteMessageRequestCalls(stub func(*sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput))

func (*FakeSQSClient) DeleteMessageRequestReturns ¶

func (fake *FakeSQSClient) DeleteMessageRequestReturns(result1 *request.Request, result2 *sqs.DeleteMessageOutput)

func (*FakeSQSClient) DeleteMessageRequestReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.DeleteMessageOutput)

func (*FakeSQSClient) DeleteMessageReturns ¶

func (fake *FakeSQSClient) DeleteMessageReturns(result1 *sqs.DeleteMessageOutput, result2 error)

func (*FakeSQSClient) DeleteMessageReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageReturnsOnCall(i int, result1 *sqs.DeleteMessageOutput, result2 error)

func (*FakeSQSClient) DeleteMessageWithContext ¶

func (fake *FakeSQSClient) DeleteMessageWithContext(arg1 context.Context, arg2 *sqs.DeleteMessageInput, arg3 ...request.Option) (*sqs.DeleteMessageOutput, error)

func (*FakeSQSClient) DeleteMessageWithContextArgsForCall ¶

func (fake *FakeSQSClient) DeleteMessageWithContextArgsForCall(i int) (context.Context, *sqs.DeleteMessageInput, []request.Option)

func (*FakeSQSClient) DeleteMessageWithContextCallCount ¶

func (fake *FakeSQSClient) DeleteMessageWithContextCallCount() int

func (*FakeSQSClient) DeleteMessageWithContextCalls ¶

func (fake *FakeSQSClient) DeleteMessageWithContextCalls(stub func(context.Context, *sqs.DeleteMessageInput, ...request.Option) (*sqs.DeleteMessageOutput, error))

func (*FakeSQSClient) DeleteMessageWithContextReturns ¶

func (fake *FakeSQSClient) DeleteMessageWithContextReturns(result1 *sqs.DeleteMessageOutput, result2 error)

func (*FakeSQSClient) DeleteMessageWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteMessageWithContextReturnsOnCall(i int, result1 *sqs.DeleteMessageOutput, result2 error)

func (*FakeSQSClient) DeleteQueue ¶

func (fake *FakeSQSClient) DeleteQueue(arg1 *sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error)

func (*FakeSQSClient) DeleteQueueArgsForCall ¶

func (fake *FakeSQSClient) DeleteQueueArgsForCall(i int) *sqs.DeleteQueueInput

func (*FakeSQSClient) DeleteQueueCallCount ¶

func (fake *FakeSQSClient) DeleteQueueCallCount() int

func (*FakeSQSClient) DeleteQueueCalls ¶

func (fake *FakeSQSClient) DeleteQueueCalls(stub func(*sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error))

func (*FakeSQSClient) DeleteQueueRequest ¶

func (fake *FakeSQSClient) DeleteQueueRequest(arg1 *sqs.DeleteQueueInput) (*request.Request, *sqs.DeleteQueueOutput)

func (*FakeSQSClient) DeleteQueueRequestArgsForCall ¶

func (fake *FakeSQSClient) DeleteQueueRequestArgsForCall(i int) *sqs.DeleteQueueInput

func (*FakeSQSClient) DeleteQueueRequestCallCount ¶

func (fake *FakeSQSClient) DeleteQueueRequestCallCount() int

func (*FakeSQSClient) DeleteQueueRequestCalls ¶

func (fake *FakeSQSClient) DeleteQueueRequestCalls(stub func(*sqs.DeleteQueueInput) (*request.Request, *sqs.DeleteQueueOutput))

func (*FakeSQSClient) DeleteQueueRequestReturns ¶

func (fake *FakeSQSClient) DeleteQueueRequestReturns(result1 *request.Request, result2 *sqs.DeleteQueueOutput)

func (*FakeSQSClient) DeleteQueueRequestReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteQueueRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.DeleteQueueOutput)

func (*FakeSQSClient) DeleteQueueReturns ¶

func (fake *FakeSQSClient) DeleteQueueReturns(result1 *sqs.DeleteQueueOutput, result2 error)

func (*FakeSQSClient) DeleteQueueReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteQueueReturnsOnCall(i int, result1 *sqs.DeleteQueueOutput, result2 error)

func (*FakeSQSClient) DeleteQueueWithContext ¶

func (fake *FakeSQSClient) DeleteQueueWithContext(arg1 context.Context, arg2 *sqs.DeleteQueueInput, arg3 ...request.Option) (*sqs.DeleteQueueOutput, error)

func (*FakeSQSClient) DeleteQueueWithContextArgsForCall ¶

func (fake *FakeSQSClient) DeleteQueueWithContextArgsForCall(i int) (context.Context, *sqs.DeleteQueueInput, []request.Option)

func (*FakeSQSClient) DeleteQueueWithContextCallCount ¶

func (fake *FakeSQSClient) DeleteQueueWithContextCallCount() int

func (*FakeSQSClient) DeleteQueueWithContextCalls ¶

func (fake *FakeSQSClient) DeleteQueueWithContextCalls(stub func(context.Context, *sqs.DeleteQueueInput, ...request.Option) (*sqs.DeleteQueueOutput, error))

func (*FakeSQSClient) DeleteQueueWithContextReturns ¶

func (fake *FakeSQSClient) DeleteQueueWithContextReturns(result1 *sqs.DeleteQueueOutput, result2 error)

func (*FakeSQSClient) DeleteQueueWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) DeleteQueueWithContextReturnsOnCall(i int, result1 *sqs.DeleteQueueOutput, result2 error)

func (*FakeSQSClient) GetQueueAttributes ¶

func (fake *FakeSQSClient) GetQueueAttributes(arg1 *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)

func (*FakeSQSClient) GetQueueAttributesArgsForCall ¶

func (fake *FakeSQSClient) GetQueueAttributesArgsForCall(i int) *sqs.GetQueueAttributesInput

func (*FakeSQSClient) GetQueueAttributesCallCount ¶

func (fake *FakeSQSClient) GetQueueAttributesCallCount() int

func (*FakeSQSClient) GetQueueAttributesCalls ¶

func (fake *FakeSQSClient) GetQueueAttributesCalls(stub func(*sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error))

func (*FakeSQSClient) GetQueueAttributesRequest ¶

func (fake *FakeSQSClient) GetQueueAttributesRequest(arg1 *sqs.GetQueueAttributesInput) (*request.Request, *sqs.GetQueueAttributesOutput)

func (*FakeSQSClient) GetQueueAttributesRequestArgsForCall ¶

func (fake *FakeSQSClient) GetQueueAttributesRequestArgsForCall(i int) *sqs.GetQueueAttributesInput

func (*FakeSQSClient) GetQueueAttributesRequestCallCount ¶

func (fake *FakeSQSClient) GetQueueAttributesRequestCallCount() int

func (*FakeSQSClient) GetQueueAttributesRequestCalls ¶

func (fake *FakeSQSClient) GetQueueAttributesRequestCalls(stub func(*sqs.GetQueueAttributesInput) (*request.Request, *sqs.GetQueueAttributesOutput))

func (*FakeSQSClient) GetQueueAttributesRequestReturns ¶

func (fake *FakeSQSClient) GetQueueAttributesRequestReturns(result1 *request.Request, result2 *sqs.GetQueueAttributesOutput)

func (*FakeSQSClient) GetQueueAttributesRequestReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueAttributesRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.GetQueueAttributesOutput)

func (*FakeSQSClient) GetQueueAttributesReturns ¶

func (fake *FakeSQSClient) GetQueueAttributesReturns(result1 *sqs.GetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) GetQueueAttributesReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueAttributesReturnsOnCall(i int, result1 *sqs.GetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) GetQueueAttributesWithContext ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContext(arg1 context.Context, arg2 *sqs.GetQueueAttributesInput, arg3 ...request.Option) (*sqs.GetQueueAttributesOutput, error)

func (*FakeSQSClient) GetQueueAttributesWithContextArgsForCall ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContextArgsForCall(i int) (context.Context, *sqs.GetQueueAttributesInput, []request.Option)

func (*FakeSQSClient) GetQueueAttributesWithContextCallCount ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContextCallCount() int

func (*FakeSQSClient) GetQueueAttributesWithContextCalls ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContextCalls(stub func(context.Context, *sqs.GetQueueAttributesInput, ...request.Option) (*sqs.GetQueueAttributesOutput, error))

func (*FakeSQSClient) GetQueueAttributesWithContextReturns ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContextReturns(result1 *sqs.GetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) GetQueueAttributesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueAttributesWithContextReturnsOnCall(i int, result1 *sqs.GetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) GetQueueUrl ¶

func (fake *FakeSQSClient) GetQueueUrl(arg1 *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)

func (*FakeSQSClient) GetQueueUrlArgsForCall ¶

func (fake *FakeSQSClient) GetQueueUrlArgsForCall(i int) *sqs.GetQueueUrlInput

func (*FakeSQSClient) GetQueueUrlCallCount ¶

func (fake *FakeSQSClient) GetQueueUrlCallCount() int

func (*FakeSQSClient) GetQueueUrlCalls ¶

func (fake *FakeSQSClient) GetQueueUrlCalls(stub func(*sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error))

func (*FakeSQSClient) GetQueueUrlRequest ¶

func (fake *FakeSQSClient) GetQueueUrlRequest(arg1 *sqs.GetQueueUrlInput) (*request.Request, *sqs.GetQueueUrlOutput)

func (*FakeSQSClient) GetQueueUrlRequestArgsForCall ¶

func (fake *FakeSQSClient) GetQueueUrlRequestArgsForCall(i int) *sqs.GetQueueUrlInput

func (*FakeSQSClient) GetQueueUrlRequestCallCount ¶

func (fake *FakeSQSClient) GetQueueUrlRequestCallCount() int

func (*FakeSQSClient) GetQueueUrlRequestCalls ¶

func (fake *FakeSQSClient) GetQueueUrlRequestCalls(stub func(*sqs.GetQueueUrlInput) (*request.Request, *sqs.GetQueueUrlOutput))

func (*FakeSQSClient) GetQueueUrlRequestReturns ¶

func (fake *FakeSQSClient) GetQueueUrlRequestReturns(result1 *request.Request, result2 *sqs.GetQueueUrlOutput)

func (*FakeSQSClient) GetQueueUrlRequestReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueUrlRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.GetQueueUrlOutput)

func (*FakeSQSClient) GetQueueUrlReturns ¶

func (fake *FakeSQSClient) GetQueueUrlReturns(result1 *sqs.GetQueueUrlOutput, result2 error)

func (*FakeSQSClient) GetQueueUrlReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueUrlReturnsOnCall(i int, result1 *sqs.GetQueueUrlOutput, result2 error)

func (*FakeSQSClient) GetQueueUrlWithContext ¶

func (fake *FakeSQSClient) GetQueueUrlWithContext(arg1 context.Context, arg2 *sqs.GetQueueUrlInput, arg3 ...request.Option) (*sqs.GetQueueUrlOutput, error)

func (*FakeSQSClient) GetQueueUrlWithContextArgsForCall ¶

func (fake *FakeSQSClient) GetQueueUrlWithContextArgsForCall(i int) (context.Context, *sqs.GetQueueUrlInput, []request.Option)

func (*FakeSQSClient) GetQueueUrlWithContextCallCount ¶

func (fake *FakeSQSClient) GetQueueUrlWithContextCallCount() int

func (*FakeSQSClient) GetQueueUrlWithContextCalls ¶

func (fake *FakeSQSClient) GetQueueUrlWithContextCalls(stub func(context.Context, *sqs.GetQueueUrlInput, ...request.Option) (*sqs.GetQueueUrlOutput, error))

func (*FakeSQSClient) GetQueueUrlWithContextReturns ¶

func (fake *FakeSQSClient) GetQueueUrlWithContextReturns(result1 *sqs.GetQueueUrlOutput, result2 error)

func (*FakeSQSClient) GetQueueUrlWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) GetQueueUrlWithContextReturnsOnCall(i int, result1 *sqs.GetQueueUrlOutput, result2 error)

func (*FakeSQSClient) Invocations ¶

func (fake *FakeSQSClient) Invocations() map[string][][]interface{}

func (*FakeSQSClient) ListDeadLetterSourceQueues ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueues(arg1 *sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesArgsForCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesArgsForCall(i int) *sqs.ListDeadLetterSourceQueuesInput

func (*FakeSQSClient) ListDeadLetterSourceQueuesCallCount ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesCallCount() int

func (*FakeSQSClient) ListDeadLetterSourceQueuesCalls ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesCalls(stub func(*sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error))

func (*FakeSQSClient) ListDeadLetterSourceQueuesPages ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPages(arg1 *sqs.ListDeadLetterSourceQueuesInput, arg2 func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool) error

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesArgsForCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesArgsForCall(i int) (*sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesCallCount ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesCallCount() int

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesCalls ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesCalls(stub func(*sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool) error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesReturns ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesReturns(result1 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesReturnsOnCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesReturnsOnCall(i int, result1 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContext ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContext(arg1 context.Context, arg2 *sqs.ListDeadLetterSourceQueuesInput, arg3 func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool, arg4 ...request.Option) error

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextArgsForCall(i int) (context.Context, *sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool, []request.Option)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextCallCount ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextCallCount() int

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextCalls ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextCalls(stub func(context.Context, *sqs.ListDeadLetterSourceQueuesInput, func(*sqs.ListDeadLetterSourceQueuesOutput, bool) bool, ...request.Option) error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextReturns ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextReturns(result1 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesPagesWithContextReturnsOnCall(i int, result1 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequest ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequest(arg1 *sqs.ListDeadLetterSourceQueuesInput) (*request.Request, *sqs.ListDeadLetterSourceQueuesOutput)

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequestArgsForCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequestArgsForCall(i int) *sqs.ListDeadLetterSourceQueuesInput

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequestCallCount ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequestCallCount() int

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequestCalls ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequestCalls(stub func(*sqs.ListDeadLetterSourceQueuesInput) (*request.Request, *sqs.ListDeadLetterSourceQueuesOutput))

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequestReturns ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequestReturns(result1 *request.Request, result2 *sqs.ListDeadLetterSourceQueuesOutput)

func (*FakeSQSClient) ListDeadLetterSourceQueuesRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ListDeadLetterSourceQueuesOutput)

func (*FakeSQSClient) ListDeadLetterSourceQueuesReturns ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesReturns(result1 *sqs.ListDeadLetterSourceQueuesOutput, result2 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesReturnsOnCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesReturnsOnCall(i int, result1 *sqs.ListDeadLetterSourceQueuesOutput, result2 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContext ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContext(arg1 context.Context, arg2 *sqs.ListDeadLetterSourceQueuesInput, arg3 ...request.Option) (*sqs.ListDeadLetterSourceQueuesOutput, error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContextArgsForCall(i int) (context.Context, *sqs.ListDeadLetterSourceQueuesInput, []request.Option)

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContextCallCount ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContextCallCount() int

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContextCalls ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContextCalls(stub func(context.Context, *sqs.ListDeadLetterSourceQueuesInput, ...request.Option) (*sqs.ListDeadLetterSourceQueuesOutput, error))

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContextReturns ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContextReturns(result1 *sqs.ListDeadLetterSourceQueuesOutput, result2 error)

func (*FakeSQSClient) ListDeadLetterSourceQueuesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListDeadLetterSourceQueuesWithContextReturnsOnCall(i int, result1 *sqs.ListDeadLetterSourceQueuesOutput, result2 error)

func (*FakeSQSClient) ListMessageMoveTasks ¶

func (fake *FakeSQSClient) ListMessageMoveTasks(arg1 *sqs.ListMessageMoveTasksInput) (*sqs.ListMessageMoveTasksOutput, error)

func (*FakeSQSClient) ListMessageMoveTasksArgsForCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksArgsForCall(i int) *sqs.ListMessageMoveTasksInput

func (*FakeSQSClient) ListMessageMoveTasksCallCount ¶

func (fake *FakeSQSClient) ListMessageMoveTasksCallCount() int

func (*FakeSQSClient) ListMessageMoveTasksCalls ¶

func (fake *FakeSQSClient) ListMessageMoveTasksCalls(stub func(*sqs.ListMessageMoveTasksInput) (*sqs.ListMessageMoveTasksOutput, error))

func (*FakeSQSClient) ListMessageMoveTasksRequest ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequest(arg1 *sqs.ListMessageMoveTasksInput) (*request.Request, *sqs.ListMessageMoveTasksOutput)

func (*FakeSQSClient) ListMessageMoveTasksRequestArgsForCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequestArgsForCall(i int) *sqs.ListMessageMoveTasksInput

func (*FakeSQSClient) ListMessageMoveTasksRequestCallCount ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequestCallCount() int

func (*FakeSQSClient) ListMessageMoveTasksRequestCalls ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequestCalls(stub func(*sqs.ListMessageMoveTasksInput) (*request.Request, *sqs.ListMessageMoveTasksOutput))

func (*FakeSQSClient) ListMessageMoveTasksRequestReturns ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequestReturns(result1 *request.Request, result2 *sqs.ListMessageMoveTasksOutput)

func (*FakeSQSClient) ListMessageMoveTasksRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ListMessageMoveTasksOutput)

func (*FakeSQSClient) ListMessageMoveTasksReturns ¶

func (fake *FakeSQSClient) ListMessageMoveTasksReturns(result1 *sqs.ListMessageMoveTasksOutput, result2 error)

func (*FakeSQSClient) ListMessageMoveTasksReturnsOnCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksReturnsOnCall(i int, result1 *sqs.ListMessageMoveTasksOutput, result2 error)

func (*FakeSQSClient) ListMessageMoveTasksWithContext ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContext(arg1 context.Context, arg2 *sqs.ListMessageMoveTasksInput, arg3 ...request.Option) (*sqs.ListMessageMoveTasksOutput, error)

func (*FakeSQSClient) ListMessageMoveTasksWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContextArgsForCall(i int) (context.Context, *sqs.ListMessageMoveTasksInput, []request.Option)

func (*FakeSQSClient) ListMessageMoveTasksWithContextCallCount ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContextCallCount() int

func (*FakeSQSClient) ListMessageMoveTasksWithContextCalls ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContextCalls(stub func(context.Context, *sqs.ListMessageMoveTasksInput, ...request.Option) (*sqs.ListMessageMoveTasksOutput, error))

func (*FakeSQSClient) ListMessageMoveTasksWithContextReturns ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContextReturns(result1 *sqs.ListMessageMoveTasksOutput, result2 error)

func (*FakeSQSClient) ListMessageMoveTasksWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListMessageMoveTasksWithContextReturnsOnCall(i int, result1 *sqs.ListMessageMoveTasksOutput, result2 error)

func (*FakeSQSClient) ListQueueTags ¶

func (fake *FakeSQSClient) ListQueueTags(arg1 *sqs.ListQueueTagsInput) (*sqs.ListQueueTagsOutput, error)

func (*FakeSQSClient) ListQueueTagsArgsForCall ¶

func (fake *FakeSQSClient) ListQueueTagsArgsForCall(i int) *sqs.ListQueueTagsInput

func (*FakeSQSClient) ListQueueTagsCallCount ¶

func (fake *FakeSQSClient) ListQueueTagsCallCount() int

func (*FakeSQSClient) ListQueueTagsCalls ¶

func (fake *FakeSQSClient) ListQueueTagsCalls(stub func(*sqs.ListQueueTagsInput) (*sqs.ListQueueTagsOutput, error))

func (*FakeSQSClient) ListQueueTagsRequest ¶

func (fake *FakeSQSClient) ListQueueTagsRequest(arg1 *sqs.ListQueueTagsInput) (*request.Request, *sqs.ListQueueTagsOutput)

func (*FakeSQSClient) ListQueueTagsRequestArgsForCall ¶

func (fake *FakeSQSClient) ListQueueTagsRequestArgsForCall(i int) *sqs.ListQueueTagsInput

func (*FakeSQSClient) ListQueueTagsRequestCallCount ¶

func (fake *FakeSQSClient) ListQueueTagsRequestCallCount() int

func (*FakeSQSClient) ListQueueTagsRequestCalls ¶

func (fake *FakeSQSClient) ListQueueTagsRequestCalls(stub func(*sqs.ListQueueTagsInput) (*request.Request, *sqs.ListQueueTagsOutput))

func (*FakeSQSClient) ListQueueTagsRequestReturns ¶

func (fake *FakeSQSClient) ListQueueTagsRequestReturns(result1 *request.Request, result2 *sqs.ListQueueTagsOutput)

func (*FakeSQSClient) ListQueueTagsRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueueTagsRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ListQueueTagsOutput)

func (*FakeSQSClient) ListQueueTagsReturns ¶

func (fake *FakeSQSClient) ListQueueTagsReturns(result1 *sqs.ListQueueTagsOutput, result2 error)

func (*FakeSQSClient) ListQueueTagsReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueueTagsReturnsOnCall(i int, result1 *sqs.ListQueueTagsOutput, result2 error)

func (*FakeSQSClient) ListQueueTagsWithContext ¶

func (fake *FakeSQSClient) ListQueueTagsWithContext(arg1 context.Context, arg2 *sqs.ListQueueTagsInput, arg3 ...request.Option) (*sqs.ListQueueTagsOutput, error)

func (*FakeSQSClient) ListQueueTagsWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListQueueTagsWithContextArgsForCall(i int) (context.Context, *sqs.ListQueueTagsInput, []request.Option)

func (*FakeSQSClient) ListQueueTagsWithContextCallCount ¶

func (fake *FakeSQSClient) ListQueueTagsWithContextCallCount() int

func (*FakeSQSClient) ListQueueTagsWithContextCalls ¶

func (fake *FakeSQSClient) ListQueueTagsWithContextCalls(stub func(context.Context, *sqs.ListQueueTagsInput, ...request.Option) (*sqs.ListQueueTagsOutput, error))

func (*FakeSQSClient) ListQueueTagsWithContextReturns ¶

func (fake *FakeSQSClient) ListQueueTagsWithContextReturns(result1 *sqs.ListQueueTagsOutput, result2 error)

func (*FakeSQSClient) ListQueueTagsWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueueTagsWithContextReturnsOnCall(i int, result1 *sqs.ListQueueTagsOutput, result2 error)

func (*FakeSQSClient) ListQueues ¶

func (fake *FakeSQSClient) ListQueues(arg1 *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)

func (*FakeSQSClient) ListQueuesArgsForCall ¶

func (fake *FakeSQSClient) ListQueuesArgsForCall(i int) *sqs.ListQueuesInput

func (*FakeSQSClient) ListQueuesCallCount ¶

func (fake *FakeSQSClient) ListQueuesCallCount() int

func (*FakeSQSClient) ListQueuesCalls ¶

func (fake *FakeSQSClient) ListQueuesCalls(stub func(*sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error))

func (*FakeSQSClient) ListQueuesPages ¶

func (fake *FakeSQSClient) ListQueuesPages(arg1 *sqs.ListQueuesInput, arg2 func(*sqs.ListQueuesOutput, bool) bool) error

func (*FakeSQSClient) ListQueuesPagesArgsForCall ¶

func (fake *FakeSQSClient) ListQueuesPagesArgsForCall(i int) (*sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool)

func (*FakeSQSClient) ListQueuesPagesCallCount ¶

func (fake *FakeSQSClient) ListQueuesPagesCallCount() int

func (*FakeSQSClient) ListQueuesPagesCalls ¶

func (fake *FakeSQSClient) ListQueuesPagesCalls(stub func(*sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool) error)

func (*FakeSQSClient) ListQueuesPagesReturns ¶

func (fake *FakeSQSClient) ListQueuesPagesReturns(result1 error)

func (*FakeSQSClient) ListQueuesPagesReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueuesPagesReturnsOnCall(i int, result1 error)

func (*FakeSQSClient) ListQueuesPagesWithContext ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContext(arg1 context.Context, arg2 *sqs.ListQueuesInput, arg3 func(*sqs.ListQueuesOutput, bool) bool, arg4 ...request.Option) error

func (*FakeSQSClient) ListQueuesPagesWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContextArgsForCall(i int) (context.Context, *sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool, []request.Option)

func (*FakeSQSClient) ListQueuesPagesWithContextCallCount ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContextCallCount() int

func (*FakeSQSClient) ListQueuesPagesWithContextCalls ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContextCalls(stub func(context.Context, *sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool, ...request.Option) error)

func (*FakeSQSClient) ListQueuesPagesWithContextReturns ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContextReturns(result1 error)

func (*FakeSQSClient) ListQueuesPagesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueuesPagesWithContextReturnsOnCall(i int, result1 error)

func (*FakeSQSClient) ListQueuesRequest ¶

func (fake *FakeSQSClient) ListQueuesRequest(arg1 *sqs.ListQueuesInput) (*request.Request, *sqs.ListQueuesOutput)

func (*FakeSQSClient) ListQueuesRequestArgsForCall ¶

func (fake *FakeSQSClient) ListQueuesRequestArgsForCall(i int) *sqs.ListQueuesInput

func (*FakeSQSClient) ListQueuesRequestCallCount ¶

func (fake *FakeSQSClient) ListQueuesRequestCallCount() int

func (*FakeSQSClient) ListQueuesRequestCalls ¶

func (fake *FakeSQSClient) ListQueuesRequestCalls(stub func(*sqs.ListQueuesInput) (*request.Request, *sqs.ListQueuesOutput))

func (*FakeSQSClient) ListQueuesRequestReturns ¶

func (fake *FakeSQSClient) ListQueuesRequestReturns(result1 *request.Request, result2 *sqs.ListQueuesOutput)

func (*FakeSQSClient) ListQueuesRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueuesRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ListQueuesOutput)

func (*FakeSQSClient) ListQueuesReturns ¶

func (fake *FakeSQSClient) ListQueuesReturns(result1 *sqs.ListQueuesOutput, result2 error)

func (*FakeSQSClient) ListQueuesReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueuesReturnsOnCall(i int, result1 *sqs.ListQueuesOutput, result2 error)

func (*FakeSQSClient) ListQueuesWithContext ¶

func (fake *FakeSQSClient) ListQueuesWithContext(arg1 context.Context, arg2 *sqs.ListQueuesInput, arg3 ...request.Option) (*sqs.ListQueuesOutput, error)

func (*FakeSQSClient) ListQueuesWithContextArgsForCall ¶

func (fake *FakeSQSClient) ListQueuesWithContextArgsForCall(i int) (context.Context, *sqs.ListQueuesInput, []request.Option)

func (*FakeSQSClient) ListQueuesWithContextCallCount ¶

func (fake *FakeSQSClient) ListQueuesWithContextCallCount() int

func (*FakeSQSClient) ListQueuesWithContextCalls ¶

func (fake *FakeSQSClient) ListQueuesWithContextCalls(stub func(context.Context, *sqs.ListQueuesInput, ...request.Option) (*sqs.ListQueuesOutput, error))

func (*FakeSQSClient) ListQueuesWithContextReturns ¶

func (fake *FakeSQSClient) ListQueuesWithContextReturns(result1 *sqs.ListQueuesOutput, result2 error)

func (*FakeSQSClient) ListQueuesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ListQueuesWithContextReturnsOnCall(i int, result1 *sqs.ListQueuesOutput, result2 error)

func (*FakeSQSClient) PurgeQueue ¶

func (fake *FakeSQSClient) PurgeQueue(arg1 *sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error)

func (*FakeSQSClient) PurgeQueueArgsForCall ¶

func (fake *FakeSQSClient) PurgeQueueArgsForCall(i int) *sqs.PurgeQueueInput

func (*FakeSQSClient) PurgeQueueCallCount ¶

func (fake *FakeSQSClient) PurgeQueueCallCount() int

func (*FakeSQSClient) PurgeQueueCalls ¶

func (fake *FakeSQSClient) PurgeQueueCalls(stub func(*sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error))

func (*FakeSQSClient) PurgeQueueRequest ¶

func (fake *FakeSQSClient) PurgeQueueRequest(arg1 *sqs.PurgeQueueInput) (*request.Request, *sqs.PurgeQueueOutput)

func (*FakeSQSClient) PurgeQueueRequestArgsForCall ¶

func (fake *FakeSQSClient) PurgeQueueRequestArgsForCall(i int) *sqs.PurgeQueueInput

func (*FakeSQSClient) PurgeQueueRequestCallCount ¶

func (fake *FakeSQSClient) PurgeQueueRequestCallCount() int

func (*FakeSQSClient) PurgeQueueRequestCalls ¶

func (fake *FakeSQSClient) PurgeQueueRequestCalls(stub func(*sqs.PurgeQueueInput) (*request.Request, *sqs.PurgeQueueOutput))

func (*FakeSQSClient) PurgeQueueRequestReturns ¶

func (fake *FakeSQSClient) PurgeQueueRequestReturns(result1 *request.Request, result2 *sqs.PurgeQueueOutput)

func (*FakeSQSClient) PurgeQueueRequestReturnsOnCall ¶

func (fake *FakeSQSClient) PurgeQueueRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.PurgeQueueOutput)

func (*FakeSQSClient) PurgeQueueReturns ¶

func (fake *FakeSQSClient) PurgeQueueReturns(result1 *sqs.PurgeQueueOutput, result2 error)

func (*FakeSQSClient) PurgeQueueReturnsOnCall ¶

func (fake *FakeSQSClient) PurgeQueueReturnsOnCall(i int, result1 *sqs.PurgeQueueOutput, result2 error)

func (*FakeSQSClient) PurgeQueueWithContext ¶

func (fake *FakeSQSClient) PurgeQueueWithContext(arg1 context.Context, arg2 *sqs.PurgeQueueInput, arg3 ...request.Option) (*sqs.PurgeQueueOutput, error)

func (*FakeSQSClient) PurgeQueueWithContextArgsForCall ¶

func (fake *FakeSQSClient) PurgeQueueWithContextArgsForCall(i int) (context.Context, *sqs.PurgeQueueInput, []request.Option)

func (*FakeSQSClient) PurgeQueueWithContextCallCount ¶

func (fake *FakeSQSClient) PurgeQueueWithContextCallCount() int

func (*FakeSQSClient) PurgeQueueWithContextCalls ¶

func (fake *FakeSQSClient) PurgeQueueWithContextCalls(stub func(context.Context, *sqs.PurgeQueueInput, ...request.Option) (*sqs.PurgeQueueOutput, error))

func (*FakeSQSClient) PurgeQueueWithContextReturns ¶

func (fake *FakeSQSClient) PurgeQueueWithContextReturns(result1 *sqs.PurgeQueueOutput, result2 error)

func (*FakeSQSClient) PurgeQueueWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) PurgeQueueWithContextReturnsOnCall(i int, result1 *sqs.PurgeQueueOutput, result2 error)

func (*FakeSQSClient) ReceiveMessage ¶

func (fake *FakeSQSClient) ReceiveMessage(arg1 *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func (*FakeSQSClient) ReceiveMessageArgsForCall ¶

func (fake *FakeSQSClient) ReceiveMessageArgsForCall(i int) *sqs.ReceiveMessageInput

func (*FakeSQSClient) ReceiveMessageCallCount ¶

func (fake *FakeSQSClient) ReceiveMessageCallCount() int

func (*FakeSQSClient) ReceiveMessageCalls ¶

func (fake *FakeSQSClient) ReceiveMessageCalls(stub func(*sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error))

func (*FakeSQSClient) ReceiveMessageRequest ¶

func (fake *FakeSQSClient) ReceiveMessageRequest(arg1 *sqs.ReceiveMessageInput) (*request.Request, *sqs.ReceiveMessageOutput)

func (*FakeSQSClient) ReceiveMessageRequestArgsForCall ¶

func (fake *FakeSQSClient) ReceiveMessageRequestArgsForCall(i int) *sqs.ReceiveMessageInput

func (*FakeSQSClient) ReceiveMessageRequestCallCount ¶

func (fake *FakeSQSClient) ReceiveMessageRequestCallCount() int

func (*FakeSQSClient) ReceiveMessageRequestCalls ¶

func (fake *FakeSQSClient) ReceiveMessageRequestCalls(stub func(*sqs.ReceiveMessageInput) (*request.Request, *sqs.ReceiveMessageOutput))

func (*FakeSQSClient) ReceiveMessageRequestReturns ¶

func (fake *FakeSQSClient) ReceiveMessageRequestReturns(result1 *request.Request, result2 *sqs.ReceiveMessageOutput)

func (*FakeSQSClient) ReceiveMessageRequestReturnsOnCall ¶

func (fake *FakeSQSClient) ReceiveMessageRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.ReceiveMessageOutput)

func (*FakeSQSClient) ReceiveMessageReturns ¶

func (fake *FakeSQSClient) ReceiveMessageReturns(result1 *sqs.ReceiveMessageOutput, result2 error)

func (*FakeSQSClient) ReceiveMessageReturnsOnCall ¶

func (fake *FakeSQSClient) ReceiveMessageReturnsOnCall(i int, result1 *sqs.ReceiveMessageOutput, result2 error)

func (*FakeSQSClient) ReceiveMessageWithContext ¶

func (fake *FakeSQSClient) ReceiveMessageWithContext(arg1 context.Context, arg2 *sqs.ReceiveMessageInput, arg3 ...request.Option) (*sqs.ReceiveMessageOutput, error)

func (*FakeSQSClient) ReceiveMessageWithContextArgsForCall ¶

func (fake *FakeSQSClient) ReceiveMessageWithContextArgsForCall(i int) (context.Context, *sqs.ReceiveMessageInput, []request.Option)

func (*FakeSQSClient) ReceiveMessageWithContextCallCount ¶

func (fake *FakeSQSClient) ReceiveMessageWithContextCallCount() int

func (*FakeSQSClient) ReceiveMessageWithContextCalls ¶

func (fake *FakeSQSClient) ReceiveMessageWithContextCalls(stub func(context.Context, *sqs.ReceiveMessageInput, ...request.Option) (*sqs.ReceiveMessageOutput, error))

func (*FakeSQSClient) ReceiveMessageWithContextReturns ¶

func (fake *FakeSQSClient) ReceiveMessageWithContextReturns(result1 *sqs.ReceiveMessageOutput, result2 error)

func (*FakeSQSClient) ReceiveMessageWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) ReceiveMessageWithContextReturnsOnCall(i int, result1 *sqs.ReceiveMessageOutput, result2 error)

func (*FakeSQSClient) RemovePermission ¶

func (fake *FakeSQSClient) RemovePermission(arg1 *sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error)

func (*FakeSQSClient) RemovePermissionArgsForCall ¶

func (fake *FakeSQSClient) RemovePermissionArgsForCall(i int) *sqs.RemovePermissionInput

func (*FakeSQSClient) RemovePermissionCallCount ¶

func (fake *FakeSQSClient) RemovePermissionCallCount() int

func (*FakeSQSClient) RemovePermissionCalls ¶

func (fake *FakeSQSClient) RemovePermissionCalls(stub func(*sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error))

func (*FakeSQSClient) RemovePermissionRequest ¶

func (fake *FakeSQSClient) RemovePermissionRequest(arg1 *sqs.RemovePermissionInput) (*request.Request, *sqs.RemovePermissionOutput)

func (*FakeSQSClient) RemovePermissionRequestArgsForCall ¶

func (fake *FakeSQSClient) RemovePermissionRequestArgsForCall(i int) *sqs.RemovePermissionInput

func (*FakeSQSClient) RemovePermissionRequestCallCount ¶

func (fake *FakeSQSClient) RemovePermissionRequestCallCount() int

func (*FakeSQSClient) RemovePermissionRequestCalls ¶

func (fake *FakeSQSClient) RemovePermissionRequestCalls(stub func(*sqs.RemovePermissionInput) (*request.Request, *sqs.RemovePermissionOutput))

func (*FakeSQSClient) RemovePermissionRequestReturns ¶

func (fake *FakeSQSClient) RemovePermissionRequestReturns(result1 *request.Request, result2 *sqs.RemovePermissionOutput)

func (*FakeSQSClient) RemovePermissionRequestReturnsOnCall ¶

func (fake *FakeSQSClient) RemovePermissionRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.RemovePermissionOutput)

func (*FakeSQSClient) RemovePermissionReturns ¶

func (fake *FakeSQSClient) RemovePermissionReturns(result1 *sqs.RemovePermissionOutput, result2 error)

func (*FakeSQSClient) RemovePermissionReturnsOnCall ¶

func (fake *FakeSQSClient) RemovePermissionReturnsOnCall(i int, result1 *sqs.RemovePermissionOutput, result2 error)

func (*FakeSQSClient) RemovePermissionWithContext ¶

func (fake *FakeSQSClient) RemovePermissionWithContext(arg1 context.Context, arg2 *sqs.RemovePermissionInput, arg3 ...request.Option) (*sqs.RemovePermissionOutput, error)

func (*FakeSQSClient) RemovePermissionWithContextArgsForCall ¶

func (fake *FakeSQSClient) RemovePermissionWithContextArgsForCall(i int) (context.Context, *sqs.RemovePermissionInput, []request.Option)

func (*FakeSQSClient) RemovePermissionWithContextCallCount ¶

func (fake *FakeSQSClient) RemovePermissionWithContextCallCount() int

func (*FakeSQSClient) RemovePermissionWithContextCalls ¶

func (fake *FakeSQSClient) RemovePermissionWithContextCalls(stub func(context.Context, *sqs.RemovePermissionInput, ...request.Option) (*sqs.RemovePermissionOutput, error))

func (*FakeSQSClient) RemovePermissionWithContextReturns ¶

func (fake *FakeSQSClient) RemovePermissionWithContextReturns(result1 *sqs.RemovePermissionOutput, result2 error)

func (*FakeSQSClient) RemovePermissionWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) RemovePermissionWithContextReturnsOnCall(i int, result1 *sqs.RemovePermissionOutput, result2 error)

func (*FakeSQSClient) SendMessage ¶

func (fake *FakeSQSClient) SendMessage(arg1 *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

func (*FakeSQSClient) SendMessageArgsForCall ¶

func (fake *FakeSQSClient) SendMessageArgsForCall(i int) *sqs.SendMessageInput

func (*FakeSQSClient) SendMessageBatch ¶

func (fake *FakeSQSClient) SendMessageBatch(arg1 *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

func (*FakeSQSClient) SendMessageBatchArgsForCall ¶

func (fake *FakeSQSClient) SendMessageBatchArgsForCall(i int) *sqs.SendMessageBatchInput

func (*FakeSQSClient) SendMessageBatchCallCount ¶

func (fake *FakeSQSClient) SendMessageBatchCallCount() int

func (*FakeSQSClient) SendMessageBatchCalls ¶

func (fake *FakeSQSClient) SendMessageBatchCalls(stub func(*sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error))

func (*FakeSQSClient) SendMessageBatchRequest ¶

func (fake *FakeSQSClient) SendMessageBatchRequest(arg1 *sqs.SendMessageBatchInput) (*request.Request, *sqs.SendMessageBatchOutput)

func (*FakeSQSClient) SendMessageBatchRequestArgsForCall ¶

func (fake *FakeSQSClient) SendMessageBatchRequestArgsForCall(i int) *sqs.SendMessageBatchInput

func (*FakeSQSClient) SendMessageBatchRequestCallCount ¶

func (fake *FakeSQSClient) SendMessageBatchRequestCallCount() int

func (*FakeSQSClient) SendMessageBatchRequestCalls ¶

func (fake *FakeSQSClient) SendMessageBatchRequestCalls(stub func(*sqs.SendMessageBatchInput) (*request.Request, *sqs.SendMessageBatchOutput))

func (*FakeSQSClient) SendMessageBatchRequestReturns ¶

func (fake *FakeSQSClient) SendMessageBatchRequestReturns(result1 *request.Request, result2 *sqs.SendMessageBatchOutput)

func (*FakeSQSClient) SendMessageBatchRequestReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageBatchRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.SendMessageBatchOutput)

func (*FakeSQSClient) SendMessageBatchReturns ¶

func (fake *FakeSQSClient) SendMessageBatchReturns(result1 *sqs.SendMessageBatchOutput, result2 error)

func (*FakeSQSClient) SendMessageBatchReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageBatchReturnsOnCall(i int, result1 *sqs.SendMessageBatchOutput, result2 error)

func (*FakeSQSClient) SendMessageBatchWithContext ¶

func (fake *FakeSQSClient) SendMessageBatchWithContext(arg1 context.Context, arg2 *sqs.SendMessageBatchInput, arg3 ...request.Option) (*sqs.SendMessageBatchOutput, error)

func (*FakeSQSClient) SendMessageBatchWithContextArgsForCall ¶

func (fake *FakeSQSClient) SendMessageBatchWithContextArgsForCall(i int) (context.Context, *sqs.SendMessageBatchInput, []request.Option)

func (*FakeSQSClient) SendMessageBatchWithContextCallCount ¶

func (fake *FakeSQSClient) SendMessageBatchWithContextCallCount() int

func (*FakeSQSClient) SendMessageBatchWithContextCalls ¶

func (fake *FakeSQSClient) SendMessageBatchWithContextCalls(stub func(context.Context, *sqs.SendMessageBatchInput, ...request.Option) (*sqs.SendMessageBatchOutput, error))

func (*FakeSQSClient) SendMessageBatchWithContextReturns ¶

func (fake *FakeSQSClient) SendMessageBatchWithContextReturns(result1 *sqs.SendMessageBatchOutput, result2 error)

func (*FakeSQSClient) SendMessageBatchWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageBatchWithContextReturnsOnCall(i int, result1 *sqs.SendMessageBatchOutput, result2 error)

func (*FakeSQSClient) SendMessageCallCount ¶

func (fake *FakeSQSClient) SendMessageCallCount() int

func (*FakeSQSClient) SendMessageCalls ¶

func (fake *FakeSQSClient) SendMessageCalls(stub func(*sqs.SendMessageInput) (*sqs.SendMessageOutput, error))

func (*FakeSQSClient) SendMessageRequest ¶

func (fake *FakeSQSClient) SendMessageRequest(arg1 *sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput)

func (*FakeSQSClient) SendMessageRequestArgsForCall ¶

func (fake *FakeSQSClient) SendMessageRequestArgsForCall(i int) *sqs.SendMessageInput

func (*FakeSQSClient) SendMessageRequestCallCount ¶

func (fake *FakeSQSClient) SendMessageRequestCallCount() int

func (*FakeSQSClient) SendMessageRequestCalls ¶

func (fake *FakeSQSClient) SendMessageRequestCalls(stub func(*sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput))

func (*FakeSQSClient) SendMessageRequestReturns ¶

func (fake *FakeSQSClient) SendMessageRequestReturns(result1 *request.Request, result2 *sqs.SendMessageOutput)

func (*FakeSQSClient) SendMessageRequestReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.SendMessageOutput)

func (*FakeSQSClient) SendMessageReturns ¶

func (fake *FakeSQSClient) SendMessageReturns(result1 *sqs.SendMessageOutput, result2 error)

func (*FakeSQSClient) SendMessageReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageReturnsOnCall(i int, result1 *sqs.SendMessageOutput, result2 error)

func (*FakeSQSClient) SendMessageWithContext ¶

func (fake *FakeSQSClient) SendMessageWithContext(arg1 context.Context, arg2 *sqs.SendMessageInput, arg3 ...request.Option) (*sqs.SendMessageOutput, error)

func (*FakeSQSClient) SendMessageWithContextArgsForCall ¶

func (fake *FakeSQSClient) SendMessageWithContextArgsForCall(i int) (context.Context, *sqs.SendMessageInput, []request.Option)

func (*FakeSQSClient) SendMessageWithContextCallCount ¶

func (fake *FakeSQSClient) SendMessageWithContextCallCount() int

func (*FakeSQSClient) SendMessageWithContextCalls ¶

func (fake *FakeSQSClient) SendMessageWithContextCalls(stub func(context.Context, *sqs.SendMessageInput, ...request.Option) (*sqs.SendMessageOutput, error))

func (*FakeSQSClient) SendMessageWithContextReturns ¶

func (fake *FakeSQSClient) SendMessageWithContextReturns(result1 *sqs.SendMessageOutput, result2 error)

func (*FakeSQSClient) SendMessageWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) SendMessageWithContextReturnsOnCall(i int, result1 *sqs.SendMessageOutput, result2 error)

func (*FakeSQSClient) SetQueueAttributes ¶

func (fake *FakeSQSClient) SetQueueAttributes(arg1 *sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error)

func (*FakeSQSClient) SetQueueAttributesArgsForCall ¶

func (fake *FakeSQSClient) SetQueueAttributesArgsForCall(i int) *sqs.SetQueueAttributesInput

func (*FakeSQSClient) SetQueueAttributesCallCount ¶

func (fake *FakeSQSClient) SetQueueAttributesCallCount() int

func (*FakeSQSClient) SetQueueAttributesCalls ¶

func (fake *FakeSQSClient) SetQueueAttributesCalls(stub func(*sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error))

func (*FakeSQSClient) SetQueueAttributesRequest ¶

func (fake *FakeSQSClient) SetQueueAttributesRequest(arg1 *sqs.SetQueueAttributesInput) (*request.Request, *sqs.SetQueueAttributesOutput)

func (*FakeSQSClient) SetQueueAttributesRequestArgsForCall ¶

func (fake *FakeSQSClient) SetQueueAttributesRequestArgsForCall(i int) *sqs.SetQueueAttributesInput

func (*FakeSQSClient) SetQueueAttributesRequestCallCount ¶

func (fake *FakeSQSClient) SetQueueAttributesRequestCallCount() int

func (*FakeSQSClient) SetQueueAttributesRequestCalls ¶

func (fake *FakeSQSClient) SetQueueAttributesRequestCalls(stub func(*sqs.SetQueueAttributesInput) (*request.Request, *sqs.SetQueueAttributesOutput))

func (*FakeSQSClient) SetQueueAttributesRequestReturns ¶

func (fake *FakeSQSClient) SetQueueAttributesRequestReturns(result1 *request.Request, result2 *sqs.SetQueueAttributesOutput)

func (*FakeSQSClient) SetQueueAttributesRequestReturnsOnCall ¶

func (fake *FakeSQSClient) SetQueueAttributesRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.SetQueueAttributesOutput)

func (*FakeSQSClient) SetQueueAttributesReturns ¶

func (fake *FakeSQSClient) SetQueueAttributesReturns(result1 *sqs.SetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) SetQueueAttributesReturnsOnCall ¶

func (fake *FakeSQSClient) SetQueueAttributesReturnsOnCall(i int, result1 *sqs.SetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) SetQueueAttributesWithContext ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContext(arg1 context.Context, arg2 *sqs.SetQueueAttributesInput, arg3 ...request.Option) (*sqs.SetQueueAttributesOutput, error)

func (*FakeSQSClient) SetQueueAttributesWithContextArgsForCall ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContextArgsForCall(i int) (context.Context, *sqs.SetQueueAttributesInput, []request.Option)

func (*FakeSQSClient) SetQueueAttributesWithContextCallCount ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContextCallCount() int

func (*FakeSQSClient) SetQueueAttributesWithContextCalls ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContextCalls(stub func(context.Context, *sqs.SetQueueAttributesInput, ...request.Option) (*sqs.SetQueueAttributesOutput, error))

func (*FakeSQSClient) SetQueueAttributesWithContextReturns ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContextReturns(result1 *sqs.SetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) SetQueueAttributesWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) SetQueueAttributesWithContextReturnsOnCall(i int, result1 *sqs.SetQueueAttributesOutput, result2 error)

func (*FakeSQSClient) StartMessageMoveTask ¶

func (fake *FakeSQSClient) StartMessageMoveTask(arg1 *sqs.StartMessageMoveTaskInput) (*sqs.StartMessageMoveTaskOutput, error)

func (*FakeSQSClient) StartMessageMoveTaskArgsForCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskArgsForCall(i int) *sqs.StartMessageMoveTaskInput

func (*FakeSQSClient) StartMessageMoveTaskCallCount ¶

func (fake *FakeSQSClient) StartMessageMoveTaskCallCount() int

func (*FakeSQSClient) StartMessageMoveTaskCalls ¶

func (fake *FakeSQSClient) StartMessageMoveTaskCalls(stub func(*sqs.StartMessageMoveTaskInput) (*sqs.StartMessageMoveTaskOutput, error))

func (*FakeSQSClient) StartMessageMoveTaskRequest ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequest(arg1 *sqs.StartMessageMoveTaskInput) (*request.Request, *sqs.StartMessageMoveTaskOutput)

func (*FakeSQSClient) StartMessageMoveTaskRequestArgsForCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequestArgsForCall(i int) *sqs.StartMessageMoveTaskInput

func (*FakeSQSClient) StartMessageMoveTaskRequestCallCount ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequestCallCount() int

func (*FakeSQSClient) StartMessageMoveTaskRequestCalls ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequestCalls(stub func(*sqs.StartMessageMoveTaskInput) (*request.Request, *sqs.StartMessageMoveTaskOutput))

func (*FakeSQSClient) StartMessageMoveTaskRequestReturns ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequestReturns(result1 *request.Request, result2 *sqs.StartMessageMoveTaskOutput)

func (*FakeSQSClient) StartMessageMoveTaskRequestReturnsOnCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.StartMessageMoveTaskOutput)

func (*FakeSQSClient) StartMessageMoveTaskReturns ¶

func (fake *FakeSQSClient) StartMessageMoveTaskReturns(result1 *sqs.StartMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) StartMessageMoveTaskReturnsOnCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskReturnsOnCall(i int, result1 *sqs.StartMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) StartMessageMoveTaskWithContext ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContext(arg1 context.Context, arg2 *sqs.StartMessageMoveTaskInput, arg3 ...request.Option) (*sqs.StartMessageMoveTaskOutput, error)

func (*FakeSQSClient) StartMessageMoveTaskWithContextArgsForCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContextArgsForCall(i int) (context.Context, *sqs.StartMessageMoveTaskInput, []request.Option)

func (*FakeSQSClient) StartMessageMoveTaskWithContextCallCount ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContextCallCount() int

func (*FakeSQSClient) StartMessageMoveTaskWithContextCalls ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContextCalls(stub func(context.Context, *sqs.StartMessageMoveTaskInput, ...request.Option) (*sqs.StartMessageMoveTaskOutput, error))

func (*FakeSQSClient) StartMessageMoveTaskWithContextReturns ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContextReturns(result1 *sqs.StartMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) StartMessageMoveTaskWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) StartMessageMoveTaskWithContextReturnsOnCall(i int, result1 *sqs.StartMessageMoveTaskOutput, result2 error)

func (*FakeSQSClient) TagQueue ¶

func (fake *FakeSQSClient) TagQueue(arg1 *sqs.TagQueueInput) (*sqs.TagQueueOutput, error)

func (*FakeSQSClient) TagQueueArgsForCall ¶

func (fake *FakeSQSClient) TagQueueArgsForCall(i int) *sqs.TagQueueInput

func (*FakeSQSClient) TagQueueCallCount ¶

func (fake *FakeSQSClient) TagQueueCallCount() int

func (*FakeSQSClient) TagQueueCalls ¶

func (fake *FakeSQSClient) TagQueueCalls(stub func(*sqs.TagQueueInput) (*sqs.TagQueueOutput, error))

func (*FakeSQSClient) TagQueueRequest ¶

func (fake *FakeSQSClient) TagQueueRequest(arg1 *sqs.TagQueueInput) (*request.Request, *sqs.TagQueueOutput)

func (*FakeSQSClient) TagQueueRequestArgsForCall ¶

func (fake *FakeSQSClient) TagQueueRequestArgsForCall(i int) *sqs.TagQueueInput

func (*FakeSQSClient) TagQueueRequestCallCount ¶

func (fake *FakeSQSClient) TagQueueRequestCallCount() int

func (*FakeSQSClient) TagQueueRequestCalls ¶

func (fake *FakeSQSClient) TagQueueRequestCalls(stub func(*sqs.TagQueueInput) (*request.Request, *sqs.TagQueueOutput))

func (*FakeSQSClient) TagQueueRequestReturns ¶

func (fake *FakeSQSClient) TagQueueRequestReturns(result1 *request.Request, result2 *sqs.TagQueueOutput)

func (*FakeSQSClient) TagQueueRequestReturnsOnCall ¶

func (fake *FakeSQSClient) TagQueueRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.TagQueueOutput)

func (*FakeSQSClient) TagQueueReturns ¶

func (fake *FakeSQSClient) TagQueueReturns(result1 *sqs.TagQueueOutput, result2 error)

func (*FakeSQSClient) TagQueueReturnsOnCall ¶

func (fake *FakeSQSClient) TagQueueReturnsOnCall(i int, result1 *sqs.TagQueueOutput, result2 error)

func (*FakeSQSClient) TagQueueWithContext ¶

func (fake *FakeSQSClient) TagQueueWithContext(arg1 context.Context, arg2 *sqs.TagQueueInput, arg3 ...request.Option) (*sqs.TagQueueOutput, error)

func (*FakeSQSClient) TagQueueWithContextArgsForCall ¶

func (fake *FakeSQSClient) TagQueueWithContextArgsForCall(i int) (context.Context, *sqs.TagQueueInput, []request.Option)

func (*FakeSQSClient) TagQueueWithContextCallCount ¶

func (fake *FakeSQSClient) TagQueueWithContextCallCount() int

func (*FakeSQSClient) TagQueueWithContextCalls ¶

func (fake *FakeSQSClient) TagQueueWithContextCalls(stub func(context.Context, *sqs.TagQueueInput, ...request.Option) (*sqs.TagQueueOutput, error))

func (*FakeSQSClient) TagQueueWithContextReturns ¶

func (fake *FakeSQSClient) TagQueueWithContextReturns(result1 *sqs.TagQueueOutput, result2 error)

func (*FakeSQSClient) TagQueueWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) TagQueueWithContextReturnsOnCall(i int, result1 *sqs.TagQueueOutput, result2 error)

func (*FakeSQSClient) UntagQueue ¶

func (fake *FakeSQSClient) UntagQueue(arg1 *sqs.UntagQueueInput) (*sqs.UntagQueueOutput, error)

func (*FakeSQSClient) UntagQueueArgsForCall ¶

func (fake *FakeSQSClient) UntagQueueArgsForCall(i int) *sqs.UntagQueueInput

func (*FakeSQSClient) UntagQueueCallCount ¶

func (fake *FakeSQSClient) UntagQueueCallCount() int

func (*FakeSQSClient) UntagQueueCalls ¶

func (fake *FakeSQSClient) UntagQueueCalls(stub func(*sqs.UntagQueueInput) (*sqs.UntagQueueOutput, error))

func (*FakeSQSClient) UntagQueueRequest ¶

func (fake *FakeSQSClient) UntagQueueRequest(arg1 *sqs.UntagQueueInput) (*request.Request, *sqs.UntagQueueOutput)

func (*FakeSQSClient) UntagQueueRequestArgsForCall ¶

func (fake *FakeSQSClient) UntagQueueRequestArgsForCall(i int) *sqs.UntagQueueInput

func (*FakeSQSClient) UntagQueueRequestCallCount ¶

func (fake *FakeSQSClient) UntagQueueRequestCallCount() int

func (*FakeSQSClient) UntagQueueRequestCalls ¶

func (fake *FakeSQSClient) UntagQueueRequestCalls(stub func(*sqs.UntagQueueInput) (*request.Request, *sqs.UntagQueueOutput))

func (*FakeSQSClient) UntagQueueRequestReturns ¶

func (fake *FakeSQSClient) UntagQueueRequestReturns(result1 *request.Request, result2 *sqs.UntagQueueOutput)

func (*FakeSQSClient) UntagQueueRequestReturnsOnCall ¶

func (fake *FakeSQSClient) UntagQueueRequestReturnsOnCall(i int, result1 *request.Request, result2 *sqs.UntagQueueOutput)

func (*FakeSQSClient) UntagQueueReturns ¶

func (fake *FakeSQSClient) UntagQueueReturns(result1 *sqs.UntagQueueOutput, result2 error)

func (*FakeSQSClient) UntagQueueReturnsOnCall ¶

func (fake *FakeSQSClient) UntagQueueReturnsOnCall(i int, result1 *sqs.UntagQueueOutput, result2 error)

func (*FakeSQSClient) UntagQueueWithContext ¶

func (fake *FakeSQSClient) UntagQueueWithContext(arg1 context.Context, arg2 *sqs.UntagQueueInput, arg3 ...request.Option) (*sqs.UntagQueueOutput, error)

func (*FakeSQSClient) UntagQueueWithContextArgsForCall ¶

func (fake *FakeSQSClient) UntagQueueWithContextArgsForCall(i int) (context.Context, *sqs.UntagQueueInput, []request.Option)

func (*FakeSQSClient) UntagQueueWithContextCallCount ¶

func (fake *FakeSQSClient) UntagQueueWithContextCallCount() int

func (*FakeSQSClient) UntagQueueWithContextCalls ¶

func (fake *FakeSQSClient) UntagQueueWithContextCalls(stub func(context.Context, *sqs.UntagQueueInput, ...request.Option) (*sqs.UntagQueueOutput, error))

func (*FakeSQSClient) UntagQueueWithContextReturns ¶

func (fake *FakeSQSClient) UntagQueueWithContextReturns(result1 *sqs.UntagQueueOutput, result2 error)

func (*FakeSQSClient) UntagQueueWithContextReturnsOnCall ¶

func (fake *FakeSQSClient) UntagQueueWithContextReturnsOnCall(i int, result1 *sqs.UntagQueueOutput, result2 error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL