kinesisfakes

package

v1.16.0 Latest Latest Go to latest Published: Jan 10, 2023 License: MIT Imports: 5 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/batchcorp/plumber

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated by counterfeiter. DO NOT EDIT.

Index ¶

type FakeKinesisAPI

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type FakeKinesisAPI ¶

type FakeKinesisAPI 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)

	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 (*FakeKinesisAPI) AddTagsToStream ¶

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

func (*FakeKinesisAPI) AddTagsToStreamArgsForCall ¶

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

func (*FakeKinesisAPI) AddTagsToStreamCallCount ¶

func (fake *FakeKinesisAPI) AddTagsToStreamCallCount() int

func (*FakeKinesisAPI) AddTagsToStreamCalls ¶

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

func (*FakeKinesisAPI) AddTagsToStreamRequest ¶

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

func (*FakeKinesisAPI) AddTagsToStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) AddTagsToStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) AddTagsToStreamRequestCallCount() int

func (*FakeKinesisAPI) AddTagsToStreamRequestCalls ¶

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

func (*FakeKinesisAPI) AddTagsToStreamRequestReturns ¶

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

func (*FakeKinesisAPI) AddTagsToStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) AddTagsToStreamReturns ¶

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

func (*FakeKinesisAPI) AddTagsToStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) AddTagsToStreamWithContext ¶

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

func (*FakeKinesisAPI) AddTagsToStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) AddTagsToStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) AddTagsToStreamWithContextCallCount() int

func (*FakeKinesisAPI) AddTagsToStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) AddTagsToStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) AddTagsToStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) CreateStream ¶

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

func (*FakeKinesisAPI) CreateStreamArgsForCall ¶

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

func (*FakeKinesisAPI) CreateStreamCallCount ¶

func (fake *FakeKinesisAPI) CreateStreamCallCount() int

func (*FakeKinesisAPI) CreateStreamCalls ¶

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

func (*FakeKinesisAPI) CreateStreamRequest ¶

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

func (*FakeKinesisAPI) CreateStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) CreateStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) CreateStreamRequestCallCount() int

func (*FakeKinesisAPI) CreateStreamRequestCalls ¶

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

func (*FakeKinesisAPI) CreateStreamRequestReturns ¶

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

func (*FakeKinesisAPI) CreateStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) CreateStreamReturns ¶

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

func (*FakeKinesisAPI) CreateStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) CreateStreamWithContext ¶

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

func (*FakeKinesisAPI) CreateStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) CreateStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) CreateStreamWithContextCallCount() int

func (*FakeKinesisAPI) CreateStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) CreateStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) CreateStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriod ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodArgsForCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodCallCount ¶

func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodCallCount() int

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodCalls ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequest ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestCallCount ¶

func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestCallCount() int

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestCalls ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestReturns ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodReturns ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodReturnsOnCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContext ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextCallCount ¶

func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextCallCount() int

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextCalls ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextReturns ¶

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

func (*FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeleteStream ¶

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

func (*FakeKinesisAPI) DeleteStreamArgsForCall ¶

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

func (*FakeKinesisAPI) DeleteStreamCallCount ¶

func (fake *FakeKinesisAPI) DeleteStreamCallCount() int

func (*FakeKinesisAPI) DeleteStreamCalls ¶

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

func (*FakeKinesisAPI) DeleteStreamRequest ¶

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

func (*FakeKinesisAPI) DeleteStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DeleteStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) DeleteStreamRequestCallCount() int

func (*FakeKinesisAPI) DeleteStreamRequestCalls ¶

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

func (*FakeKinesisAPI) DeleteStreamRequestReturns ¶

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

func (*FakeKinesisAPI) DeleteStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeleteStreamReturns ¶

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

func (*FakeKinesisAPI) DeleteStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeleteStreamWithContext ¶

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

func (*FakeKinesisAPI) DeleteStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DeleteStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) DeleteStreamWithContextCallCount() int

