kinesisfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeKinesisAPI
  • func (fake *FakeKinesisAPI) AddTagsToStream(arg1 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
  • func (fake *FakeKinesisAPI) AddTagsToStreamArgsForCall(i int) *kinesis.AddTagsToStreamInput
  • func (fake *FakeKinesisAPI) AddTagsToStreamCallCount() int
  • func (fake *FakeKinesisAPI) AddTagsToStreamCalls(...)
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequest(arg1 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequestArgsForCall(i int) *kinesis.AddTagsToStreamInput
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequestReturns(result1 *request.Request, result2 *kinesis.AddTagsToStreamOutput)
  • func (fake *FakeKinesisAPI) AddTagsToStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.AddTagsToStreamOutput)
  • func (fake *FakeKinesisAPI) AddTagsToStreamReturns(result1 *kinesis.AddTagsToStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) AddTagsToStreamReturnsOnCall(i int, result1 *kinesis.AddTagsToStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContext(arg1 context.Context, arg2 *kinesis.AddTagsToStreamInput, ...) (*kinesis.AddTagsToStreamOutput, error)
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContextArgsForCall(i int) (context.Context, *kinesis.AddTagsToStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContextReturns(result1 *kinesis.AddTagsToStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) AddTagsToStreamWithContextReturnsOnCall(i int, result1 *kinesis.AddTagsToStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) CreateStream(arg1 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
  • func (fake *FakeKinesisAPI) CreateStreamArgsForCall(i int) *kinesis.CreateStreamInput
  • func (fake *FakeKinesisAPI) CreateStreamCallCount() int
  • func (fake *FakeKinesisAPI) CreateStreamCalls(stub func(*kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error))
  • func (fake *FakeKinesisAPI) CreateStreamRequest(arg1 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
  • func (fake *FakeKinesisAPI) CreateStreamRequestArgsForCall(i int) *kinesis.CreateStreamInput
  • func (fake *FakeKinesisAPI) CreateStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) CreateStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) CreateStreamRequestReturns(result1 *request.Request, result2 *kinesis.CreateStreamOutput)
  • func (fake *FakeKinesisAPI) CreateStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.CreateStreamOutput)
  • func (fake *FakeKinesisAPI) CreateStreamReturns(result1 *kinesis.CreateStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) CreateStreamReturnsOnCall(i int, result1 *kinesis.CreateStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) CreateStreamWithContext(arg1 context.Context, arg2 *kinesis.CreateStreamInput, arg3 ...request.Option) (*kinesis.CreateStreamOutput, error)
  • func (fake *FakeKinesisAPI) CreateStreamWithContextArgsForCall(i int) (context.Context, *kinesis.CreateStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) CreateStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) CreateStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) CreateStreamWithContextReturns(result1 *kinesis.CreateStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) CreateStreamWithContextReturnsOnCall(i int, result1 *kinesis.CreateStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriod(arg1 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodArgsForCall(i int) *kinesis.DecreaseStreamRetentionPeriodInput
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodCallCount() int
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodCalls(...)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequest(arg1 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestArgsForCall(i int) *kinesis.DecreaseStreamRetentionPeriodInput
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestCallCount() int
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestCalls(...)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestReturns(result1 *request.Request, result2 *kinesis.DecreaseStreamRetentionPeriodOutput)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodRequestReturnsOnCall(i int, result1 *request.Request, ...)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodReturns(result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodReturnsOnCall(i int, result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContext(arg1 context.Context, arg2 *kinesis.DecreaseStreamRetentionPeriodInput, ...) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextArgsForCall(i int) (context.Context, *kinesis.DecreaseStreamRetentionPeriodInput, []request.Option)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextReturns(result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) DecreaseStreamRetentionPeriodWithContextReturnsOnCall(i int, result1 *kinesis.DecreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeleteStream(arg1 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
  • func (fake *FakeKinesisAPI) DeleteStreamArgsForCall(i int) *kinesis.DeleteStreamInput
  • func (fake *FakeKinesisAPI) DeleteStreamCallCount() int
  • func (fake *FakeKinesisAPI) DeleteStreamCalls(stub func(*kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error))
  • func (fake *FakeKinesisAPI) DeleteStreamRequest(arg1 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
  • func (fake *FakeKinesisAPI) DeleteStreamRequestArgsForCall(i int) *kinesis.DeleteStreamInput
  • func (fake *FakeKinesisAPI) DeleteStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) DeleteStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) DeleteStreamRequestReturns(result1 *request.Request, result2 *kinesis.DeleteStreamOutput)
  • func (fake *FakeKinesisAPI) DeleteStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DeleteStreamOutput)
  • func (fake *FakeKinesisAPI) DeleteStreamReturns(result1 *kinesis.DeleteStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeleteStreamReturnsOnCall(i int, result1 *kinesis.DeleteStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeleteStreamWithContext(arg1 context.Context, arg2 *kinesis.DeleteStreamInput, arg3 ...request.Option) (*kinesis.DeleteStreamOutput, error)
  • func (fake *FakeKinesisAPI) DeleteStreamWithContextArgsForCall(i int) (context.Context, *kinesis.DeleteStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) DeleteStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DeleteStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DeleteStreamWithContextReturns(result1 *kinesis.DeleteStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeleteStreamWithContextReturnsOnCall(i int, result1 *kinesis.DeleteStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumer(arg1 *kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerArgsForCall(i int) *kinesis.DeregisterStreamConsumerInput
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerCallCount() int
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerCalls(...)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequest(arg1 *kinesis.DeregisterStreamConsumerInput) (*request.Request, *kinesis.DeregisterStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestArgsForCall(i int) *kinesis.DeregisterStreamConsumerInput
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestCallCount() int
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestCalls(...)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.DeregisterStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, ...)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerReturns(result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerReturnsOnCall(i int, result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.DeregisterStreamConsumerInput, ...) (*kinesis.DeregisterStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.DeregisterStreamConsumerInput, []request.Option)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextReturns(result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DeregisterStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.DeregisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeLimits(arg1 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)
  • func (fake *FakeKinesisAPI) DescribeLimitsArgsForCall(i int) *kinesis.DescribeLimitsInput
  • func (fake *FakeKinesisAPI) DescribeLimitsCallCount() int
  • func (fake *FakeKinesisAPI) DescribeLimitsCalls(stub func(*kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error))
  • func (fake *FakeKinesisAPI) DescribeLimitsRequest(arg1 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)
  • func (fake *FakeKinesisAPI) DescribeLimitsRequestArgsForCall(i int) *kinesis.DescribeLimitsInput
  • func (fake *FakeKinesisAPI) DescribeLimitsRequestCallCount() int
  • func (fake *FakeKinesisAPI) DescribeLimitsRequestCalls(...)
  • func (fake *FakeKinesisAPI) DescribeLimitsRequestReturns(result1 *request.Request, result2 *kinesis.DescribeLimitsOutput)
  • func (fake *FakeKinesisAPI) DescribeLimitsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeLimitsOutput)
  • func (fake *FakeKinesisAPI) DescribeLimitsReturns(result1 *kinesis.DescribeLimitsOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeLimitsReturnsOnCall(i int, result1 *kinesis.DescribeLimitsOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContext(arg1 context.Context, arg2 *kinesis.DescribeLimitsInput, ...) (*kinesis.DescribeLimitsOutput, error)
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeLimitsInput, []request.Option)
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContextReturns(result1 *kinesis.DescribeLimitsOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeLimitsWithContextReturnsOnCall(i int, result1 *kinesis.DescribeLimitsOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStream(arg1 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamArgsForCall(i int) *kinesis.DescribeStreamInput
  • func (fake *FakeKinesisAPI) DescribeStreamCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamCalls(stub func(*kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error))
  • func (fake *FakeKinesisAPI) DescribeStreamConsumer(arg1 *kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerArgsForCall(i int) *kinesis.DescribeStreamConsumerInput
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequest(arg1 *kinesis.DescribeStreamConsumerInput) (*request.Request, *kinesis.DescribeStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestArgsForCall(i int) *kinesis.DescribeStreamConsumerInput
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerReturns(result1 *kinesis.DescribeStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerReturnsOnCall(i int, result1 *kinesis.DescribeStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamConsumerInput, ...) (*kinesis.DescribeStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamConsumerInput, []request.Option)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextReturns(result1 *kinesis.DescribeStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamPages(arg1 *kinesis.DescribeStreamInput, ...) error
  • func (fake *FakeKinesisAPI) DescribeStreamPagesArgsForCall(i int) (*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamPagesCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesReturns(result1 error)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, ...) error
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, ...)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextCalls(stub func(context.Context, *kinesis.DescribeStreamInput, ...) error)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextReturns(result1 error)
  • func (fake *FakeKinesisAPI) DescribeStreamPagesWithContextReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) DescribeStreamRequest(arg1 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamRequestArgsForCall(i int) *kinesis.DescribeStreamInput
  • func (fake *FakeKinesisAPI) DescribeStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamReturns(result1 *kinesis.DescribeStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamReturnsOnCall(i int, result1 *kinesis.DescribeStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummary(arg1 *kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryArgsForCall(i int) *kinesis.DescribeStreamSummaryInput
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequest(arg1 *kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestArgsForCall(i int) *kinesis.DescribeStreamSummaryInput
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestReturns(result1 *request.Request, result2 *kinesis.DescribeStreamSummaryOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.DescribeStreamSummaryOutput)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryReturns(result1 *kinesis.DescribeStreamSummaryOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryReturnsOnCall(i int, result1 *kinesis.DescribeStreamSummaryOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamSummaryInput, ...) (*kinesis.DescribeStreamSummaryOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamSummaryInput, []request.Option)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextReturns(result1 *kinesis.DescribeStreamSummaryOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamSummaryWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamSummaryOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, ...) (*kinesis.DescribeStreamOutput, error)
  • func (fake *FakeKinesisAPI) DescribeStreamWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) DescribeStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DescribeStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DescribeStreamWithContextReturns(result1 *kinesis.DescribeStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DescribeStreamWithContextReturnsOnCall(i int, result1 *kinesis.DescribeStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoring(arg1 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringArgsForCall(i int) *kinesis.DisableEnhancedMonitoringInput
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringCallCount() int
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringCalls(...)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequest(arg1 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestArgsForCall(i int) *kinesis.DisableEnhancedMonitoringInput
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestCallCount() int
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestCalls(...)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestReturns(result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContext(arg1 context.Context, arg2 *kinesis.DisableEnhancedMonitoringInput, ...) (*kinesis.EnhancedMonitoringOutput, error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextArgsForCall(i int) (context.Context, *kinesis.DisableEnhancedMonitoringInput, []request.Option)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextCallCount() int
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextCalls(...)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) DisableEnhancedMonitoringWithContextReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoring(arg1 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringArgsForCall(i int) *kinesis.EnableEnhancedMonitoringInput
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringCallCount() int
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringCalls(...)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequest(arg1 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestArgsForCall(i int) *kinesis.EnableEnhancedMonitoringInput
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestCallCount() int
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestCalls(...)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestReturns(result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.EnhancedMonitoringOutput)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContext(arg1 context.Context, arg2 *kinesis.EnableEnhancedMonitoringInput, ...) (*kinesis.EnhancedMonitoringOutput, error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextArgsForCall(i int) (context.Context, *kinesis.EnableEnhancedMonitoringInput, []request.Option)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextCallCount() int
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextCalls(...)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextReturns(result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) EnableEnhancedMonitoringWithContextReturnsOnCall(i int, result1 *kinesis.EnhancedMonitoringOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetRecords(arg1 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
  • func (fake *FakeKinesisAPI) GetRecordsArgsForCall(i int) *kinesis.GetRecordsInput
  • func (fake *FakeKinesisAPI) GetRecordsCallCount() int
  • func (fake *FakeKinesisAPI) GetRecordsCalls(stub func(*kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error))
  • func (fake *FakeKinesisAPI) GetRecordsRequest(arg1 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
  • func (fake *FakeKinesisAPI) GetRecordsRequestArgsForCall(i int) *kinesis.GetRecordsInput
  • func (fake *FakeKinesisAPI) GetRecordsRequestCallCount() int
  • func (fake *FakeKinesisAPI) GetRecordsRequestCalls(...)
  • func (fake *FakeKinesisAPI) GetRecordsRequestReturns(result1 *request.Request, result2 *kinesis.GetRecordsOutput)
  • func (fake *FakeKinesisAPI) GetRecordsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.GetRecordsOutput)
  • func (fake *FakeKinesisAPI) GetRecordsReturns(result1 *kinesis.GetRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetRecordsReturnsOnCall(i int, result1 *kinesis.GetRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetRecordsWithContext(arg1 context.Context, arg2 *kinesis.GetRecordsInput, arg3 ...request.Option) (*kinesis.GetRecordsOutput, error)
  • func (fake *FakeKinesisAPI) GetRecordsWithContextArgsForCall(i int) (context.Context, *kinesis.GetRecordsInput, []request.Option)
  • func (fake *FakeKinesisAPI) GetRecordsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) GetRecordsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) GetRecordsWithContextReturns(result1 *kinesis.GetRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetRecordsWithContextReturnsOnCall(i int, result1 *kinesis.GetRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetShardIterator(arg1 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
  • func (fake *FakeKinesisAPI) GetShardIteratorArgsForCall(i int) *kinesis.GetShardIteratorInput
  • func (fake *FakeKinesisAPI) GetShardIteratorCallCount() int
  • func (fake *FakeKinesisAPI) GetShardIteratorCalls(...)
  • func (fake *FakeKinesisAPI) GetShardIteratorRequest(arg1 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
  • func (fake *FakeKinesisAPI) GetShardIteratorRequestArgsForCall(i int) *kinesis.GetShardIteratorInput
  • func (fake *FakeKinesisAPI) GetShardIteratorRequestCallCount() int
  • func (fake *FakeKinesisAPI) GetShardIteratorRequestCalls(...)
  • func (fake *FakeKinesisAPI) GetShardIteratorRequestReturns(result1 *request.Request, result2 *kinesis.GetShardIteratorOutput)
  • func (fake *FakeKinesisAPI) GetShardIteratorRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.GetShardIteratorOutput)
  • func (fake *FakeKinesisAPI) GetShardIteratorReturns(result1 *kinesis.GetShardIteratorOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetShardIteratorReturnsOnCall(i int, result1 *kinesis.GetShardIteratorOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContext(arg1 context.Context, arg2 *kinesis.GetShardIteratorInput, ...) (*kinesis.GetShardIteratorOutput, error)
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContextArgsForCall(i int) (context.Context, *kinesis.GetShardIteratorInput, []request.Option)
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContextCallCount() int
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContextCalls(...)
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContextReturns(result1 *kinesis.GetShardIteratorOutput, result2 error)
  • func (fake *FakeKinesisAPI) GetShardIteratorWithContextReturnsOnCall(i int, result1 *kinesis.GetShardIteratorOutput, result2 error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriod(arg1 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodArgsForCall(i int) *kinesis.IncreaseStreamRetentionPeriodInput
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodCallCount() int
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodCalls(...)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequest(arg1 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestArgsForCall(i int) *kinesis.IncreaseStreamRetentionPeriodInput
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestCallCount() int
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestCalls(...)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestReturns(result1 *request.Request, result2 *kinesis.IncreaseStreamRetentionPeriodOutput)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodRequestReturnsOnCall(i int, result1 *request.Request, ...)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodReturns(result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodReturnsOnCall(i int, result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContext(arg1 context.Context, arg2 *kinesis.IncreaseStreamRetentionPeriodInput, ...) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextArgsForCall(i int) (context.Context, *kinesis.IncreaseStreamRetentionPeriodInput, []request.Option)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextCallCount() int
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextCalls(...)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextReturns(result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) IncreaseStreamRetentionPeriodWithContextReturnsOnCall(i int, result1 *kinesis.IncreaseStreamRetentionPeriodOutput, result2 error)
  • func (fake *FakeKinesisAPI) Invocations() map[string][][]interface{}
  • func (fake *FakeKinesisAPI) ListShards(arg1 *kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)
  • func (fake *FakeKinesisAPI) ListShardsArgsForCall(i int) *kinesis.ListShardsInput
  • func (fake *FakeKinesisAPI) ListShardsCallCount() int
  • func (fake *FakeKinesisAPI) ListShardsCalls(stub func(*kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error))
  • func (fake *FakeKinesisAPI) ListShardsRequest(arg1 *kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput)
  • func (fake *FakeKinesisAPI) ListShardsRequestArgsForCall(i int) *kinesis.ListShardsInput
  • func (fake *FakeKinesisAPI) ListShardsRequestCallCount() int
  • func (fake *FakeKinesisAPI) ListShardsRequestCalls(...)
  • func (fake *FakeKinesisAPI) ListShardsRequestReturns(result1 *request.Request, result2 *kinesis.ListShardsOutput)
  • func (fake *FakeKinesisAPI) ListShardsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListShardsOutput)
  • func (fake *FakeKinesisAPI) ListShardsReturns(result1 *kinesis.ListShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListShardsReturnsOnCall(i int, result1 *kinesis.ListShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListShardsWithContext(arg1 context.Context, arg2 *kinesis.ListShardsInput, arg3 ...request.Option) (*kinesis.ListShardsOutput, error)
  • func (fake *FakeKinesisAPI) ListShardsWithContextArgsForCall(i int) (context.Context, *kinesis.ListShardsInput, []request.Option)
  • func (fake *FakeKinesisAPI) ListShardsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListShardsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) ListShardsWithContextReturns(result1 *kinesis.ListShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListShardsWithContextReturnsOnCall(i int, result1 *kinesis.ListShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumers(arg1 *kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersArgsForCall(i int) *kinesis.ListStreamConsumersInput
  • func (fake *FakeKinesisAPI) ListStreamConsumersCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamConsumersCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPages(arg1 *kinesis.ListStreamConsumersInput, ...) error
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesArgsForCall(i int) (*kinesis.ListStreamConsumersInput, ...)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesCalls(stub func(*kinesis.ListStreamConsumersInput, ...) error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesReturns(result1 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContext(arg1 context.Context, arg2 *kinesis.ListStreamConsumersInput, ...) error
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamConsumersInput, ...)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextCalls(stub func(context.Context, *kinesis.ListStreamConsumersInput, ...) error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextReturns(result1 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersPagesWithContextReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequest(arg1 *kinesis.ListStreamConsumersInput) (*request.Request, *kinesis.ListStreamConsumersOutput)
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequestArgsForCall(i int) *kinesis.ListStreamConsumersInput
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequestCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequestCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequestReturns(result1 *request.Request, result2 *kinesis.ListStreamConsumersOutput)
  • func (fake *FakeKinesisAPI) ListStreamConsumersRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListStreamConsumersOutput)
  • func (fake *FakeKinesisAPI) ListStreamConsumersReturns(result1 *kinesis.ListStreamConsumersOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersReturnsOnCall(i int, result1 *kinesis.ListStreamConsumersOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContext(arg1 context.Context, arg2 *kinesis.ListStreamConsumersInput, ...) (*kinesis.ListStreamConsumersOutput, error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamConsumersInput, []request.Option)
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContextCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContextReturns(result1 *kinesis.ListStreamConsumersOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamConsumersWithContextReturnsOnCall(i int, result1 *kinesis.ListStreamConsumersOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreams(arg1 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
  • func (fake *FakeKinesisAPI) ListStreamsArgsForCall(i int) *kinesis.ListStreamsInput
  • func (fake *FakeKinesisAPI) ListStreamsCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamsCalls(stub func(*kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error))
  • func (fake *FakeKinesisAPI) ListStreamsPages(arg1 *kinesis.ListStreamsInput, ...) error
  • func (fake *FakeKinesisAPI) ListStreamsPagesArgsForCall(i int) (*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool)
  • func (fake *FakeKinesisAPI) ListStreamsPagesCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamsPagesCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamsPagesReturns(result1 error)
  • func (fake *FakeKinesisAPI) ListStreamsPagesReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContext(arg1 context.Context, arg2 *kinesis.ListStreamsInput, ...) error
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamsInput, ...)
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContextCalls(stub func(context.Context, *kinesis.ListStreamsInput, ...) error)
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContextReturns(result1 error)
  • func (fake *FakeKinesisAPI) ListStreamsPagesWithContextReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) ListStreamsRequest(arg1 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
  • func (fake *FakeKinesisAPI) ListStreamsRequestArgsForCall(i int) *kinesis.ListStreamsInput
  • func (fake *FakeKinesisAPI) ListStreamsRequestCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamsRequestCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamsRequestReturns(result1 *request.Request, result2 *kinesis.ListStreamsOutput)
  • func (fake *FakeKinesisAPI) ListStreamsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListStreamsOutput)
  • func (fake *FakeKinesisAPI) ListStreamsReturns(result1 *kinesis.ListStreamsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamsReturnsOnCall(i int, result1 *kinesis.ListStreamsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamsWithContext(arg1 context.Context, arg2 *kinesis.ListStreamsInput, arg3 ...request.Option) (*kinesis.ListStreamsOutput, error)
  • func (fake *FakeKinesisAPI) ListStreamsWithContextArgsForCall(i int) (context.Context, *kinesis.ListStreamsInput, []request.Option)
  • func (fake *FakeKinesisAPI) ListStreamsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListStreamsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) ListStreamsWithContextReturns(result1 *kinesis.ListStreamsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListStreamsWithContextReturnsOnCall(i int, result1 *kinesis.ListStreamsOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListTagsForStream(arg1 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
  • func (fake *FakeKinesisAPI) ListTagsForStreamArgsForCall(i int) *kinesis.ListTagsForStreamInput
  • func (fake *FakeKinesisAPI) ListTagsForStreamCallCount() int
  • func (fake *FakeKinesisAPI) ListTagsForStreamCalls(...)
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequest(arg1 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequestArgsForCall(i int) *kinesis.ListTagsForStreamInput
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequestReturns(result1 *request.Request, result2 *kinesis.ListTagsForStreamOutput)
  • func (fake *FakeKinesisAPI) ListTagsForStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.ListTagsForStreamOutput)
  • func (fake *FakeKinesisAPI) ListTagsForStreamReturns(result1 *kinesis.ListTagsForStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListTagsForStreamReturnsOnCall(i int, result1 *kinesis.ListTagsForStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContext(arg1 context.Context, arg2 *kinesis.ListTagsForStreamInput, ...) (*kinesis.ListTagsForStreamOutput, error)
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContextArgsForCall(i int) (context.Context, *kinesis.ListTagsForStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContextReturns(result1 *kinesis.ListTagsForStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) ListTagsForStreamWithContextReturnsOnCall(i int, result1 *kinesis.ListTagsForStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) MergeShards(arg1 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
  • func (fake *FakeKinesisAPI) MergeShardsArgsForCall(i int) *kinesis.MergeShardsInput
  • func (fake *FakeKinesisAPI) MergeShardsCallCount() int
  • func (fake *FakeKinesisAPI) MergeShardsCalls(stub func(*kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error))
  • func (fake *FakeKinesisAPI) MergeShardsRequest(arg1 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
  • func (fake *FakeKinesisAPI) MergeShardsRequestArgsForCall(i int) *kinesis.MergeShardsInput
  • func (fake *FakeKinesisAPI) MergeShardsRequestCallCount() int
  • func (fake *FakeKinesisAPI) MergeShardsRequestCalls(...)
  • func (fake *FakeKinesisAPI) MergeShardsRequestReturns(result1 *request.Request, result2 *kinesis.MergeShardsOutput)
  • func (fake *FakeKinesisAPI) MergeShardsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.MergeShardsOutput)
  • func (fake *FakeKinesisAPI) MergeShardsReturns(result1 *kinesis.MergeShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) MergeShardsReturnsOnCall(i int, result1 *kinesis.MergeShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) MergeShardsWithContext(arg1 context.Context, arg2 *kinesis.MergeShardsInput, arg3 ...request.Option) (*kinesis.MergeShardsOutput, error)
  • func (fake *FakeKinesisAPI) MergeShardsWithContextArgsForCall(i int) (context.Context, *kinesis.MergeShardsInput, []request.Option)
  • func (fake *FakeKinesisAPI) MergeShardsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) MergeShardsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) MergeShardsWithContextReturns(result1 *kinesis.MergeShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) MergeShardsWithContextReturnsOnCall(i int, result1 *kinesis.MergeShardsOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecord(arg1 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
  • func (fake *FakeKinesisAPI) PutRecordArgsForCall(i int) *kinesis.PutRecordInput
  • func (fake *FakeKinesisAPI) PutRecordCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordCalls(stub func(*kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error))
  • func (fake *FakeKinesisAPI) PutRecordRequest(arg1 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
  • func (fake *FakeKinesisAPI) PutRecordRequestArgsForCall(i int) *kinesis.PutRecordInput
  • func (fake *FakeKinesisAPI) PutRecordRequestCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordRequestCalls(...)
  • func (fake *FakeKinesisAPI) PutRecordRequestReturns(result1 *request.Request, result2 *kinesis.PutRecordOutput)
  • func (fake *FakeKinesisAPI) PutRecordRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.PutRecordOutput)
  • func (fake *FakeKinesisAPI) PutRecordReturns(result1 *kinesis.PutRecordOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordReturnsOnCall(i int, result1 *kinesis.PutRecordOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordWithContext(arg1 context.Context, arg2 *kinesis.PutRecordInput, arg3 ...request.Option) (*kinesis.PutRecordOutput, error)
  • func (fake *FakeKinesisAPI) PutRecordWithContextArgsForCall(i int) (context.Context, *kinesis.PutRecordInput, []request.Option)
  • func (fake *FakeKinesisAPI) PutRecordWithContextCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordWithContextCalls(...)
  • func (fake *FakeKinesisAPI) PutRecordWithContextReturns(result1 *kinesis.PutRecordOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordWithContextReturnsOnCall(i int, result1 *kinesis.PutRecordOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecords(arg1 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
  • func (fake *FakeKinesisAPI) PutRecordsArgsForCall(i int) *kinesis.PutRecordsInput
  • func (fake *FakeKinesisAPI) PutRecordsCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordsCalls(stub func(*kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error))
  • func (fake *FakeKinesisAPI) PutRecordsRequest(arg1 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
  • func (fake *FakeKinesisAPI) PutRecordsRequestArgsForCall(i int) *kinesis.PutRecordsInput
  • func (fake *FakeKinesisAPI) PutRecordsRequestCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordsRequestCalls(...)
  • func (fake *FakeKinesisAPI) PutRecordsRequestReturns(result1 *request.Request, result2 *kinesis.PutRecordsOutput)
  • func (fake *FakeKinesisAPI) PutRecordsRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.PutRecordsOutput)
  • func (fake *FakeKinesisAPI) PutRecordsReturns(result1 *kinesis.PutRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordsReturnsOnCall(i int, result1 *kinesis.PutRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordsWithContext(arg1 context.Context, arg2 *kinesis.PutRecordsInput, arg3 ...request.Option) (*kinesis.PutRecordsOutput, error)
  • func (fake *FakeKinesisAPI) PutRecordsWithContextArgsForCall(i int) (context.Context, *kinesis.PutRecordsInput, []request.Option)
  • func (fake *FakeKinesisAPI) PutRecordsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) PutRecordsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) PutRecordsWithContextReturns(result1 *kinesis.PutRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) PutRecordsWithContextReturnsOnCall(i int, result1 *kinesis.PutRecordsOutput, result2 error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumer(arg1 *kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerArgsForCall(i int) *kinesis.RegisterStreamConsumerInput
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerCallCount() int
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerCalls(...)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequest(arg1 *kinesis.RegisterStreamConsumerInput) (*request.Request, *kinesis.RegisterStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestArgsForCall(i int) *kinesis.RegisterStreamConsumerInput
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestCallCount() int
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestCalls(...)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestReturns(result1 *request.Request, result2 *kinesis.RegisterStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.RegisterStreamConsumerOutput)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerReturns(result1 *kinesis.RegisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerReturnsOnCall(i int, result1 *kinesis.RegisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContext(arg1 context.Context, arg2 *kinesis.RegisterStreamConsumerInput, ...) (*kinesis.RegisterStreamConsumerOutput, error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextArgsForCall(i int) (context.Context, *kinesis.RegisterStreamConsumerInput, []request.Option)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextCallCount() int
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextCalls(...)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextReturns(result1 *kinesis.RegisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) RegisterStreamConsumerWithContextReturnsOnCall(i int, result1 *kinesis.RegisterStreamConsumerOutput, result2 error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStream(arg1 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamArgsForCall(i int) *kinesis.RemoveTagsFromStreamInput
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamCallCount() int
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamCalls(...)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequest(arg1 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestArgsForCall(i int) *kinesis.RemoveTagsFromStreamInput
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestCallCount() int
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestCalls(...)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestReturns(result1 *request.Request, result2 *kinesis.RemoveTagsFromStreamOutput)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.RemoveTagsFromStreamOutput)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamReturns(result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamReturnsOnCall(i int, result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContext(arg1 context.Context, arg2 *kinesis.RemoveTagsFromStreamInput, ...) (*kinesis.RemoveTagsFromStreamOutput, error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextArgsForCall(i int) (context.Context, *kinesis.RemoveTagsFromStreamInput, []request.Option)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextCallCount() int
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextCalls(...)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextReturns(result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) RemoveTagsFromStreamWithContextReturnsOnCall(i int, result1 *kinesis.RemoveTagsFromStreamOutput, result2 error)
  • func (fake *FakeKinesisAPI) SplitShard(arg1 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
  • func (fake *FakeKinesisAPI) SplitShardArgsForCall(i int) *kinesis.SplitShardInput
  • func (fake *FakeKinesisAPI) SplitShardCallCount() int
  • func (fake *FakeKinesisAPI) SplitShardCalls(stub func(*kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error))
  • func (fake *FakeKinesisAPI) SplitShardRequest(arg1 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
  • func (fake *FakeKinesisAPI) SplitShardRequestArgsForCall(i int) *kinesis.SplitShardInput
  • func (fake *FakeKinesisAPI) SplitShardRequestCallCount() int
  • func (fake *FakeKinesisAPI) SplitShardRequestCalls(...)
  • func (fake *FakeKinesisAPI) SplitShardRequestReturns(result1 *request.Request, result2 *kinesis.SplitShardOutput)
  • func (fake *FakeKinesisAPI) SplitShardRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.SplitShardOutput)
  • func (fake *FakeKinesisAPI) SplitShardReturns(result1 *kinesis.SplitShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SplitShardReturnsOnCall(i int, result1 *kinesis.SplitShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SplitShardWithContext(arg1 context.Context, arg2 *kinesis.SplitShardInput, arg3 ...request.Option) (*kinesis.SplitShardOutput, error)
  • func (fake *FakeKinesisAPI) SplitShardWithContextArgsForCall(i int) (context.Context, *kinesis.SplitShardInput, []request.Option)
  • func (fake *FakeKinesisAPI) SplitShardWithContextCallCount() int
  • func (fake *FakeKinesisAPI) SplitShardWithContextCalls(...)
  • func (fake *FakeKinesisAPI) SplitShardWithContextReturns(result1 *kinesis.SplitShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SplitShardWithContextReturnsOnCall(i int, result1 *kinesis.SplitShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) StartStreamEncryption(arg1 *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionArgsForCall(i int) *kinesis.StartStreamEncryptionInput
  • func (fake *FakeKinesisAPI) StartStreamEncryptionCallCount() int
  • func (fake *FakeKinesisAPI) StartStreamEncryptionCalls(...)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequest(arg1 *kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequestArgsForCall(i int) *kinesis.StartStreamEncryptionInput
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequestCallCount() int
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequestCalls(...)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequestReturns(result1 *request.Request, result2 *kinesis.StartStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.StartStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionReturns(result1 *kinesis.StartStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionReturnsOnCall(i int, result1 *kinesis.StartStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContext(arg1 context.Context, arg2 *kinesis.StartStreamEncryptionInput, ...) (*kinesis.StartStreamEncryptionOutput, error)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextArgsForCall(i int) (context.Context, *kinesis.StartStreamEncryptionInput, []request.Option)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextCallCount() int
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextCalls(...)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextReturns(result1 *kinesis.StartStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StartStreamEncryptionWithContextReturnsOnCall(i int, result1 *kinesis.StartStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StopStreamEncryption(arg1 *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionArgsForCall(i int) *kinesis.StopStreamEncryptionInput
  • func (fake *FakeKinesisAPI) StopStreamEncryptionCallCount() int
  • func (fake *FakeKinesisAPI) StopStreamEncryptionCalls(...)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequest(arg1 *kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequestArgsForCall(i int) *kinesis.StopStreamEncryptionInput
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequestCallCount() int
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequestCalls(...)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequestReturns(result1 *request.Request, result2 *kinesis.StopStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.StopStreamEncryptionOutput)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionReturns(result1 *kinesis.StopStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionReturnsOnCall(i int, result1 *kinesis.StopStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContext(arg1 context.Context, arg2 *kinesis.StopStreamEncryptionInput, ...) (*kinesis.StopStreamEncryptionOutput, error)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextArgsForCall(i int) (context.Context, *kinesis.StopStreamEncryptionInput, []request.Option)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextCallCount() int
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextCalls(...)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextReturns(result1 *kinesis.StopStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) StopStreamEncryptionWithContextReturnsOnCall(i int, result1 *kinesis.StopStreamEncryptionOutput, result2 error)
  • func (fake *FakeKinesisAPI) SubscribeToShard(arg1 *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)
  • func (fake *FakeKinesisAPI) SubscribeToShardArgsForCall(i int) *kinesis.SubscribeToShardInput
  • func (fake *FakeKinesisAPI) SubscribeToShardCallCount() int
  • func (fake *FakeKinesisAPI) SubscribeToShardCalls(...)
  • func (fake *FakeKinesisAPI) SubscribeToShardRequest(arg1 *kinesis.SubscribeToShardInput) (*request.Request, *kinesis.SubscribeToShardOutput)
  • func (fake *FakeKinesisAPI) SubscribeToShardRequestArgsForCall(i int) *kinesis.SubscribeToShardInput
  • func (fake *FakeKinesisAPI) SubscribeToShardRequestCallCount() int
  • func (fake *FakeKinesisAPI) SubscribeToShardRequestCalls(...)
  • func (fake *FakeKinesisAPI) SubscribeToShardRequestReturns(result1 *request.Request, result2 *kinesis.SubscribeToShardOutput)
  • func (fake *FakeKinesisAPI) SubscribeToShardRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.SubscribeToShardOutput)
  • func (fake *FakeKinesisAPI) SubscribeToShardReturns(result1 *kinesis.SubscribeToShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SubscribeToShardReturnsOnCall(i int, result1 *kinesis.SubscribeToShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContext(arg1 context.Context, arg2 *kinesis.SubscribeToShardInput, ...) (*kinesis.SubscribeToShardOutput, error)
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContextArgsForCall(i int) (context.Context, *kinesis.SubscribeToShardInput, []request.Option)
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContextCallCount() int
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContextCalls(...)
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContextReturns(result1 *kinesis.SubscribeToShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) SubscribeToShardWithContextReturnsOnCall(i int, result1 *kinesis.SubscribeToShardOutput, result2 error)
  • func (fake *FakeKinesisAPI) UpdateShardCount(arg1 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)
  • func (fake *FakeKinesisAPI) UpdateShardCountArgsForCall(i int) *kinesis.UpdateShardCountInput
  • func (fake *FakeKinesisAPI) UpdateShardCountCallCount() int
  • func (fake *FakeKinesisAPI) UpdateShardCountCalls(...)
  • func (fake *FakeKinesisAPI) UpdateShardCountRequest(arg1 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)
  • func (fake *FakeKinesisAPI) UpdateShardCountRequestArgsForCall(i int) *kinesis.UpdateShardCountInput
  • func (fake *FakeKinesisAPI) UpdateShardCountRequestCallCount() int
  • func (fake *FakeKinesisAPI) UpdateShardCountRequestCalls(...)
  • func (fake *FakeKinesisAPI) UpdateShardCountRequestReturns(result1 *request.Request, result2 *kinesis.UpdateShardCountOutput)
  • func (fake *FakeKinesisAPI) UpdateShardCountRequestReturnsOnCall(i int, result1 *request.Request, result2 *kinesis.UpdateShardCountOutput)
  • func (fake *FakeKinesisAPI) UpdateShardCountReturns(result1 *kinesis.UpdateShardCountOutput, result2 error)
  • func (fake *FakeKinesisAPI) UpdateShardCountReturnsOnCall(i int, result1 *kinesis.UpdateShardCountOutput, result2 error)
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContext(arg1 context.Context, arg2 *kinesis.UpdateShardCountInput, ...) (*kinesis.UpdateShardCountOutput, error)
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContextArgsForCall(i int) (context.Context, *kinesis.UpdateShardCountInput, []request.Option)
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContextCallCount() int
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContextCalls(...)
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContextReturns(result1 *kinesis.UpdateShardCountOutput, result2 error)
  • func (fake *FakeKinesisAPI) UpdateShardCountWithContextReturnsOnCall(i int, result1 *kinesis.UpdateShardCountOutput, result2 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExists(arg1 *kinesis.DescribeStreamInput) error
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsArgsForCall(i int) *kinesis.DescribeStreamInput
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsCallCount() int
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsCalls(stub func(*kinesis.DescribeStreamInput) error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsReturns(result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, ...) error
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextReturns(result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamExistsWithContextReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExists(arg1 *kinesis.DescribeStreamInput) error
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsArgsForCall(i int) *kinesis.DescribeStreamInput
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsCallCount() int
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsCalls(stub func(*kinesis.DescribeStreamInput) error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsReturns(result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsReturnsOnCall(i int, result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContext(arg1 context.Context, arg2 *kinesis.DescribeStreamInput, ...) error
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextArgsForCall(i int) (context.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextCallCount() int
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextCalls(...)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextReturns(result1 error)
  • func (fake *FakeKinesisAPI) WaitUntilStreamNotExistsWithContextReturnsOnCall(i int, result1 error)

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)