kinesismock

package
v1.44.173 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package kinesismock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockKinesisAPI 

type MockKinesisAPI struct {
	// contains filtered or unexported fields
}

MockKinesisAPI is a mock of KinesisAPI interface

func NewMockKinesisAPI 

func NewMockKinesisAPI(ctrl *gomock.Controller) *MockKinesisAPI

NewMockKinesisAPI creates a new mock instance

func (*MockKinesisAPI) AddTagsToStream 

func (m *MockKinesisAPI) AddTagsToStream(arg0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)

AddTagsToStream mocks base method

func (*MockKinesisAPI) AddTagsToStreamRequest 

func (m *MockKinesisAPI) AddTagsToStreamRequest(arg0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)

AddTagsToStreamRequest mocks base method

func (*MockKinesisAPI) AddTagsToStreamWithContext 

func (m *MockKinesisAPI) AddTagsToStreamWithContext(arg0 context.Context, arg1 *kinesis.AddTagsToStreamInput, arg2 ...request.Option) (*kinesis.AddTagsToStreamOutput, error)

AddTagsToStreamWithContext mocks base method

func (*MockKinesisAPI) CreateStream 

func (m *MockKinesisAPI) CreateStream(arg0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

CreateStream mocks base method

func (*MockKinesisAPI) CreateStreamRequest 

func (m *MockKinesisAPI) CreateStreamRequest(arg0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)

CreateStreamRequest mocks base method

func (*MockKinesisAPI) CreateStreamWithContext 

func (m *MockKinesisAPI) CreateStreamWithContext(arg0 context.Context, arg1 *kinesis.CreateStreamInput, arg2 ...request.Option) (*kinesis.CreateStreamOutput, error)

CreateStreamWithContext mocks base method

func (*MockKinesisAPI) DecreaseStreamRetentionPeriod 

func (m *MockKinesisAPI) DecreaseStreamRetentionPeriod(arg0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

DecreaseStreamRetentionPeriod mocks base method

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodRequest 

func (m *MockKinesisAPI) DecreaseStreamRetentionPeriodRequest(arg0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)

DecreaseStreamRetentionPeriodRequest mocks base method

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext 

func (m *MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext(arg0 context.Context, arg1 *kinesis.DecreaseStreamRetentionPeriodInput, arg2 ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

DecreaseStreamRetentionPeriodWithContext mocks base method

func (*MockKinesisAPI) DeleteStream 

func (m *MockKinesisAPI) DeleteStream(arg0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)

DeleteStream mocks base method

func (*MockKinesisAPI) DeleteStreamRequest 

func (m *MockKinesisAPI) DeleteStreamRequest(arg0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)

DeleteStreamRequest mocks base method

func (*MockKinesisAPI) DeleteStreamWithContext 

func (m *MockKinesisAPI) DeleteStreamWithContext(arg0 context.Context, arg1 *kinesis.DeleteStreamInput, arg2 ...request.Option) (*kinesis.DeleteStreamOutput, error)

DeleteStreamWithContext mocks base method

func (*MockKinesisAPI) DeregisterStreamConsumer 

func (m *MockKinesisAPI) DeregisterStreamConsumer(arg0 *kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error)

DeregisterStreamConsumer mocks base method

func (*MockKinesisAPI) DeregisterStreamConsumerRequest 

func (m *MockKinesisAPI) DeregisterStreamConsumerRequest(arg0 *kinesis.DeregisterStreamConsumerInput) (*request.Request, *kinesis.DeregisterStreamConsumerOutput)

DeregisterStreamConsumerRequest mocks base method

func (*MockKinesisAPI) DeregisterStreamConsumerWithContext 

func (m *MockKinesisAPI) DeregisterStreamConsumerWithContext(arg0 context.Context, arg1 *kinesis.DeregisterStreamConsumerInput, arg2 ...request.Option) (*kinesis.DeregisterStreamConsumerOutput, error)

DeregisterStreamConsumerWithContext mocks base method

func (*MockKinesisAPI) DescribeLimits 

func (m *MockKinesisAPI) DescribeLimits(arg0 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)

DescribeLimits mocks base method

func (*MockKinesisAPI) DescribeLimitsRequest 

func (m *MockKinesisAPI) DescribeLimitsRequest(arg0 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)

DescribeLimitsRequest mocks base method

func (*MockKinesisAPI) DescribeLimitsWithContext 

func (m *MockKinesisAPI) DescribeLimitsWithContext(arg0 context.Context, arg1 *kinesis.DescribeLimitsInput, arg2 ...request.Option) (*kinesis.DescribeLimitsOutput, error)

DescribeLimitsWithContext mocks base method

func (*MockKinesisAPI) DescribeStream 

func (m *MockKinesisAPI) DescribeStream(arg0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

DescribeStream mocks base method

func (*MockKinesisAPI) DescribeStreamConsumer 

func (m *MockKinesisAPI) DescribeStreamConsumer(arg0 *kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error)

DescribeStreamConsumer mocks base method

func (*MockKinesisAPI) DescribeStreamConsumerRequest 

func (m *MockKinesisAPI) DescribeStreamConsumerRequest(arg0 *kinesis.DescribeStreamConsumerInput) (*request.Request, *kinesis.DescribeStreamConsumerOutput)

DescribeStreamConsumerRequest mocks base method

func (*MockKinesisAPI) DescribeStreamConsumerWithContext 

func (m *MockKinesisAPI) DescribeStreamConsumerWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamConsumerInput, arg2 ...request.Option) (*kinesis.DescribeStreamConsumerOutput, error)

DescribeStreamConsumerWithContext mocks base method

func (*MockKinesisAPI) DescribeStreamPages 

func (m *MockKinesisAPI) DescribeStreamPages(arg0 *kinesis.DescribeStreamInput, arg1 func(*kinesis.DescribeStreamOutput, bool) bool) error

DescribeStreamPages mocks base method

func (*MockKinesisAPI) DescribeStreamPagesWithContext 

func (m *MockKinesisAPI) DescribeStreamPagesWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamInput, arg2 func(*kinesis.DescribeStreamOutput, bool) bool, arg3 ...request.Option) error

DescribeStreamPagesWithContext mocks base method

func (*MockKinesisAPI) DescribeStreamRequest 

func (m *MockKinesisAPI) DescribeStreamRequest(arg0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)

DescribeStreamRequest mocks base method

func (*MockKinesisAPI) DescribeStreamSummary 

func (m *MockKinesisAPI) DescribeStreamSummary(arg0 *kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)

DescribeStreamSummary mocks base method

func (*MockKinesisAPI) DescribeStreamSummaryRequest 

func (m *MockKinesisAPI) DescribeStreamSummaryRequest(arg0 *kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput)

DescribeStreamSummaryRequest mocks base method

func (*MockKinesisAPI) DescribeStreamSummaryWithContext 

func (m *MockKinesisAPI) DescribeStreamSummaryWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamSummaryInput, arg2 ...request.Option) (*kinesis.DescribeStreamSummaryOutput, error)

DescribeStreamSummaryWithContext mocks base method

func (*MockKinesisAPI) DescribeStreamWithContext 

func (m *MockKinesisAPI) DescribeStreamWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamInput, arg2 ...request.Option) (*kinesis.DescribeStreamOutput, error)

DescribeStreamWithContext mocks base method

func (*MockKinesisAPI) DisableEnhancedMonitoring 

func (m *MockKinesisAPI) DisableEnhancedMonitoring(arg0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

DisableEnhancedMonitoring mocks base method

func (*MockKinesisAPI) DisableEnhancedMonitoringRequest 

func (m *MockKinesisAPI) DisableEnhancedMonitoringRequest(arg0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

DisableEnhancedMonitoringRequest mocks base method

func (*MockKinesisAPI) DisableEnhancedMonitoringWithContext 

func (m *MockKinesisAPI) DisableEnhancedMonitoringWithContext(arg0 context.Context, arg1 *kinesis.DisableEnhancedMonitoringInput, arg2 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

DisableEnhancedMonitoringWithContext mocks base method

func (*MockKinesisAPI) EXPECT 

func (m *MockKinesisAPI) EXPECT() *MockKinesisAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockKinesisAPI) EnableEnhancedMonitoring 

func (m *MockKinesisAPI) EnableEnhancedMonitoring(arg0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

EnableEnhancedMonitoring mocks base method

func (*MockKinesisAPI) EnableEnhancedMonitoringRequest 

func (m *MockKinesisAPI) EnableEnhancedMonitoringRequest(arg0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

EnableEnhancedMonitoringRequest mocks base method

func (*MockKinesisAPI) EnableEnhancedMonitoringWithContext 

func (m *MockKinesisAPI) EnableEnhancedMonitoringWithContext(arg0 context.Context, arg1 *kinesis.EnableEnhancedMonitoringInput, arg2 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

EnableEnhancedMonitoringWithContext mocks base method

func (*MockKinesisAPI) GetRecords 

func (m *MockKinesisAPI) GetRecords(arg0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

GetRecords mocks base method

func (*MockKinesisAPI) GetRecordsRequest 

func (m *MockKinesisAPI) GetRecordsRequest(arg0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)

GetRecordsRequest mocks base method

func (*MockKinesisAPI) GetRecordsWithContext 

func (m *MockKinesisAPI) GetRecordsWithContext(arg0 context.Context, arg1 *kinesis.GetRecordsInput, arg2 ...request.Option) (*kinesis.GetRecordsOutput, error)

GetRecordsWithContext mocks base method

func (*MockKinesisAPI) GetShardIterator 

func (m *MockKinesisAPI) GetShardIterator(arg0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)

GetShardIterator mocks base method

func (*MockKinesisAPI) GetShardIteratorRequest 

func (m *MockKinesisAPI) GetShardIteratorRequest(arg0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)

GetShardIteratorRequest mocks base method

func (*MockKinesisAPI) GetShardIteratorWithContext 

func (m *MockKinesisAPI) GetShardIteratorWithContext(arg0 context.Context, arg1 *kinesis.GetShardIteratorInput, arg2 ...request.Option) (*kinesis.GetShardIteratorOutput, error)

GetShardIteratorWithContext mocks base method

func (*MockKinesisAPI) IncreaseStreamRetentionPeriod 

func (m *MockKinesisAPI) IncreaseStreamRetentionPeriod(arg0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

IncreaseStreamRetentionPeriod mocks base method

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodRequest 

func (m *MockKinesisAPI) IncreaseStreamRetentionPeriodRequest(arg0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)

IncreaseStreamRetentionPeriodRequest mocks base method

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext 

func (m *MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext(arg0 context.Context, arg1 *kinesis.IncreaseStreamRetentionPeriodInput, arg2 ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

IncreaseStreamRetentionPeriodWithContext mocks base method

func (*MockKinesisAPI) ListShards 

func (m *MockKinesisAPI) ListShards(arg0 *kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)

ListShards mocks base method

func (*MockKinesisAPI) ListShardsRequest 

func (m *MockKinesisAPI) ListShardsRequest(arg0 *kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput)

ListShardsRequest mocks base method

func (*MockKinesisAPI) ListShardsWithContext 

func (m *MockKinesisAPI) ListShardsWithContext(arg0 context.Context, arg1 *kinesis.ListShardsInput, arg2 ...request.Option) (*kinesis.ListShardsOutput, error)

ListShardsWithContext mocks base method

func (*MockKinesisAPI) ListStreamConsumers 

func (m *MockKinesisAPI) ListStreamConsumers(arg0 *kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error)

ListStreamConsumers mocks base method

func (*MockKinesisAPI) ListStreamConsumersPages 

func (m *MockKinesisAPI) ListStreamConsumersPages(arg0 *kinesis.ListStreamConsumersInput, arg1 func(*kinesis.ListStreamConsumersOutput, bool) bool) error

ListStreamConsumersPages mocks base method

func (*MockKinesisAPI) ListStreamConsumersPagesWithContext 

func (m *MockKinesisAPI) ListStreamConsumersPagesWithContext(arg0 context.Context, arg1 *kinesis.ListStreamConsumersInput, arg2 func(*kinesis.ListStreamConsumersOutput, bool) bool, arg3 ...request.Option) error

ListStreamConsumersPagesWithContext mocks base method

func (*MockKinesisAPI) ListStreamConsumersRequest 

func (m *MockKinesisAPI) ListStreamConsumersRequest(arg0 *kinesis.ListStreamConsumersInput) (*request.Request, *kinesis.ListStreamConsumersOutput)

ListStreamConsumersRequest mocks base method

func (*MockKinesisAPI) ListStreamConsumersWithContext 

func (m *MockKinesisAPI) ListStreamConsumersWithContext(arg0 context.Context, arg1 *kinesis.ListStreamConsumersInput, arg2 ...request.Option) (*kinesis.ListStreamConsumersOutput, error)

ListStreamConsumersWithContext mocks base method

func (*MockKinesisAPI) ListStreams 

func (m *MockKinesisAPI) ListStreams(arg0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

ListStreams mocks base method

func (*MockKinesisAPI) ListStreamsPages 

func (m *MockKinesisAPI) ListStreamsPages(arg0 *kinesis.ListStreamsInput, arg1 func(*kinesis.ListStreamsOutput, bool) bool) error

ListStreamsPages mocks base method

func (*MockKinesisAPI) ListStreamsPagesWithContext 

func (m *MockKinesisAPI) ListStreamsPagesWithContext(arg0 context.Context, arg1 *kinesis.ListStreamsInput, arg2 func(*kinesis.ListStreamsOutput, bool) bool, arg3 ...request.Option) error

ListStreamsPagesWithContext mocks base method

func (*MockKinesisAPI) ListStreamsRequest 

func (m *MockKinesisAPI) ListStreamsRequest(arg0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)

ListStreamsRequest mocks base method

func (*MockKinesisAPI) ListStreamsWithContext 

func (m *MockKinesisAPI) ListStreamsWithContext(arg0 context.Context, arg1 *kinesis.ListStreamsInput, arg2 ...request.Option) (*kinesis.ListStreamsOutput, error)

ListStreamsWithContext mocks base method

func (*MockKinesisAPI) ListTagsForStream 

func (m *MockKinesisAPI) ListTagsForStream(arg0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)

ListTagsForStream mocks base method

func (*MockKinesisAPI) ListTagsForStreamRequest 

func (m *MockKinesisAPI) ListTagsForStreamRequest(arg0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)

ListTagsForStreamRequest mocks base method

func (*MockKinesisAPI) ListTagsForStreamWithContext 

func (m *MockKinesisAPI) ListTagsForStreamWithContext(arg0 context.Context, arg1 *kinesis.ListTagsForStreamInput, arg2 ...request.Option) (*kinesis.ListTagsForStreamOutput, error)

ListTagsForStreamWithContext mocks base method

func (*MockKinesisAPI) MergeShards 

func (m *MockKinesisAPI) MergeShards(arg0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)

MergeShards mocks base method

func (*MockKinesisAPI) MergeShardsRequest 

func (m *MockKinesisAPI) MergeShardsRequest(arg0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)

MergeShardsRequest mocks base method

func (*MockKinesisAPI) MergeShardsWithContext 

func (m *MockKinesisAPI) MergeShardsWithContext(arg0 context.Context, arg1 *kinesis.MergeShardsInput, arg2 ...request.Option) (*kinesis.MergeShardsOutput, error)

MergeShardsWithContext mocks base method

func (*MockKinesisAPI) PutRecord 

func (m *MockKinesisAPI) PutRecord(arg0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

PutRecord mocks base method

func (*MockKinesisAPI) PutRecordRequest 

func (m *MockKinesisAPI) PutRecordRequest(arg0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)

PutRecordRequest mocks base method

func (*MockKinesisAPI) PutRecordWithContext 

func (m *MockKinesisAPI) PutRecordWithContext(arg0 context.Context, arg1 *kinesis.PutRecordInput, arg2 ...request.Option) (*kinesis.PutRecordOutput, error)

PutRecordWithContext mocks base method

func (*MockKinesisAPI) PutRecords 

func (m *MockKinesisAPI) PutRecords(arg0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

PutRecords mocks base method

func (*MockKinesisAPI) PutRecordsRequest 

func (m *MockKinesisAPI) PutRecordsRequest(arg0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)

PutRecordsRequest mocks base method

func (*MockKinesisAPI) PutRecordsWithContext 

func (m *MockKinesisAPI) PutRecordsWithContext(arg0 context.Context, arg1 *kinesis.PutRecordsInput, arg2 ...request.Option) (*kinesis.PutRecordsOutput, error)

PutRecordsWithContext mocks base method

func (*MockKinesisAPI) RegisterStreamConsumer 

func (m *MockKinesisAPI) RegisterStreamConsumer(arg0 *kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error)

RegisterStreamConsumer mocks base method

func (*MockKinesisAPI) RegisterStreamConsumerRequest 

func (m *MockKinesisAPI) RegisterStreamConsumerRequest(arg0 *kinesis.RegisterStreamConsumerInput) (*request.Request, *kinesis.RegisterStreamConsumerOutput)

RegisterStreamConsumerRequest mocks base method

func (*MockKinesisAPI) RegisterStreamConsumerWithContext 

func (m *MockKinesisAPI) RegisterStreamConsumerWithContext(arg0 context.Context, arg1 *kinesis.RegisterStreamConsumerInput, arg2 ...request.Option) (*kinesis.RegisterStreamConsumerOutput, error)

RegisterStreamConsumerWithContext mocks base method

func (*MockKinesisAPI) RemoveTagsFromStream 

func (m *MockKinesisAPI) RemoveTagsFromStream(arg0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)

RemoveTagsFromStream mocks base method

func (*MockKinesisAPI) RemoveTagsFromStreamRequest 

func (m *MockKinesisAPI) RemoveTagsFromStreamRequest(arg0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)

RemoveTagsFromStreamRequest mocks base method

func (*MockKinesisAPI) RemoveTagsFromStreamWithContext 

func (m *MockKinesisAPI) RemoveTagsFromStreamWithContext(arg0 context.Context, arg1 *kinesis.RemoveTagsFromStreamInput, arg2 ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error)

RemoveTagsFromStreamWithContext mocks base method

func (*MockKinesisAPI) SplitShard 

func (m *MockKinesisAPI) SplitShard(arg0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)

SplitShard mocks base method

func (*MockKinesisAPI) SplitShardRequest 

func (m *MockKinesisAPI) SplitShardRequest(arg0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)

SplitShardRequest mocks base method

func (*MockKinesisAPI) SplitShardWithContext 

func (m *MockKinesisAPI) SplitShardWithContext(arg0 context.Context, arg1 *kinesis.SplitShardInput, arg2 ...request.Option) (*kinesis.SplitShardOutput, error)

SplitShardWithContext mocks base method

func (*MockKinesisAPI) StartStreamEncryption 

func (m *MockKinesisAPI) StartStreamEncryption(arg0 *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)

StartStreamEncryption mocks base method

func (*MockKinesisAPI) StartStreamEncryptionRequest 

func (m *MockKinesisAPI) StartStreamEncryptionRequest(arg0 *kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)

StartStreamEncryptionRequest mocks base method

func (*MockKinesisAPI) StartStreamEncryptionWithContext 

func (m *MockKinesisAPI) StartStreamEncryptionWithContext(arg0 context.Context, arg1 *kinesis.StartStreamEncryptionInput, arg2 ...request.Option) (*kinesis.StartStreamEncryptionOutput, error)

StartStreamEncryptionWithContext mocks base method

func (*MockKinesisAPI) StopStreamEncryption 

func (m *MockKinesisAPI) StopStreamEncryption(arg0 *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)

StopStreamEncryption mocks base method

func (*MockKinesisAPI) StopStreamEncryptionRequest 

func (m *MockKinesisAPI) StopStreamEncryptionRequest(arg0 *kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)

StopStreamEncryptionRequest mocks base method

func (*MockKinesisAPI) StopStreamEncryptionWithContext 

func (m *MockKinesisAPI) StopStreamEncryptionWithContext(arg0 context.Context, arg1 *kinesis.StopStreamEncryptionInput, arg2 ...request.Option) (*kinesis.StopStreamEncryptionOutput, error)

StopStreamEncryptionWithContext mocks base method

func (*MockKinesisAPI) SubscribeToShard 

func (m *MockKinesisAPI) SubscribeToShard(arg0 *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)

SubscribeToShard mocks base method

func (*MockKinesisAPI) SubscribeToShardRequest 

func (m *MockKinesisAPI) SubscribeToShardRequest(arg0 *kinesis.SubscribeToShardInput) (*request.Request, *kinesis.SubscribeToShardOutput)

SubscribeToShardRequest mocks base method

func (*MockKinesisAPI) SubscribeToShardWithContext 

func (m *MockKinesisAPI) SubscribeToShardWithContext(arg0 context.Context, arg1 *kinesis.SubscribeToShardInput, arg2 ...request.Option) (*kinesis.SubscribeToShardOutput, error)

SubscribeToShardWithContext mocks base method

func (*MockKinesisAPI) UpdateShardCount 

func (m *MockKinesisAPI) UpdateShardCount(arg0 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)

UpdateShardCount mocks base method

func (*MockKinesisAPI) UpdateShardCountRequest 

func (m *MockKinesisAPI) UpdateShardCountRequest(arg0 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)

UpdateShardCountRequest mocks base method

func (*MockKinesisAPI) UpdateShardCountWithContext 

func (m *MockKinesisAPI) UpdateShardCountWithContext(arg0 context.Context, arg1 *kinesis.UpdateShardCountInput, arg2 ...request.Option) (*kinesis.UpdateShardCountOutput, error)

UpdateShardCountWithContext mocks base method

func (*MockKinesisAPI) UpdateStreamMode 

func (m *MockKinesisAPI) UpdateStreamMode(arg0 *kinesis.UpdateStreamModeInput) (*kinesis.UpdateStreamModeOutput, error)

UpdateStreamMode mocks base method

func (*MockKinesisAPI) UpdateStreamModeRequest 

func (m *MockKinesisAPI) UpdateStreamModeRequest(arg0 *kinesis.UpdateStreamModeInput) (*request.Request, *kinesis.UpdateStreamModeOutput)

UpdateStreamModeRequest mocks base method

func (*MockKinesisAPI) UpdateStreamModeWithContext 

func (m *MockKinesisAPI) UpdateStreamModeWithContext(arg0 context.Context, arg1 *kinesis.UpdateStreamModeInput, arg2 ...request.Option) (*kinesis.UpdateStreamModeOutput, error)

UpdateStreamModeWithContext mocks base method

func (*MockKinesisAPI) WaitUntilStreamExists 

func (m *MockKinesisAPI) WaitUntilStreamExists(arg0 *kinesis.DescribeStreamInput) error

WaitUntilStreamExists mocks base method

func (*MockKinesisAPI) WaitUntilStreamExistsWithContext 

func (m *MockKinesisAPI) WaitUntilStreamExistsWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamInput, arg2 ...request.WaiterOption) error

WaitUntilStreamExistsWithContext mocks base method

func (*MockKinesisAPI) WaitUntilStreamNotExists 

func (m *MockKinesisAPI) WaitUntilStreamNotExists(arg0 *kinesis.DescribeStreamInput) error

WaitUntilStreamNotExists mocks base method

func (*MockKinesisAPI) WaitUntilStreamNotExistsWithContext 

func (m *MockKinesisAPI) WaitUntilStreamNotExistsWithContext(arg0 context.Context, arg1 *kinesis.DescribeStreamInput, arg2 ...request.WaiterOption) error

WaitUntilStreamNotExistsWithContext mocks base method

type MockKinesisAPIMockRecorder 

type MockKinesisAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockKinesisAPIMockRecorder is the mock recorder for MockKinesisAPI

func (*MockKinesisAPIMockRecorder) AddTagsToStream 

func (mr *MockKinesisAPIMockRecorder) AddTagsToStream(arg0 interface{}) *gomock.Call

AddTagsToStream indicates an expected call of AddTagsToStream

func (*MockKinesisAPIMockRecorder) AddTagsToStreamRequest 

func (mr *MockKinesisAPIMockRecorder) AddTagsToStreamRequest(arg0 interface{}) *gomock.Call

AddTagsToStreamRequest indicates an expected call of AddTagsToStreamRequest

func (*MockKinesisAPIMockRecorder) AddTagsToStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) AddTagsToStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

AddTagsToStreamWithContext indicates an expected call of AddTagsToStreamWithContext

func (*MockKinesisAPIMockRecorder) CreateStream 

func (mr *MockKinesisAPIMockRecorder) CreateStream(arg0 interface{}) *gomock.Call

CreateStream indicates an expected call of CreateStream

func (*MockKinesisAPIMockRecorder) CreateStreamRequest 

func (mr *MockKinesisAPIMockRecorder) CreateStreamRequest(arg0 interface{}) *gomock.Call

CreateStreamRequest indicates an expected call of CreateStreamRequest

func (*MockKinesisAPIMockRecorder) CreateStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) CreateStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CreateStreamWithContext indicates an expected call of CreateStreamWithContext

func (*MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriod 

func (mr *MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriod(arg0 interface{}) *gomock.Call

DecreaseStreamRetentionPeriod indicates an expected call of DecreaseStreamRetentionPeriod

func (*MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriodRequest 

func (mr *MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriodRequest(arg0 interface{}) *gomock.Call

DecreaseStreamRetentionPeriodRequest indicates an expected call of DecreaseStreamRetentionPeriodRequest

func (*MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriodWithContext 

func (mr *MockKinesisAPIMockRecorder) DecreaseStreamRetentionPeriodWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DecreaseStreamRetentionPeriodWithContext indicates an expected call of DecreaseStreamRetentionPeriodWithContext

func (*MockKinesisAPIMockRecorder) DeleteStream 

func (mr *MockKinesisAPIMockRecorder) DeleteStream(arg0 interface{}) *gomock.Call

DeleteStream indicates an expected call of DeleteStream

func (*MockKinesisAPIMockRecorder) DeleteStreamRequest 

func (mr *MockKinesisAPIMockRecorder) DeleteStreamRequest(arg0 interface{}) *gomock.Call

DeleteStreamRequest indicates an expected call of DeleteStreamRequest

func (*MockKinesisAPIMockRecorder) DeleteStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) DeleteStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeleteStreamWithContext indicates an expected call of DeleteStreamWithContext

func (*MockKinesisAPIMockRecorder) DeregisterStreamConsumer 

func (mr *MockKinesisAPIMockRecorder) DeregisterStreamConsumer(arg0 interface{}) *gomock.Call

DeregisterStreamConsumer indicates an expected call of DeregisterStreamConsumer

func (*MockKinesisAPIMockRecorder) DeregisterStreamConsumerRequest 

func (mr *MockKinesisAPIMockRecorder) DeregisterStreamConsumerRequest(arg0 interface{}) *gomock.Call

DeregisterStreamConsumerRequest indicates an expected call of DeregisterStreamConsumerRequest

func (*MockKinesisAPIMockRecorder) DeregisterStreamConsumerWithContext 

func (mr *MockKinesisAPIMockRecorder) DeregisterStreamConsumerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeregisterStreamConsumerWithContext indicates an expected call of DeregisterStreamConsumerWithContext

func (*MockKinesisAPIMockRecorder) DescribeLimits 

func (mr *MockKinesisAPIMockRecorder) DescribeLimits(arg0 interface{}) *gomock.Call

DescribeLimits indicates an expected call of DescribeLimits

func (*MockKinesisAPIMockRecorder) DescribeLimitsRequest 

func (mr *MockKinesisAPIMockRecorder) DescribeLimitsRequest(arg0 interface{}) *gomock.Call

DescribeLimitsRequest indicates an expected call of DescribeLimitsRequest

func (*MockKinesisAPIMockRecorder) DescribeLimitsWithContext 

func (mr *MockKinesisAPIMockRecorder) DescribeLimitsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeLimitsWithContext indicates an expected call of DescribeLimitsWithContext

func (*MockKinesisAPIMockRecorder) DescribeStream 

func (mr *MockKinesisAPIMockRecorder) DescribeStream(arg0 interface{}) *gomock.Call

DescribeStream indicates an expected call of DescribeStream

func (*MockKinesisAPIMockRecorder) DescribeStreamConsumer 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamConsumer(arg0 interface{}) *gomock.Call

DescribeStreamConsumer indicates an expected call of DescribeStreamConsumer

func (*MockKinesisAPIMockRecorder) DescribeStreamConsumerRequest 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamConsumerRequest(arg0 interface{}) *gomock.Call

DescribeStreamConsumerRequest indicates an expected call of DescribeStreamConsumerRequest

func (*MockKinesisAPIMockRecorder) DescribeStreamConsumerWithContext 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamConsumerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeStreamConsumerWithContext indicates an expected call of DescribeStreamConsumerWithContext

func (*MockKinesisAPIMockRecorder) DescribeStreamPages 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamPages(arg0, arg1 interface{}) *gomock.Call

DescribeStreamPages indicates an expected call of DescribeStreamPages

func (*MockKinesisAPIMockRecorder) DescribeStreamPagesWithContext 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

DescribeStreamPagesWithContext indicates an expected call of DescribeStreamPagesWithContext

func (*MockKinesisAPIMockRecorder) DescribeStreamRequest 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamRequest(arg0 interface{}) *gomock.Call

DescribeStreamRequest indicates an expected call of DescribeStreamRequest

func (*MockKinesisAPIMockRecorder) DescribeStreamSummary 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamSummary(arg0 interface{}) *gomock.Call

DescribeStreamSummary indicates an expected call of DescribeStreamSummary

func (*MockKinesisAPIMockRecorder) DescribeStreamSummaryRequest 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamSummaryRequest(arg0 interface{}) *gomock.Call

DescribeStreamSummaryRequest indicates an expected call of DescribeStreamSummaryRequest

func (*MockKinesisAPIMockRecorder) DescribeStreamSummaryWithContext 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamSummaryWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeStreamSummaryWithContext indicates an expected call of DescribeStreamSummaryWithContext

func (*MockKinesisAPIMockRecorder) DescribeStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) DescribeStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeStreamWithContext indicates an expected call of DescribeStreamWithContext

func (*MockKinesisAPIMockRecorder) DisableEnhancedMonitoring 

func (mr *MockKinesisAPIMockRecorder) DisableEnhancedMonitoring(arg0 interface{}) *gomock.Call

DisableEnhancedMonitoring indicates an expected call of DisableEnhancedMonitoring

func (*MockKinesisAPIMockRecorder) DisableEnhancedMonitoringRequest 

func (mr *MockKinesisAPIMockRecorder) DisableEnhancedMonitoringRequest(arg0 interface{}) *gomock.Call

DisableEnhancedMonitoringRequest indicates an expected call of DisableEnhancedMonitoringRequest

func (*MockKinesisAPIMockRecorder) DisableEnhancedMonitoringWithContext 

func (mr *MockKinesisAPIMockRecorder) DisableEnhancedMonitoringWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DisableEnhancedMonitoringWithContext indicates an expected call of DisableEnhancedMonitoringWithContext

func (*MockKinesisAPIMockRecorder) EnableEnhancedMonitoring 

func (mr *MockKinesisAPIMockRecorder) EnableEnhancedMonitoring(arg0 interface{}) *gomock.Call

EnableEnhancedMonitoring indicates an expected call of EnableEnhancedMonitoring

func (*MockKinesisAPIMockRecorder) EnableEnhancedMonitoringRequest 

func (mr *MockKinesisAPIMockRecorder) EnableEnhancedMonitoringRequest(arg0 interface{}) *gomock.Call

EnableEnhancedMonitoringRequest indicates an expected call of EnableEnhancedMonitoringRequest

func (*MockKinesisAPIMockRecorder) EnableEnhancedMonitoringWithContext 

func (mr *MockKinesisAPIMockRecorder) EnableEnhancedMonitoringWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

EnableEnhancedMonitoringWithContext indicates an expected call of EnableEnhancedMonitoringWithContext

func (*MockKinesisAPIMockRecorder) GetRecords 

func (mr *MockKinesisAPIMockRecorder) GetRecords(arg0 interface{}) *gomock.Call

GetRecords indicates an expected call of GetRecords

func (*MockKinesisAPIMockRecorder) GetRecordsRequest 

func (mr *MockKinesisAPIMockRecorder) GetRecordsRequest(arg0 interface{}) *gomock.Call

GetRecordsRequest indicates an expected call of GetRecordsRequest

func (*MockKinesisAPIMockRecorder) GetRecordsWithContext 

func (mr *MockKinesisAPIMockRecorder) GetRecordsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetRecordsWithContext indicates an expected call of GetRecordsWithContext

func (*MockKinesisAPIMockRecorder) GetShardIterator 

func (mr *MockKinesisAPIMockRecorder) GetShardIterator(arg0 interface{}) *gomock.Call

GetShardIterator indicates an expected call of GetShardIterator

func (*MockKinesisAPIMockRecorder) GetShardIteratorRequest 

func (mr *MockKinesisAPIMockRecorder) GetShardIteratorRequest(arg0 interface{}) *gomock.Call

GetShardIteratorRequest indicates an expected call of GetShardIteratorRequest

func (*MockKinesisAPIMockRecorder) GetShardIteratorWithContext 

func (mr *MockKinesisAPIMockRecorder) GetShardIteratorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetShardIteratorWithContext indicates an expected call of GetShardIteratorWithContext

func (*MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriod 

func (mr *MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriod(arg0 interface{}) *gomock.Call

IncreaseStreamRetentionPeriod indicates an expected call of IncreaseStreamRetentionPeriod

func (*MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriodRequest 

func (mr *MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriodRequest(arg0 interface{}) *gomock.Call

IncreaseStreamRetentionPeriodRequest indicates an expected call of IncreaseStreamRetentionPeriodRequest

func (*MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriodWithContext 

func (mr *MockKinesisAPIMockRecorder) IncreaseStreamRetentionPeriodWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

IncreaseStreamRetentionPeriodWithContext indicates an expected call of IncreaseStreamRetentionPeriodWithContext

func (*MockKinesisAPIMockRecorder) ListShards 

func (mr *MockKinesisAPIMockRecorder) ListShards(arg0 interface{}) *gomock.Call

ListShards indicates an expected call of ListShards

func (*MockKinesisAPIMockRecorder) ListShardsRequest 

func (mr *MockKinesisAPIMockRecorder) ListShardsRequest(arg0 interface{}) *gomock.Call

ListShardsRequest indicates an expected call of ListShardsRequest

func (*MockKinesisAPIMockRecorder) ListShardsWithContext 

func (mr *MockKinesisAPIMockRecorder) ListShardsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListShardsWithContext indicates an expected call of ListShardsWithContext

func (*MockKinesisAPIMockRecorder) ListStreamConsumers 

func (mr *MockKinesisAPIMockRecorder) ListStreamConsumers(arg0 interface{}) *gomock.Call

ListStreamConsumers indicates an expected call of ListStreamConsumers

func (*MockKinesisAPIMockRecorder) ListStreamConsumersPages 

func (mr *MockKinesisAPIMockRecorder) ListStreamConsumersPages(arg0, arg1 interface{}) *gomock.Call

ListStreamConsumersPages indicates an expected call of ListStreamConsumersPages

func (*MockKinesisAPIMockRecorder) ListStreamConsumersPagesWithContext 

func (mr *MockKinesisAPIMockRecorder) ListStreamConsumersPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

ListStreamConsumersPagesWithContext indicates an expected call of ListStreamConsumersPagesWithContext

func (*MockKinesisAPIMockRecorder) ListStreamConsumersRequest 

func (mr *MockKinesisAPIMockRecorder) ListStreamConsumersRequest(arg0 interface{}) *gomock.Call

ListStreamConsumersRequest indicates an expected call of ListStreamConsumersRequest

func (*MockKinesisAPIMockRecorder) ListStreamConsumersWithContext 

func (mr *MockKinesisAPIMockRecorder) ListStreamConsumersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListStreamConsumersWithContext indicates an expected call of ListStreamConsumersWithContext

func (*MockKinesisAPIMockRecorder) ListStreams 

func (mr *MockKinesisAPIMockRecorder) ListStreams(arg0 interface{}) *gomock.Call

ListStreams indicates an expected call of ListStreams

func (*MockKinesisAPIMockRecorder) ListStreamsPages 

func (mr *MockKinesisAPIMockRecorder) ListStreamsPages(arg0, arg1 interface{}) *gomock.Call

ListStreamsPages indicates an expected call of ListStreamsPages

func (*MockKinesisAPIMockRecorder) ListStreamsPagesWithContext 

func (mr *MockKinesisAPIMockRecorder) ListStreamsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

ListStreamsPagesWithContext indicates an expected call of ListStreamsPagesWithContext

func (*MockKinesisAPIMockRecorder) ListStreamsRequest 

func (mr *MockKinesisAPIMockRecorder) ListStreamsRequest(arg0 interface{}) *gomock.Call

ListStreamsRequest indicates an expected call of ListStreamsRequest

func (*MockKinesisAPIMockRecorder) ListStreamsWithContext 

func (mr *MockKinesisAPIMockRecorder) ListStreamsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListStreamsWithContext indicates an expected call of ListStreamsWithContext

func (*MockKinesisAPIMockRecorder) ListTagsForStream 

func (mr *MockKinesisAPIMockRecorder) ListTagsForStream(arg0 interface{}) *gomock.Call

ListTagsForStream indicates an expected call of ListTagsForStream

func (*MockKinesisAPIMockRecorder) ListTagsForStreamRequest 

func (mr *MockKinesisAPIMockRecorder) ListTagsForStreamRequest(arg0 interface{}) *gomock.Call

ListTagsForStreamRequest indicates an expected call of ListTagsForStreamRequest

func (*MockKinesisAPIMockRecorder) ListTagsForStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) ListTagsForStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListTagsForStreamWithContext indicates an expected call of ListTagsForStreamWithContext

func (*MockKinesisAPIMockRecorder) MergeShards 

func (mr *MockKinesisAPIMockRecorder) MergeShards(arg0 interface{}) *gomock.Call

MergeShards indicates an expected call of MergeShards

func (*MockKinesisAPIMockRecorder) MergeShardsRequest 

func (mr *MockKinesisAPIMockRecorder) MergeShardsRequest(arg0 interface{}) *gomock.Call

MergeShardsRequest indicates an expected call of MergeShardsRequest

func (*MockKinesisAPIMockRecorder) MergeShardsWithContext 

func (mr *MockKinesisAPIMockRecorder) MergeShardsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

MergeShardsWithContext indicates an expected call of MergeShardsWithContext

func (*MockKinesisAPIMockRecorder) PutRecord 

func (mr *MockKinesisAPIMockRecorder) PutRecord(arg0 interface{}) *gomock.Call

PutRecord indicates an expected call of PutRecord

func (*MockKinesisAPIMockRecorder) PutRecordRequest 

func (mr *MockKinesisAPIMockRecorder) PutRecordRequest(arg0 interface{}) *gomock.Call

PutRecordRequest indicates an expected call of PutRecordRequest

func (*MockKinesisAPIMockRecorder) PutRecordWithContext 

func (mr *MockKinesisAPIMockRecorder) PutRecordWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PutRecordWithContext indicates an expected call of PutRecordWithContext

func (*MockKinesisAPIMockRecorder) PutRecords 

func (mr *MockKinesisAPIMockRecorder) PutRecords(arg0 interface{}) *gomock.Call

PutRecords indicates an expected call of PutRecords

func (*MockKinesisAPIMockRecorder) PutRecordsRequest 

func (mr *MockKinesisAPIMockRecorder) PutRecordsRequest(arg0 interface{}) *gomock.Call

PutRecordsRequest indicates an expected call of PutRecordsRequest

func (*MockKinesisAPIMockRecorder) PutRecordsWithContext 

func (mr *MockKinesisAPIMockRecorder) PutRecordsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PutRecordsWithContext indicates an expected call of PutRecordsWithContext

func (*MockKinesisAPIMockRecorder) RegisterStreamConsumer 

func (mr *MockKinesisAPIMockRecorder) RegisterStreamConsumer(arg0 interface{}) *gomock.Call

RegisterStreamConsumer indicates an expected call of RegisterStreamConsumer

func (*MockKinesisAPIMockRecorder) RegisterStreamConsumerRequest 

func (mr *MockKinesisAPIMockRecorder) RegisterStreamConsumerRequest(arg0 interface{}) *gomock.Call

RegisterStreamConsumerRequest indicates an expected call of RegisterStreamConsumerRequest

func (*MockKinesisAPIMockRecorder) RegisterStreamConsumerWithContext 

func (mr *MockKinesisAPIMockRecorder) RegisterStreamConsumerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RegisterStreamConsumerWithContext indicates an expected call of RegisterStreamConsumerWithContext

func (*MockKinesisAPIMockRecorder) RemoveTagsFromStream 

func (mr *MockKinesisAPIMockRecorder) RemoveTagsFromStream(arg0 interface{}) *gomock.Call

RemoveTagsFromStream indicates an expected call of RemoveTagsFromStream

func (*MockKinesisAPIMockRecorder) RemoveTagsFromStreamRequest 

func (mr *MockKinesisAPIMockRecorder) RemoveTagsFromStreamRequest(arg0 interface{}) *gomock.Call

RemoveTagsFromStreamRequest indicates an expected call of RemoveTagsFromStreamRequest

func (*MockKinesisAPIMockRecorder) RemoveTagsFromStreamWithContext 

func (mr *MockKinesisAPIMockRecorder) RemoveTagsFromStreamWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RemoveTagsFromStreamWithContext indicates an expected call of RemoveTagsFromStreamWithContext

func (*MockKinesisAPIMockRecorder) SplitShard 

func (mr *MockKinesisAPIMockRecorder) SplitShard(arg0 interface{}) *gomock.Call

SplitShard indicates an expected call of SplitShard

func (*MockKinesisAPIMockRecorder) SplitShardRequest 

func (mr *MockKinesisAPIMockRecorder) SplitShardRequest(arg0 interface{}) *gomock.Call

SplitShardRequest indicates an expected call of SplitShardRequest

func (*MockKinesisAPIMockRecorder) SplitShardWithContext 

func (mr *MockKinesisAPIMockRecorder) SplitShardWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SplitShardWithContext indicates an expected call of SplitShardWithContext

func (*MockKinesisAPIMockRecorder) StartStreamEncryption 

func (mr *MockKinesisAPIMockRecorder) StartStreamEncryption(arg0 interface{}) *gomock.Call

StartStreamEncryption indicates an expected call of StartStreamEncryption

func (*MockKinesisAPIMockRecorder) StartStreamEncryptionRequest 

func (mr *MockKinesisAPIMockRecorder) StartStreamEncryptionRequest(arg0 interface{}) *gomock.Call

StartStreamEncryptionRequest indicates an expected call of StartStreamEncryptionRequest

func (*MockKinesisAPIMockRecorder) StartStreamEncryptionWithContext 

func (mr *MockKinesisAPIMockRecorder) StartStreamEncryptionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StartStreamEncryptionWithContext indicates an expected call of StartStreamEncryptionWithContext

func (*MockKinesisAPIMockRecorder) StopStreamEncryption 

func (mr *MockKinesisAPIMockRecorder) StopStreamEncryption(arg0 interface{}) *gomock.Call

StopStreamEncryption indicates an expected call of StopStreamEncryption

func (*MockKinesisAPIMockRecorder) StopStreamEncryptionRequest 

func (mr *MockKinesisAPIMockRecorder) StopStreamEncryptionRequest(arg0 interface{}) *gomock.Call

StopStreamEncryptionRequest indicates an expected call of StopStreamEncryptionRequest

func (*MockKinesisAPIMockRecorder) StopStreamEncryptionWithContext 

func (mr *MockKinesisAPIMockRecorder) StopStreamEncryptionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StopStreamEncryptionWithContext indicates an expected call of StopStreamEncryptionWithContext

func (*MockKinesisAPIMockRecorder) SubscribeToShard 

func (mr *MockKinesisAPIMockRecorder) SubscribeToShard(arg0 interface{}) *gomock.Call

SubscribeToShard indicates an expected call of SubscribeToShard

func (*MockKinesisAPIMockRecorder) SubscribeToShardRequest 

func (mr *MockKinesisAPIMockRecorder) SubscribeToShardRequest(arg0 interface{}) *gomock.Call

SubscribeToShardRequest indicates an expected call of SubscribeToShardRequest

func (*MockKinesisAPIMockRecorder) SubscribeToShardWithContext 

func (mr *MockKinesisAPIMockRecorder) SubscribeToShardWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SubscribeToShardWithContext indicates an expected call of SubscribeToShardWithContext

func (*MockKinesisAPIMockRecorder) UpdateShardCount 

func (mr *MockKinesisAPIMockRecorder) UpdateShardCount(arg0 interface{}) *gomock.Call

UpdateShardCount indicates an expected call of UpdateShardCount

func (*MockKinesisAPIMockRecorder) UpdateShardCountRequest 

func (mr *MockKinesisAPIMockRecorder) UpdateShardCountRequest(arg0 interface{}) *gomock.Call

UpdateShardCountRequest indicates an expected call of UpdateShardCountRequest

func (*MockKinesisAPIMockRecorder) UpdateShardCountWithContext 

func (mr *MockKinesisAPIMockRecorder) UpdateShardCountWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateShardCountWithContext indicates an expected call of UpdateShardCountWithContext

func (*MockKinesisAPIMockRecorder) UpdateStreamMode 

func (mr *MockKinesisAPIMockRecorder) UpdateStreamMode(arg0 interface{}) *gomock.Call

UpdateStreamMode indicates an expected call of UpdateStreamMode

func (*MockKinesisAPIMockRecorder) UpdateStreamModeRequest 

func (mr *MockKinesisAPIMockRecorder) UpdateStreamModeRequest(arg0 interface{}) *gomock.Call

UpdateStreamModeRequest indicates an expected call of UpdateStreamModeRequest

func (*MockKinesisAPIMockRecorder) UpdateStreamModeWithContext 

func (mr *MockKinesisAPIMockRecorder) UpdateStreamModeWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateStreamModeWithContext indicates an expected call of UpdateStreamModeWithContext

func (*MockKinesisAPIMockRecorder) WaitUntilStreamExists 

func (mr *MockKinesisAPIMockRecorder) WaitUntilStreamExists(arg0 interface{}) *gomock.Call

WaitUntilStreamExists indicates an expected call of WaitUntilStreamExists

func (*MockKinesisAPIMockRecorder) WaitUntilStreamExistsWithContext 

func (mr *MockKinesisAPIMockRecorder) WaitUntilStreamExistsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

WaitUntilStreamExistsWithContext indicates an expected call of WaitUntilStreamExistsWithContext

func (*MockKinesisAPIMockRecorder) WaitUntilStreamNotExists 

func (mr *MockKinesisAPIMockRecorder) WaitUntilStreamNotExists(arg0 interface{}) *gomock.Call

WaitUntilStreamNotExists indicates an expected call of WaitUntilStreamNotExists

func (*MockKinesisAPIMockRecorder) WaitUntilStreamNotExistsWithContext 

func (mr *MockKinesisAPIMockRecorder) WaitUntilStreamNotExistsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

WaitUntilStreamNotExistsWithContext indicates an expected call of WaitUntilStreamNotExistsWithContext

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.