func (*FakeKinesisAPI) DeleteStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) DeleteStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) DeleteStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumer ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerArgsForCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerCallCount ¶

func (fake *FakeKinesisAPI) DeregisterStreamConsumerCallCount() int

func (*FakeKinesisAPI) DeregisterStreamConsumerCalls ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerRequest ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestCallCount() int

func (*FakeKinesisAPI) DeregisterStreamConsumerRequestCalls ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerRequestReturns ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerReturns ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerReturnsOnCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContext ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextCallCount() int

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContextCalls ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContextReturns ¶

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

func (*FakeKinesisAPI) DeregisterStreamConsumerWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeLimits ¶

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

func (*FakeKinesisAPI) DescribeLimitsArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeLimitsCallCount ¶

func (fake *FakeKinesisAPI) DescribeLimitsCallCount() int

func (*FakeKinesisAPI) DescribeLimitsCalls ¶

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

func (*FakeKinesisAPI) DescribeLimitsRequest ¶

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

func (*FakeKinesisAPI) DescribeLimitsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeLimitsRequestCallCount ¶

func (fake *FakeKinesisAPI) DescribeLimitsRequestCallCount() int

func (*FakeKinesisAPI) DescribeLimitsRequestCalls ¶

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

func (*FakeKinesisAPI) DescribeLimitsRequestReturns ¶

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

func (*FakeKinesisAPI) DescribeLimitsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeLimitsReturns ¶

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

func (*FakeKinesisAPI) DescribeLimitsReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeLimitsWithContext ¶

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

func (*FakeKinesisAPI) DescribeLimitsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeLimitsWithContextCallCount ¶

func (fake *FakeKinesisAPI) DescribeLimitsWithContextCallCount() int

func (*FakeKinesisAPI) DescribeLimitsWithContextCalls ¶

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

func (*FakeKinesisAPI) DescribeLimitsWithContextReturns ¶

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

func (*FakeKinesisAPI) DescribeLimitsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStream ¶

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

func (*FakeKinesisAPI) DescribeStreamArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamCallCount() int

func (*FakeKinesisAPI) DescribeStreamCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumer ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamConsumerCallCount() int

func (*FakeKinesisAPI) DescribeStreamConsumerCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerRequest ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestCallCount() int

func (*FakeKinesisAPI) DescribeStreamConsumerRequestCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerRequestReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerWithContext ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextCallCount() int

func (*FakeKinesisAPI) DescribeStreamConsumerWithContextCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerWithContextReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamConsumerWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamPages ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamPagesCallCount() int

func (*FakeKinesisAPI) DescribeStreamPagesCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesReturns ¶

func (fake *FakeKinesisAPI) DescribeStreamPagesReturns(result1 error)

func (*FakeKinesisAPI) DescribeStreamPagesReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesWithContext ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesWithContextCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextCallCount() int

func (*FakeKinesisAPI) DescribeStreamPagesWithContextCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamPagesWithContextReturns ¶

func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextReturns(result1 error)

func (*FakeKinesisAPI) DescribeStreamPagesWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamRequest ¶

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

func (*FakeKinesisAPI) DescribeStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamRequestCallCount() int

func (*FakeKinesisAPI) DescribeStreamRequestCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamRequestReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummary ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamSummaryCallCount() int

func (*FakeKinesisAPI) DescribeStreamSummaryCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryRequest ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryRequestCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestCallCount() int

func (*FakeKinesisAPI) DescribeStreamSummaryRequestCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryRequestReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryWithContext ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryWithContextCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextCallCount() int

func (*FakeKinesisAPI) DescribeStreamSummaryWithContextCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryWithContextReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamSummaryWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DescribeStreamWithContext ¶

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

func (*FakeKinesisAPI) DescribeStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DescribeStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) DescribeStreamWithContextCallCount() int

