Documentation
¶
Index ¶
- type IClient
- func (_m *IClient) AddTagsToStream(ctx context.Context, params *kinesis.AddTagsToStreamInput, ...) (*kinesis.AddTagsToStreamOutput, error)
- func (_m *IClient) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, ...) (*kinesis.CreateStreamOutput, error)
- func (_m *IClient) DecreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.DecreaseStreamRetentionPeriodInput, ...) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
- func (_m *IClient) DeleteResourcePolicy(ctx context.Context, params *kinesis.DeleteResourcePolicyInput, ...) (*kinesis.DeleteResourcePolicyOutput, error)
- func (_m *IClient) DeleteStream(ctx context.Context, params *kinesis.DeleteStreamInput, ...) (*kinesis.DeleteStreamOutput, error)
- func (_m *IClient) DeregisterStreamConsumer(ctx context.Context, params *kinesis.DeregisterStreamConsumerInput, ...) (*kinesis.DeregisterStreamConsumerOutput, error)
- func (_m *IClient) DescribeLimits(ctx context.Context, params *kinesis.DescribeLimitsInput, ...) (*kinesis.DescribeLimitsOutput, error)
- func (_m *IClient) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, ...) (*kinesis.DescribeStreamOutput, error)
- func (_m *IClient) DescribeStreamConsumer(ctx context.Context, params *kinesis.DescribeStreamConsumerInput, ...) (*kinesis.DescribeStreamConsumerOutput, error)
- func (_m *IClient) DescribeStreamSummary(ctx context.Context, params *kinesis.DescribeStreamSummaryInput, ...) (*kinesis.DescribeStreamSummaryOutput, error)
- func (_m *IClient) DisableEnhancedMonitoring(ctx context.Context, params *kinesis.DisableEnhancedMonitoringInput, ...) (*kinesis.DisableEnhancedMonitoringOutput, error)
- func (_m *IClient) EnableEnhancedMonitoring(ctx context.Context, params *kinesis.EnableEnhancedMonitoringInput, ...) (*kinesis.EnableEnhancedMonitoringOutput, error)
- func (_m *IClient) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, ...) (*kinesis.GetRecordsOutput, error)
- func (_m *IClient) GetResourcePolicy(ctx context.Context, params *kinesis.GetResourcePolicyInput, ...) (*kinesis.GetResourcePolicyOutput, error)
- func (_m *IClient) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, ...) (*kinesis.GetShardIteratorOutput, error)
- func (_m *IClient) IncreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.IncreaseStreamRetentionPeriodInput, ...) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
- func (_m *IClient) ListShards(ctx context.Context, params *kinesis.ListShardsInput, ...) (*kinesis.ListShardsOutput, error)
- func (_m *IClient) ListStreamConsumers(ctx context.Context, params *kinesis.ListStreamConsumersInput, ...) (*kinesis.ListStreamConsumersOutput, error)
- func (_m *IClient) ListStreams(ctx context.Context, params *kinesis.ListStreamsInput, ...) (*kinesis.ListStreamsOutput, error)
- func (_m *IClient) ListTagsForStream(ctx context.Context, params *kinesis.ListTagsForStreamInput, ...) (*kinesis.ListTagsForStreamOutput, error)
- func (_m *IClient) MergeShards(ctx context.Context, params *kinesis.MergeShardsInput, ...) (*kinesis.MergeShardsOutput, error)
- func (_m *IClient) Options() kinesis.Options
- func (_m *IClient) PutRecord(ctx context.Context, params *kinesis.PutRecordInput, ...) (*kinesis.PutRecordOutput, error)
- func (_m *IClient) PutRecords(ctx context.Context, params *kinesis.PutRecordsInput, ...) (*kinesis.PutRecordsOutput, error)
- func (_m *IClient) PutResourcePolicy(ctx context.Context, params *kinesis.PutResourcePolicyInput, ...) (*kinesis.PutResourcePolicyOutput, error)
- func (_m *IClient) RegisterStreamConsumer(ctx context.Context, params *kinesis.RegisterStreamConsumerInput, ...) (*kinesis.RegisterStreamConsumerOutput, error)
- func (_m *IClient) RemoveTagsFromStream(ctx context.Context, params *kinesis.RemoveTagsFromStreamInput, ...) (*kinesis.RemoveTagsFromStreamOutput, error)
- func (_m *IClient) SplitShard(ctx context.Context, params *kinesis.SplitShardInput, ...) (*kinesis.SplitShardOutput, error)
- func (_m *IClient) StartStreamEncryption(ctx context.Context, params *kinesis.StartStreamEncryptionInput, ...) (*kinesis.StartStreamEncryptionOutput, error)
- func (_m *IClient) StopStreamEncryption(ctx context.Context, params *kinesis.StopStreamEncryptionInput, ...) (*kinesis.StopStreamEncryptionOutput, error)
- func (_m *IClient) SubscribeToShard(ctx context.Context, params *kinesis.SubscribeToShardInput, ...) (*kinesis.SubscribeToShardOutput, error)
- func (_m *IClient) UpdateShardCount(ctx context.Context, params *kinesis.UpdateShardCountInput, ...) (*kinesis.UpdateShardCountOutput, error)
- func (_m *IClient) UpdateStreamMode(ctx context.Context, params *kinesis.UpdateStreamModeInput, ...) (*kinesis.UpdateStreamModeOutput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IClient ¶
IClient is an autogenerated mock type for the IClient type
func NewIClient ¶
NewIClient creates a new instance of IClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*IClient) AddTagsToStream ¶
func (_m *IClient) AddTagsToStream(ctx context.Context, params *kinesis.AddTagsToStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.AddTagsToStreamOutput, error)
AddTagsToStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateStream ¶
func (_m *IClient) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)
CreateStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) DecreaseStreamRetentionPeriod ¶
func (_m *IClient) DecreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.DecreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options)) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
DecreaseStreamRetentionPeriod provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteResourcePolicy ¶
func (_m *IClient) DeleteResourcePolicy(ctx context.Context, params *kinesis.DeleteResourcePolicyInput, optFns ...func(*kinesis.Options)) (*kinesis.DeleteResourcePolicyOutput, error)
DeleteResourcePolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteStream ¶
func (_m *IClient) DeleteStream(ctx context.Context, params *kinesis.DeleteStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DeleteStreamOutput, error)
DeleteStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeregisterStreamConsumer ¶
func (_m *IClient) DeregisterStreamConsumer(ctx context.Context, params *kinesis.DeregisterStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.DeregisterStreamConsumerOutput, error)
DeregisterStreamConsumer provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeLimits ¶
func (_m *IClient) DescribeLimits(ctx context.Context, params *kinesis.DescribeLimitsInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeLimitsOutput, error)
DescribeLimits provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeStream ¶
func (_m *IClient) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)
DescribeStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeStreamConsumer ¶
func (_m *IClient) DescribeStreamConsumer(ctx context.Context, params *kinesis.DescribeStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamConsumerOutput, error)
DescribeStreamConsumer provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeStreamSummary ¶
func (_m *IClient) DescribeStreamSummary(ctx context.Context, params *kinesis.DescribeStreamSummaryInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamSummaryOutput, error)
DescribeStreamSummary provides a mock function with given fields: ctx, params, optFns
func (*IClient) DisableEnhancedMonitoring ¶
func (_m *IClient) DisableEnhancedMonitoring(ctx context.Context, params *kinesis.DisableEnhancedMonitoringInput, optFns ...func(*kinesis.Options)) (*kinesis.DisableEnhancedMonitoringOutput, error)
DisableEnhancedMonitoring provides a mock function with given fields: ctx, params, optFns
func (*IClient) EnableEnhancedMonitoring ¶
func (_m *IClient) EnableEnhancedMonitoring(ctx context.Context, params *kinesis.EnableEnhancedMonitoringInput, optFns ...func(*kinesis.Options)) (*kinesis.EnableEnhancedMonitoringOutput, error)
EnableEnhancedMonitoring provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetRecords ¶
func (_m *IClient) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)
GetRecords provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetResourcePolicy ¶
func (_m *IClient) GetResourcePolicy(ctx context.Context, params *kinesis.GetResourcePolicyInput, optFns ...func(*kinesis.Options)) (*kinesis.GetResourcePolicyOutput, error)
GetResourcePolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetShardIterator ¶
func (_m *IClient) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)
GetShardIterator provides a mock function with given fields: ctx, params, optFns
func (*IClient) IncreaseStreamRetentionPeriod ¶
func (_m *IClient) IncreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.IncreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options)) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
IncreaseStreamRetentionPeriod provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListShards ¶
func (_m *IClient) ListShards(ctx context.Context, params *kinesis.ListShardsInput, optFns ...func(*kinesis.Options)) (*kinesis.ListShardsOutput, error)
ListShards provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListStreamConsumers ¶
func (_m *IClient) ListStreamConsumers(ctx context.Context, params *kinesis.ListStreamConsumersInput, optFns ...func(*kinesis.Options)) (*kinesis.ListStreamConsumersOutput, error)
ListStreamConsumers provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListStreams ¶
func (_m *IClient) ListStreams(ctx context.Context, params *kinesis.ListStreamsInput, optFns ...func(*kinesis.Options)) (*kinesis.ListStreamsOutput, error)
ListStreams provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListTagsForStream ¶
func (_m *IClient) ListTagsForStream(ctx context.Context, params *kinesis.ListTagsForStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.ListTagsForStreamOutput, error)
ListTagsForStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) MergeShards ¶
func (_m *IClient) MergeShards(ctx context.Context, params *kinesis.MergeShardsInput, optFns ...func(*kinesis.Options)) (*kinesis.MergeShardsOutput, error)
MergeShards provides a mock function with given fields: ctx, params, optFns
func (*IClient) PutRecord ¶
func (_m *IClient) PutRecord(ctx context.Context, params *kinesis.PutRecordInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordOutput, error)
PutRecord provides a mock function with given fields: ctx, params, optFns
func (*IClient) PutRecords ¶
func (_m *IClient) PutRecords(ctx context.Context, params *kinesis.PutRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordsOutput, error)
PutRecords provides a mock function with given fields: ctx, params, optFns
func (*IClient) PutResourcePolicy ¶
func (_m *IClient) PutResourcePolicy(ctx context.Context, params *kinesis.PutResourcePolicyInput, optFns ...func(*kinesis.Options)) (*kinesis.PutResourcePolicyOutput, error)
PutResourcePolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) RegisterStreamConsumer ¶
func (_m *IClient) RegisterStreamConsumer(ctx context.Context, params *kinesis.RegisterStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.RegisterStreamConsumerOutput, error)
RegisterStreamConsumer provides a mock function with given fields: ctx, params, optFns
func (*IClient) RemoveTagsFromStream ¶
func (_m *IClient) RemoveTagsFromStream(ctx context.Context, params *kinesis.RemoveTagsFromStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.RemoveTagsFromStreamOutput, error)
RemoveTagsFromStream provides a mock function with given fields: ctx, params, optFns
func (*IClient) SplitShard ¶
func (_m *IClient) SplitShard(ctx context.Context, params *kinesis.SplitShardInput, optFns ...func(*kinesis.Options)) (*kinesis.SplitShardOutput, error)
SplitShard provides a mock function with given fields: ctx, params, optFns
func (*IClient) StartStreamEncryption ¶
func (_m *IClient) StartStreamEncryption(ctx context.Context, params *kinesis.StartStreamEncryptionInput, optFns ...func(*kinesis.Options)) (*kinesis.StartStreamEncryptionOutput, error)
StartStreamEncryption provides a mock function with given fields: ctx, params, optFns
func (*IClient) StopStreamEncryption ¶
func (_m *IClient) StopStreamEncryption(ctx context.Context, params *kinesis.StopStreamEncryptionInput, optFns ...func(*kinesis.Options)) (*kinesis.StopStreamEncryptionOutput, error)
StopStreamEncryption provides a mock function with given fields: ctx, params, optFns
func (*IClient) SubscribeToShard ¶
func (_m *IClient) SubscribeToShard(ctx context.Context, params *kinesis.SubscribeToShardInput, optFns ...func(*kinesis.Options)) (*kinesis.SubscribeToShardOutput, error)
SubscribeToShard provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateShardCount ¶
func (_m *IClient) UpdateShardCount(ctx context.Context, params *kinesis.UpdateShardCountInput, optFns ...func(*kinesis.Options)) (*kinesis.UpdateShardCountOutput, error)
UpdateShardCount provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateStreamMode ¶
func (_m *IClient) UpdateStreamMode(ctx context.Context, params *kinesis.UpdateStreamModeInput, optFns ...func(*kinesis.Options)) (*kinesis.UpdateStreamModeOutput, error)
UpdateStreamMode provides a mock function with given fields: ctx, params, optFns