func (*FakeKinesisAPI) DescribeStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) DescribeStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) DescribeStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoring ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringArgsForCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringCallCount ¶

func (fake *FakeKinesisAPI) DisableEnhancedMonitoringCallCount() int

func (*FakeKinesisAPI) DisableEnhancedMonitoringCalls ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequest ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequestArgsForCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequestCallCount ¶

func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestCallCount() int

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequestCalls ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequestReturns ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringReturns ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringReturnsOnCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContext ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContextCallCount ¶

func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextCallCount() int

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContextCalls ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContextReturns ¶

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

func (*FakeKinesisAPI) DisableEnhancedMonitoringWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoring ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringArgsForCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringCallCount ¶

func (fake *FakeKinesisAPI) EnableEnhancedMonitoringCallCount() int

func (*FakeKinesisAPI) EnableEnhancedMonitoringCalls ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequest ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequestArgsForCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequestCallCount ¶

func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestCallCount() int

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequestCalls ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequestReturns ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringReturns ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringReturnsOnCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContext ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContextCallCount ¶

func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextCallCount() int

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContextCalls ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContextReturns ¶

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

func (*FakeKinesisAPI) EnableEnhancedMonitoringWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetRecords ¶

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

func (*FakeKinesisAPI) GetRecordsArgsForCall ¶

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

func (*FakeKinesisAPI) GetRecordsCallCount ¶

func (fake *FakeKinesisAPI) GetRecordsCallCount() int

func (*FakeKinesisAPI) GetRecordsCalls ¶

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

func (*FakeKinesisAPI) GetRecordsRequest ¶

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

func (*FakeKinesisAPI) GetRecordsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) GetRecordsRequestCallCount ¶

func (fake *FakeKinesisAPI) GetRecordsRequestCallCount() int

func (*FakeKinesisAPI) GetRecordsRequestCalls ¶

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

func (*FakeKinesisAPI) GetRecordsRequestReturns ¶

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

func (*FakeKinesisAPI) GetRecordsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetRecordsReturns ¶

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

func (*FakeKinesisAPI) GetRecordsReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetRecordsWithContext ¶

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

func (*FakeKinesisAPI) GetRecordsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) GetRecordsWithContextCallCount ¶

func (fake *FakeKinesisAPI) GetRecordsWithContextCallCount() int

func (*FakeKinesisAPI) GetRecordsWithContextCalls ¶

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

func (*FakeKinesisAPI) GetRecordsWithContextReturns ¶

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

func (*FakeKinesisAPI) GetRecordsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetShardIterator ¶

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

func (*FakeKinesisAPI) GetShardIteratorArgsForCall ¶

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

func (*FakeKinesisAPI) GetShardIteratorCallCount ¶

func (fake *FakeKinesisAPI) GetShardIteratorCallCount() int

func (*FakeKinesisAPI) GetShardIteratorCalls ¶

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

func (*FakeKinesisAPI) GetShardIteratorRequest ¶

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

func (*FakeKinesisAPI) GetShardIteratorRequestArgsForCall ¶

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

func (*FakeKinesisAPI) GetShardIteratorRequestCallCount ¶

func (fake *FakeKinesisAPI) GetShardIteratorRequestCallCount() int

func (*FakeKinesisAPI) GetShardIteratorRequestCalls ¶

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

func (*FakeKinesisAPI) GetShardIteratorRequestReturns ¶

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

func (*FakeKinesisAPI) GetShardIteratorRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetShardIteratorReturns ¶

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

func (*FakeKinesisAPI) GetShardIteratorReturnsOnCall ¶

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

func (*FakeKinesisAPI) GetShardIteratorWithContext ¶

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

func (*FakeKinesisAPI) GetShardIteratorWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) GetShardIteratorWithContextCallCount ¶

func (fake *FakeKinesisAPI) GetShardIteratorWithContextCallCount() int

func (*FakeKinesisAPI) GetShardIteratorWithContextCalls ¶

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

func (*FakeKinesisAPI) GetShardIteratorWithContextReturns ¶

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

func (*FakeKinesisAPI) GetShardIteratorWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriod ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodArgsForCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodCallCount ¶

func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodCallCount() int

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodCalls ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequest ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestArgsForCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestCallCount ¶

func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestCallCount() int

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestCalls ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestReturns ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodReturns ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodReturnsOnCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContext ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextCallCount ¶

func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextCallCount() int

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextCalls ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextReturns ¶

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

func (*FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) Invocations ¶

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

func (*FakeKinesisAPI) ListShards ¶

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

func (*FakeKinesisAPI) ListShardsArgsForCall ¶

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

func (*FakeKinesisAPI) ListShardsCallCount ¶

func (fake *FakeKinesisAPI) ListShardsCallCount() int

func (*FakeKinesisAPI) ListShardsCalls ¶

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

func (*FakeKinesisAPI) ListShardsRequest ¶

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

func (*FakeKinesisAPI) ListShardsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) ListShardsRequestCallCount ¶

func (fake *FakeKinesisAPI) ListShardsRequestCallCount() int

func (*FakeKinesisAPI) ListShardsRequestCalls ¶

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

func (*FakeKinesisAPI) ListShardsRequestReturns ¶

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

func (*FakeKinesisAPI) ListShardsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListShardsReturns ¶

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

func (*FakeKinesisAPI) ListShardsReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListShardsWithContext ¶

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

func (*FakeKinesisAPI) ListShardsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListShardsWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListShardsWithContextCallCount() int

func (*FakeKinesisAPI) ListShardsWithContextCalls ¶

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

func (*FakeKinesisAPI) ListShardsWithContextReturns ¶

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

func (*FakeKinesisAPI) ListShardsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumers ¶

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

func (*FakeKinesisAPI) ListStreamConsumersArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersCallCount ¶

func (fake *FakeKinesisAPI) ListStreamConsumersCallCount() int

func (*FakeKinesisAPI) ListStreamConsumersCalls ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPages ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesCallCount ¶

func (fake *FakeKinesisAPI) ListStreamConsumersPagesCallCount() int

func (*FakeKinesisAPI) ListStreamConsumersPagesCalls ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesReturns ¶

func (fake *FakeKinesisAPI) ListStreamConsumersPagesReturns(result1 error)

func (*FakeKinesisAPI) ListStreamConsumersPagesReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContext ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextCallCount() int

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContextCalls ¶

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

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContextReturns ¶

func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextReturns(result1 error)

func (*FakeKinesisAPI) ListStreamConsumersPagesWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersRequest ¶

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

func (*FakeKinesisAPI) ListStreamConsumersRequestArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersRequestCallCount ¶

func (fake *FakeKinesisAPI) ListStreamConsumersRequestCallCount() int

func (*FakeKinesisAPI) ListStreamConsumersRequestCalls ¶

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

func (*FakeKinesisAPI) ListStreamConsumersRequestReturns ¶

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

func (*FakeKinesisAPI) ListStreamConsumersRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersReturns ¶

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

func (*FakeKinesisAPI) ListStreamConsumersReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersWithContext ¶

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

func (*FakeKinesisAPI) ListStreamConsumersWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamConsumersWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListStreamConsumersWithContextCallCount() int

func (*FakeKinesisAPI) ListStreamConsumersWithContextCalls ¶

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

func (*FakeKinesisAPI) ListStreamConsumersWithContextReturns ¶

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

func (*FakeKinesisAPI) ListStreamConsumersWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreams ¶

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

func (*FakeKinesisAPI) ListStreamsArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamsCallCount ¶

func (fake *FakeKinesisAPI) ListStreamsCallCount() int

func (*FakeKinesisAPI) ListStreamsCalls ¶

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

func (*FakeKinesisAPI) ListStreamsPages ¶

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

func (*FakeKinesisAPI) ListStreamsPagesArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamsPagesCallCount ¶

func (fake *FakeKinesisAPI) ListStreamsPagesCallCount() int

func (*FakeKinesisAPI) ListStreamsPagesCalls ¶

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

func (*FakeKinesisAPI) ListStreamsPagesReturns ¶

func (fake *FakeKinesisAPI) ListStreamsPagesReturns(result1 error)

func (*FakeKinesisAPI) ListStreamsPagesReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamsPagesWithContext ¶

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

func (*FakeKinesisAPI) ListStreamsPagesWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamsPagesWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListStreamsPagesWithContextCallCount() int

func (*FakeKinesisAPI) ListStreamsPagesWithContextCalls ¶

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

func (*FakeKinesisAPI) ListStreamsPagesWithContextReturns ¶

func (fake *FakeKinesisAPI) ListStreamsPagesWithContextReturns(result1 error)

func (*FakeKinesisAPI) ListStreamsPagesWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamsRequest ¶

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

func (*FakeKinesisAPI) ListStreamsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamsRequestCallCount ¶

func (fake *FakeKinesisAPI) ListStreamsRequestCallCount() int

func (*FakeKinesisAPI) ListStreamsRequestCalls ¶

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

func (*FakeKinesisAPI) ListStreamsRequestReturns ¶

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

func (*FakeKinesisAPI) ListStreamsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamsReturns ¶

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

func (*FakeKinesisAPI) ListStreamsReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListStreamsWithContext ¶

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

func (*FakeKinesisAPI) ListStreamsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListStreamsWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListStreamsWithContextCallCount() int

func (*FakeKinesisAPI) ListStreamsWithContextCalls ¶

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

func (*FakeKinesisAPI) ListStreamsWithContextReturns ¶

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

func (*FakeKinesisAPI) ListStreamsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListTagsForStream ¶

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

func (*FakeKinesisAPI) ListTagsForStreamArgsForCall ¶

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

func (*FakeKinesisAPI) ListTagsForStreamCallCount ¶

func (fake *FakeKinesisAPI) ListTagsForStreamCallCount() int

func (*FakeKinesisAPI) ListTagsForStreamCalls ¶

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

func (*FakeKinesisAPI) ListTagsForStreamRequest ¶

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

func (*FakeKinesisAPI) ListTagsForStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) ListTagsForStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) ListTagsForStreamRequestCallCount() int

func (*FakeKinesisAPI) ListTagsForStreamRequestCalls ¶

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

func (*FakeKinesisAPI) ListTagsForStreamRequestReturns ¶

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

func (*FakeKinesisAPI) ListTagsForStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListTagsForStreamReturns ¶

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

func (*FakeKinesisAPI) ListTagsForStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) ListTagsForStreamWithContext ¶

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

func (*FakeKinesisAPI) ListTagsForStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) ListTagsForStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) ListTagsForStreamWithContextCallCount() int

func (*FakeKinesisAPI) ListTagsForStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) ListTagsForStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) ListTagsForStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) MergeShards ¶

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

func (*FakeKinesisAPI) MergeShardsArgsForCall ¶

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

func (*FakeKinesisAPI) MergeShardsCallCount ¶

func (fake *FakeKinesisAPI) MergeShardsCallCount() int

func (*FakeKinesisAPI) MergeShardsCalls ¶

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

func (*FakeKinesisAPI) MergeShardsRequest ¶

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

func (*FakeKinesisAPI) MergeShardsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) MergeShardsRequestCallCount ¶

func (fake *FakeKinesisAPI) MergeShardsRequestCallCount() int

func (*FakeKinesisAPI) MergeShardsRequestCalls ¶

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

func (*FakeKinesisAPI) MergeShardsRequestReturns ¶

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

func (*FakeKinesisAPI) MergeShardsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) MergeShardsReturns ¶

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

func (*FakeKinesisAPI) MergeShardsReturnsOnCall ¶

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

func (*FakeKinesisAPI) MergeShardsWithContext ¶

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

func (*FakeKinesisAPI) MergeShardsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) MergeShardsWithContextCallCount ¶

func (fake *FakeKinesisAPI) MergeShardsWithContextCallCount() int

func (*FakeKinesisAPI) MergeShardsWithContextCalls ¶

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

func (*FakeKinesisAPI) MergeShardsWithContextReturns ¶

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

func (*FakeKinesisAPI) MergeShardsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecord ¶

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

func (*FakeKinesisAPI) PutRecordArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordCallCount ¶

func (fake *FakeKinesisAPI) PutRecordCallCount() int

func (*FakeKinesisAPI) PutRecordCalls ¶

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

func (*FakeKinesisAPI) PutRecordRequest ¶

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

func (*FakeKinesisAPI) PutRecordRequestArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordRequestCallCount ¶

func (fake *FakeKinesisAPI) PutRecordRequestCallCount() int

func (*FakeKinesisAPI) PutRecordRequestCalls ¶

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

func (*FakeKinesisAPI) PutRecordRequestReturns ¶

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

func (*FakeKinesisAPI) PutRecordRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecordReturns ¶

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

func (*FakeKinesisAPI) PutRecordReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecordWithContext ¶

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

func (*FakeKinesisAPI) PutRecordWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordWithContextCallCount ¶

func (fake *FakeKinesisAPI) PutRecordWithContextCallCount() int

func (*FakeKinesisAPI) PutRecordWithContextCalls ¶

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

func (*FakeKinesisAPI) PutRecordWithContextReturns ¶

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

func (*FakeKinesisAPI) PutRecordWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecords ¶

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

func (*FakeKinesisAPI) PutRecordsArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordsCallCount ¶

func (fake *FakeKinesisAPI) PutRecordsCallCount() int

func (*FakeKinesisAPI) PutRecordsCalls ¶

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

func (*FakeKinesisAPI) PutRecordsRequest ¶

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

func (*FakeKinesisAPI) PutRecordsRequestArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordsRequestCallCount ¶

func (fake *FakeKinesisAPI) PutRecordsRequestCallCount() int

func (*FakeKinesisAPI) PutRecordsRequestCalls ¶

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

func (*FakeKinesisAPI) PutRecordsRequestReturns ¶

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

func (*FakeKinesisAPI) PutRecordsRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecordsReturns ¶

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

func (*FakeKinesisAPI) PutRecordsReturnsOnCall ¶

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

func (*FakeKinesisAPI) PutRecordsWithContext ¶

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

func (*FakeKinesisAPI) PutRecordsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) PutRecordsWithContextCallCount ¶

func (fake *FakeKinesisAPI) PutRecordsWithContextCallCount() int

func (*FakeKinesisAPI) PutRecordsWithContextCalls ¶

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

func (*FakeKinesisAPI) PutRecordsWithContextReturns ¶

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

func (*FakeKinesisAPI) PutRecordsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumer ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerArgsForCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerCallCount ¶

func (fake *FakeKinesisAPI) RegisterStreamConsumerCallCount() int

func (*FakeKinesisAPI) RegisterStreamConsumerCalls ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerRequest ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerRequestArgsForCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerRequestCallCount ¶

func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestCallCount() int

func (*FakeKinesisAPI) RegisterStreamConsumerRequestCalls ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerRequestReturns ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerReturns ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerReturnsOnCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerWithContext ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerWithContextCallCount ¶

func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextCallCount() int

func (*FakeKinesisAPI) RegisterStreamConsumerWithContextCalls ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerWithContextReturns ¶

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

func (*FakeKinesisAPI) RegisterStreamConsumerWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStream ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamArgsForCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamCallCount ¶

func (fake *FakeKinesisAPI) RemoveTagsFromStreamCallCount() int

func (*FakeKinesisAPI) RemoveTagsFromStreamCalls ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamRequest ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamRequestArgsForCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamRequestCallCount ¶

func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestCallCount() int

func (*FakeKinesisAPI) RemoveTagsFromStreamRequestCalls ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamRequestReturns ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamReturns ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamReturnsOnCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContext ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContextCallCount ¶

func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextCallCount() int

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContextCalls ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContextReturns ¶

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

func (*FakeKinesisAPI) RemoveTagsFromStreamWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) SplitShard ¶

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

func (*FakeKinesisAPI) SplitShardArgsForCall ¶

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

func (*FakeKinesisAPI) SplitShardCallCount ¶

func (fake *FakeKinesisAPI) SplitShardCallCount() int

func (*FakeKinesisAPI) SplitShardCalls ¶

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

func (*FakeKinesisAPI) SplitShardRequest ¶

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

func (*FakeKinesisAPI) SplitShardRequestArgsForCall ¶

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

func (*FakeKinesisAPI) SplitShardRequestCallCount ¶

func (fake *FakeKinesisAPI) SplitShardRequestCallCount() int

func (*FakeKinesisAPI) SplitShardRequestCalls ¶

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

func (*FakeKinesisAPI) SplitShardRequestReturns ¶

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

func (*FakeKinesisAPI) SplitShardRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) SplitShardReturns ¶

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

func (*FakeKinesisAPI) SplitShardReturnsOnCall ¶

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

func (*FakeKinesisAPI) SplitShardWithContext ¶

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

func (*FakeKinesisAPI) SplitShardWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) SplitShardWithContextCallCount ¶

func (fake *FakeKinesisAPI) SplitShardWithContextCallCount() int

func (*FakeKinesisAPI) SplitShardWithContextCalls ¶

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

func (*FakeKinesisAPI) SplitShardWithContextReturns ¶

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

func (*FakeKinesisAPI) SplitShardWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryption ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionArgsForCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionCallCount ¶

func (fake *FakeKinesisAPI) StartStreamEncryptionCallCount() int

func (*FakeKinesisAPI) StartStreamEncryptionCalls ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionRequest ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionRequestArgsForCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionRequestCallCount ¶

func (fake *FakeKinesisAPI) StartStreamEncryptionRequestCallCount() int

func (*FakeKinesisAPI) StartStreamEncryptionRequestCalls ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionRequestReturns ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionReturns ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionReturnsOnCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionWithContext ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionWithContextCallCount ¶

func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextCallCount() int

func (*FakeKinesisAPI) StartStreamEncryptionWithContextCalls ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionWithContextReturns ¶

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

func (*FakeKinesisAPI) StartStreamEncryptionWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryption ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionArgsForCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionCallCount ¶

func (fake *FakeKinesisAPI) StopStreamEncryptionCallCount() int

func (*FakeKinesisAPI) StopStreamEncryptionCalls ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionRequest ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionRequestArgsForCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionRequestCallCount ¶

func (fake *FakeKinesisAPI) StopStreamEncryptionRequestCallCount() int

func (*FakeKinesisAPI) StopStreamEncryptionRequestCalls ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionRequestReturns ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionReturns ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionReturnsOnCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionWithContext ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionWithContextCallCount ¶

func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextCallCount() int

func (*FakeKinesisAPI) StopStreamEncryptionWithContextCalls ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionWithContextReturns ¶

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

func (*FakeKinesisAPI) StopStreamEncryptionWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) SubscribeToShard ¶

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

func (*FakeKinesisAPI) SubscribeToShardArgsForCall ¶

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

func (*FakeKinesisAPI) SubscribeToShardCallCount ¶

func (fake *FakeKinesisAPI) SubscribeToShardCallCount() int

func (*FakeKinesisAPI) SubscribeToShardCalls ¶

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

func (*FakeKinesisAPI) SubscribeToShardRequest ¶

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

func (*FakeKinesisAPI) SubscribeToShardRequestArgsForCall ¶

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

func (*FakeKinesisAPI) SubscribeToShardRequestCallCount ¶

func (fake *FakeKinesisAPI) SubscribeToShardRequestCallCount() int

func (*FakeKinesisAPI) SubscribeToShardRequestCalls ¶

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

func (*FakeKinesisAPI) SubscribeToShardRequestReturns ¶

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

func (*FakeKinesisAPI) SubscribeToShardRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) SubscribeToShardReturns ¶

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

func (*FakeKinesisAPI) SubscribeToShardReturnsOnCall ¶

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

func (*FakeKinesisAPI) SubscribeToShardWithContext ¶

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

func (*FakeKinesisAPI) SubscribeToShardWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) SubscribeToShardWithContextCallCount ¶

func (fake *FakeKinesisAPI) SubscribeToShardWithContextCallCount() int

func (*FakeKinesisAPI) SubscribeToShardWithContextCalls ¶

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

func (*FakeKinesisAPI) SubscribeToShardWithContextReturns ¶

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

func (*FakeKinesisAPI) SubscribeToShardWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) UpdateShardCount ¶

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

func (*FakeKinesisAPI) UpdateShardCountArgsForCall ¶

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

func (*FakeKinesisAPI) UpdateShardCountCallCount ¶

func (fake *FakeKinesisAPI) UpdateShardCountCallCount() int

func (*FakeKinesisAPI) UpdateShardCountCalls ¶

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

func (*FakeKinesisAPI) UpdateShardCountRequest ¶

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

func (*FakeKinesisAPI) UpdateShardCountRequestArgsForCall ¶

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

func (*FakeKinesisAPI) UpdateShardCountRequestCallCount ¶

func (fake *FakeKinesisAPI) UpdateShardCountRequestCallCount() int

func (*FakeKinesisAPI) UpdateShardCountRequestCalls ¶

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

func (*FakeKinesisAPI) UpdateShardCountRequestReturns ¶

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

func (*FakeKinesisAPI) UpdateShardCountRequestReturnsOnCall ¶

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

func (*FakeKinesisAPI) UpdateShardCountReturns ¶

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

func (*FakeKinesisAPI) UpdateShardCountReturnsOnCall ¶

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

func (*FakeKinesisAPI) UpdateShardCountWithContext ¶

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

func (*FakeKinesisAPI) UpdateShardCountWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) UpdateShardCountWithContextCallCount ¶

func (fake *FakeKinesisAPI) UpdateShardCountWithContextCallCount() int

func (*FakeKinesisAPI) UpdateShardCountWithContextCalls ¶

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

func (*FakeKinesisAPI) UpdateShardCountWithContextReturns ¶

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

func (*FakeKinesisAPI) UpdateShardCountWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExists ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsArgsForCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsCallCount ¶

func (fake *FakeKinesisAPI) WaitUntilStreamExistsCallCount() int

func (*FakeKinesisAPI) WaitUntilStreamExistsCalls ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsReturns ¶

func (fake *FakeKinesisAPI) WaitUntilStreamExistsReturns(result1 error)

func (*FakeKinesisAPI) WaitUntilStreamExistsReturnsOnCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContext ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContextCallCount ¶

func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextCallCount() int

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContextCalls ¶

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

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContextReturns ¶

func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextReturns(result1 error)

func (*FakeKinesisAPI) WaitUntilStreamExistsWithContextReturnsOnCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExists ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsArgsForCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsCallCount ¶

func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsCallCount() int

func (*FakeKinesisAPI) WaitUntilStreamNotExistsCalls ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsReturns ¶

func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsReturns(result1 error)

func (*FakeKinesisAPI) WaitUntilStreamNotExistsReturnsOnCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContext ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContextArgsForCall ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContextCallCount ¶

func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextCallCount() int

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContextCalls ¶

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

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContextReturns ¶

func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextReturns(result1 error)

func (*FakeKinesisAPI) WaitUntilStreamNotExistsWithContextReturnsOnCall ¶

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

Source Files ¶

View all Source files

fake_kinesis.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL