Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mock

package

Go to main page

Versions in this module

v1

v1.2.0

Sep 20, 2019

v1.1.0

Nov 15, 2018

v1.0.0

Mar 9, 2018

Changes in this version

+ type KinesisAPI_AddTagsToStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_AddTagsToStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.AddTagsToStreamInput)

+ func (c *KinesisAPI_AddTagsToStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.AddTagsToStreamInput

+ type KinesisAPI_AddTagsToStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_AddTagsToStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.AddTagsToStreamInput, ...)

+ func (c *KinesisAPI_AddTagsToStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.AddTagsToStreamInput, []request.Option)

+ type KinesisAPI_AddTagsToStream_OngoingVerification struct

+ func (c *KinesisAPI_AddTagsToStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.AddTagsToStreamInput)

+ func (c *KinesisAPI_AddTagsToStream_OngoingVerification) GetCapturedArguments() *kinesis.AddTagsToStreamInput

+ type KinesisAPI_CreateStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_CreateStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.CreateStreamInput)

+ func (c *KinesisAPI_CreateStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.CreateStreamInput

+ type KinesisAPI_CreateStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_CreateStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.CreateStreamInput, ...)

+ func (c *KinesisAPI_CreateStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.CreateStreamInput, []request.Option)

+ type KinesisAPI_CreateStream_OngoingVerification struct

+ func (c *KinesisAPI_CreateStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.CreateStreamInput)

+ func (c *KinesisAPI_CreateStream_OngoingVerification) GetCapturedArguments() *kinesis.CreateStreamInput

+ type KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification struct

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DecreaseStreamRetentionPeriodInput)

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification) GetCapturedArguments() *kinesis.DecreaseStreamRetentionPeriodInput

+ type KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DecreaseStreamRetentionPeriodInput, ...)

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DecreaseStreamRetentionPeriodInput, []request.Option)

+ type KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification struct

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DecreaseStreamRetentionPeriodInput)

+ func (c *KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification) GetCapturedArguments() *kinesis.DecreaseStreamRetentionPeriodInput

+ type KinesisAPI_DeleteStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_DeleteStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DeleteStreamInput)

+ func (c *KinesisAPI_DeleteStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.DeleteStreamInput

+ type KinesisAPI_DeleteStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DeleteStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DeleteStreamInput, ...)

+ func (c *KinesisAPI_DeleteStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DeleteStreamInput, []request.Option)

+ type KinesisAPI_DeleteStream_OngoingVerification struct

+ func (c *KinesisAPI_DeleteStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DeleteStreamInput)

+ func (c *KinesisAPI_DeleteStream_OngoingVerification) GetCapturedArguments() *kinesis.DeleteStreamInput

+ type KinesisAPI_DescribeLimitsRequest_OngoingVerification struct

+ func (c *KinesisAPI_DescribeLimitsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeLimitsInput)

+ func (c *KinesisAPI_DescribeLimitsRequest_OngoingVerification) GetCapturedArguments() *kinesis.DescribeLimitsInput

+ type KinesisAPI_DescribeLimitsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DescribeLimitsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeLimitsInput, ...)

+ func (c *KinesisAPI_DescribeLimitsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeLimitsInput, []request.Option)

+ type KinesisAPI_DescribeLimits_OngoingVerification struct

+ func (c *KinesisAPI_DescribeLimits_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeLimitsInput)

+ func (c *KinesisAPI_DescribeLimits_OngoingVerification) GetCapturedArguments() *kinesis.DescribeLimitsInput

+ type KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamInput, ...)

+ func (c *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamInput, ...)

+ type KinesisAPI_DescribeStreamPages_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamPages_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput, ...)

+ func (c *KinesisAPI_DescribeStreamPages_OngoingVerification) GetCapturedArguments() (*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool)

+ type KinesisAPI_DescribeStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput)

+ func (c *KinesisAPI_DescribeStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamInput

+ type KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamSummaryInput)

+ func (c *KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamSummaryInput

+ type KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamSummaryInput, ...)

+ func (c *KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamSummaryInput, []request.Option)

+ type KinesisAPI_DescribeStreamSummary_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamSummary_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamSummaryInput)

+ func (c *KinesisAPI_DescribeStreamSummary_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamSummaryInput

+ type KinesisAPI_DescribeStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamInput, ...)

+ func (c *KinesisAPI_DescribeStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamInput, []request.Option)

+ type KinesisAPI_DescribeStream_OngoingVerification struct

+ func (c *KinesisAPI_DescribeStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput)

+ func (c *KinesisAPI_DescribeStream_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamInput

+ type KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification struct

+ func (c *KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DisableEnhancedMonitoringInput)

+ func (c *KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification) GetCapturedArguments() *kinesis.DisableEnhancedMonitoringInput

+ type KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification struct

+ func (c *KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DisableEnhancedMonitoringInput, ...)

+ func (c *KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DisableEnhancedMonitoringInput, []request.Option)

+ type KinesisAPI_DisableEnhancedMonitoring_OngoingVerification struct

+ func (c *KinesisAPI_DisableEnhancedMonitoring_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DisableEnhancedMonitoringInput)

+ func (c *KinesisAPI_DisableEnhancedMonitoring_OngoingVerification) GetCapturedArguments() *kinesis.DisableEnhancedMonitoringInput

+ type KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification struct

+ func (c *KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.EnableEnhancedMonitoringInput)

+ func (c *KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification) GetCapturedArguments() *kinesis.EnableEnhancedMonitoringInput

+ type KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification struct

+ func (c *KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.EnableEnhancedMonitoringInput, ...)

+ func (c *KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.EnableEnhancedMonitoringInput, []request.Option)

+ type KinesisAPI_EnableEnhancedMonitoring_OngoingVerification struct

+ func (c *KinesisAPI_EnableEnhancedMonitoring_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.EnableEnhancedMonitoringInput)

+ func (c *KinesisAPI_EnableEnhancedMonitoring_OngoingVerification) GetCapturedArguments() *kinesis.EnableEnhancedMonitoringInput

+ type KinesisAPI_GetRecordsRequest_OngoingVerification struct

+ func (c *KinesisAPI_GetRecordsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.GetRecordsInput)

+ func (c *KinesisAPI_GetRecordsRequest_OngoingVerification) GetCapturedArguments() *kinesis.GetRecordsInput

+ type KinesisAPI_GetRecordsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_GetRecordsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.GetRecordsInput, ...)

+ func (c *KinesisAPI_GetRecordsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.GetRecordsInput, []request.Option)

+ type KinesisAPI_GetRecords_OngoingVerification struct

+ func (c *KinesisAPI_GetRecords_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.GetRecordsInput)

+ func (c *KinesisAPI_GetRecords_OngoingVerification) GetCapturedArguments() *kinesis.GetRecordsInput

+ type KinesisAPI_GetShardIteratorRequest_OngoingVerification struct

+ func (c *KinesisAPI_GetShardIteratorRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.GetShardIteratorInput)

+ func (c *KinesisAPI_GetShardIteratorRequest_OngoingVerification) GetCapturedArguments() *kinesis.GetShardIteratorInput

+ type KinesisAPI_GetShardIteratorWithContext_OngoingVerification struct

+ func (c *KinesisAPI_GetShardIteratorWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.GetShardIteratorInput, ...)

+ func (c *KinesisAPI_GetShardIteratorWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.GetShardIteratorInput, []request.Option)

+ type KinesisAPI_GetShardIterator_OngoingVerification struct

+ func (c *KinesisAPI_GetShardIterator_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.GetShardIteratorInput)

+ func (c *KinesisAPI_GetShardIterator_OngoingVerification) GetCapturedArguments() *kinesis.GetShardIteratorInput

+ type KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification struct

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.IncreaseStreamRetentionPeriodInput)

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification) GetCapturedArguments() *kinesis.IncreaseStreamRetentionPeriodInput

+ type KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification struct

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.IncreaseStreamRetentionPeriodInput, ...)

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.IncreaseStreamRetentionPeriodInput, []request.Option)

+ type KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification struct

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.IncreaseStreamRetentionPeriodInput)

+ func (c *KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification) GetCapturedArguments() *kinesis.IncreaseStreamRetentionPeriodInput

+ type KinesisAPI_ListShardsRequest_OngoingVerification struct

+ func (c *KinesisAPI_ListShardsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListShardsInput)

+ func (c *KinesisAPI_ListShardsRequest_OngoingVerification) GetCapturedArguments() *kinesis.ListShardsInput

+ type KinesisAPI_ListShardsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_ListShardsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.ListShardsInput, ...)

+ func (c *KinesisAPI_ListShardsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.ListShardsInput, []request.Option)

+ type KinesisAPI_ListShards_OngoingVerification struct

+ func (c *KinesisAPI_ListShards_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListShardsInput)

+ func (c *KinesisAPI_ListShards_OngoingVerification) GetCapturedArguments() *kinesis.ListShardsInput

+ type KinesisAPI_ListStreamsPagesWithContext_OngoingVerification struct

+ func (c *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.ListStreamsInput, ...)

+ func (c *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.ListStreamsInput, ...)

+ type KinesisAPI_ListStreamsPages_OngoingVerification struct

+ func (c *KinesisAPI_ListStreamsPages_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListStreamsInput, ...)

+ func (c *KinesisAPI_ListStreamsPages_OngoingVerification) GetCapturedArguments() (*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool)

+ type KinesisAPI_ListStreamsRequest_OngoingVerification struct

+ func (c *KinesisAPI_ListStreamsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListStreamsInput)

+ func (c *KinesisAPI_ListStreamsRequest_OngoingVerification) GetCapturedArguments() *kinesis.ListStreamsInput

+ type KinesisAPI_ListStreamsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_ListStreamsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.ListStreamsInput, ...)

+ func (c *KinesisAPI_ListStreamsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.ListStreamsInput, []request.Option)

+ type KinesisAPI_ListStreams_OngoingVerification struct

+ func (c *KinesisAPI_ListStreams_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListStreamsInput)

+ func (c *KinesisAPI_ListStreams_OngoingVerification) GetCapturedArguments() *kinesis.ListStreamsInput

+ type KinesisAPI_ListTagsForStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_ListTagsForStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListTagsForStreamInput)

+ func (c *KinesisAPI_ListTagsForStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.ListTagsForStreamInput

+ type KinesisAPI_ListTagsForStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_ListTagsForStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.ListTagsForStreamInput, ...)

+ func (c *KinesisAPI_ListTagsForStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.ListTagsForStreamInput, []request.Option)

+ type KinesisAPI_ListTagsForStream_OngoingVerification struct

+ func (c *KinesisAPI_ListTagsForStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListTagsForStreamInput)

+ func (c *KinesisAPI_ListTagsForStream_OngoingVerification) GetCapturedArguments() *kinesis.ListTagsForStreamInput

+ type KinesisAPI_MergeShardsRequest_OngoingVerification struct

+ func (c *KinesisAPI_MergeShardsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.MergeShardsInput)

+ func (c *KinesisAPI_MergeShardsRequest_OngoingVerification) GetCapturedArguments() *kinesis.MergeShardsInput

+ type KinesisAPI_MergeShardsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_MergeShardsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.MergeShardsInput, ...)

+ func (c *KinesisAPI_MergeShardsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.MergeShardsInput, []request.Option)

+ type KinesisAPI_MergeShards_OngoingVerification struct

+ func (c *KinesisAPI_MergeShards_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.MergeShardsInput)

+ func (c *KinesisAPI_MergeShards_OngoingVerification) GetCapturedArguments() *kinesis.MergeShardsInput

+ type KinesisAPI_PutRecordRequest_OngoingVerification struct

+ func (c *KinesisAPI_PutRecordRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.PutRecordInput)

+ func (c *KinesisAPI_PutRecordRequest_OngoingVerification) GetCapturedArguments() *kinesis.PutRecordInput

+ type KinesisAPI_PutRecordWithContext_OngoingVerification struct

+ func (c *KinesisAPI_PutRecordWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.PutRecordInput, ...)

+ func (c *KinesisAPI_PutRecordWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.PutRecordInput, []request.Option)

+ type KinesisAPI_PutRecord_OngoingVerification struct

+ func (c *KinesisAPI_PutRecord_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.PutRecordInput)

+ func (c *KinesisAPI_PutRecord_OngoingVerification) GetCapturedArguments() *kinesis.PutRecordInput

+ type KinesisAPI_PutRecordsRequest_OngoingVerification struct

+ func (c *KinesisAPI_PutRecordsRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.PutRecordsInput)

+ func (c *KinesisAPI_PutRecordsRequest_OngoingVerification) GetCapturedArguments() *kinesis.PutRecordsInput

+ type KinesisAPI_PutRecordsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_PutRecordsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.PutRecordsInput, ...)

+ func (c *KinesisAPI_PutRecordsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.PutRecordsInput, []request.Option)

+ type KinesisAPI_PutRecords_OngoingVerification struct

+ func (c *KinesisAPI_PutRecords_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.PutRecordsInput)

+ func (c *KinesisAPI_PutRecords_OngoingVerification) GetCapturedArguments() *kinesis.PutRecordsInput

+ type KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification struct

+ func (c *KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.RemoveTagsFromStreamInput)

+ func (c *KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification) GetCapturedArguments() *kinesis.RemoveTagsFromStreamInput

+ type KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification struct

+ func (c *KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.RemoveTagsFromStreamInput, ...)

+ func (c *KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.RemoveTagsFromStreamInput, []request.Option)

+ type KinesisAPI_RemoveTagsFromStream_OngoingVerification struct

+ func (c *KinesisAPI_RemoveTagsFromStream_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.RemoveTagsFromStreamInput)

+ func (c *KinesisAPI_RemoveTagsFromStream_OngoingVerification) GetCapturedArguments() *kinesis.RemoveTagsFromStreamInput

+ type KinesisAPI_SplitShardRequest_OngoingVerification struct

+ func (c *KinesisAPI_SplitShardRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.SplitShardInput)

+ func (c *KinesisAPI_SplitShardRequest_OngoingVerification) GetCapturedArguments() *kinesis.SplitShardInput

+ type KinesisAPI_SplitShardWithContext_OngoingVerification struct

+ func (c *KinesisAPI_SplitShardWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.SplitShardInput, ...)

+ func (c *KinesisAPI_SplitShardWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.SplitShardInput, []request.Option)

+ type KinesisAPI_SplitShard_OngoingVerification struct

+ func (c *KinesisAPI_SplitShard_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.SplitShardInput)

+ func (c *KinesisAPI_SplitShard_OngoingVerification) GetCapturedArguments() *kinesis.SplitShardInput

+ type KinesisAPI_StartStreamEncryptionRequest_OngoingVerification struct

+ func (c *KinesisAPI_StartStreamEncryptionRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.StartStreamEncryptionInput)

+ func (c *KinesisAPI_StartStreamEncryptionRequest_OngoingVerification) GetCapturedArguments() *kinesis.StartStreamEncryptionInput

+ type KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification struct

+ func (c *KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.StartStreamEncryptionInput, ...)

+ func (c *KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.StartStreamEncryptionInput, []request.Option)

+ type KinesisAPI_StartStreamEncryption_OngoingVerification struct

+ func (c *KinesisAPI_StartStreamEncryption_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.StartStreamEncryptionInput)

+ func (c *KinesisAPI_StartStreamEncryption_OngoingVerification) GetCapturedArguments() *kinesis.StartStreamEncryptionInput

+ type KinesisAPI_StopStreamEncryptionRequest_OngoingVerification struct

+ func (c *KinesisAPI_StopStreamEncryptionRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.StopStreamEncryptionInput)

+ func (c *KinesisAPI_StopStreamEncryptionRequest_OngoingVerification) GetCapturedArguments() *kinesis.StopStreamEncryptionInput

+ type KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification struct

+ func (c *KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.StopStreamEncryptionInput, ...)

+ func (c *KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.StopStreamEncryptionInput, []request.Option)

+ type KinesisAPI_StopStreamEncryption_OngoingVerification struct

+ func (c *KinesisAPI_StopStreamEncryption_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.StopStreamEncryptionInput)

+ func (c *KinesisAPI_StopStreamEncryption_OngoingVerification) GetCapturedArguments() *kinesis.StopStreamEncryptionInput

+ type KinesisAPI_UpdateShardCountRequest_OngoingVerification struct

+ func (c *KinesisAPI_UpdateShardCountRequest_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.UpdateShardCountInput)

+ func (c *KinesisAPI_UpdateShardCountRequest_OngoingVerification) GetCapturedArguments() *kinesis.UpdateShardCountInput

+ type KinesisAPI_UpdateShardCountWithContext_OngoingVerification struct

+ func (c *KinesisAPI_UpdateShardCountWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.UpdateShardCountInput, ...)

+ func (c *KinesisAPI_UpdateShardCountWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.UpdateShardCountInput, []request.Option)

+ type KinesisAPI_UpdateShardCount_OngoingVerification struct

+ func (c *KinesisAPI_UpdateShardCount_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.UpdateShardCountInput)

+ func (c *KinesisAPI_UpdateShardCount_OngoingVerification) GetCapturedArguments() *kinesis.UpdateShardCountInput

+ type KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamInput, ...)

+ func (c *KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)

+ type KinesisAPI_WaitUntilStreamExists_OngoingVerification struct

+ func (c *KinesisAPI_WaitUntilStreamExists_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput)

+ func (c *KinesisAPI_WaitUntilStreamExists_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamInput

+ type KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification struct

+ func (c *KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamInput, ...)

+ func (c *KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamInput, []request.WaiterOption)

+ type KinesisAPI_WaitUntilStreamNotExists_OngoingVerification struct

+ func (c *KinesisAPI_WaitUntilStreamNotExists_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput)

+ func (c *KinesisAPI_WaitUntilStreamNotExists_OngoingVerification) GetCapturedArguments() *kinesis.DescribeStreamInput

+ type MockKinesisAPI struct

+ func NewMockKinesisAPI() *MockKinesisAPI

+ func (mock *MockKinesisAPI) AddTagsToStream(_param0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)

+ func (mock *MockKinesisAPI) AddTagsToStreamRequest(_param0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)

+ func (mock *MockKinesisAPI) AddTagsToStreamWithContext(_param0 aws.Context, _param1 *kinesis.AddTagsToStreamInput, ...) (*kinesis.AddTagsToStreamOutput, error)

+ func (mock *MockKinesisAPI) CreateStream(_param0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

+ func (mock *MockKinesisAPI) CreateStreamRequest(_param0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)

+ func (mock *MockKinesisAPI) CreateStreamWithContext(_param0 aws.Context, _param1 *kinesis.CreateStreamInput, ...) (*kinesis.CreateStreamOutput, error)

+ func (mock *MockKinesisAPI) DecreaseStreamRetentionPeriod(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

+ func (mock *MockKinesisAPI) DecreaseStreamRetentionPeriodRequest(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)

+ func (mock *MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.DecreaseStreamRetentionPeriodInput, ...) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

+ func (mock *MockKinesisAPI) DeleteStream(_param0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)

+ func (mock *MockKinesisAPI) DeleteStreamRequest(_param0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)

+ func (mock *MockKinesisAPI) DeleteStreamWithContext(_param0 aws.Context, _param1 *kinesis.DeleteStreamInput, ...) (*kinesis.DeleteStreamOutput, error)

+ func (mock *MockKinesisAPI) DescribeLimits(_param0 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)

+ func (mock *MockKinesisAPI) DescribeLimitsRequest(_param0 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)

+ func (mock *MockKinesisAPI) DescribeLimitsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeLimitsInput, ...) (*kinesis.DescribeLimitsOutput, error)

+ func (mock *MockKinesisAPI) DescribeStream(_param0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

+ func (mock *MockKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, ...) error

+ func (mock *MockKinesisAPI) DescribeStreamPagesWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) error

+ func (mock *MockKinesisAPI) DescribeStreamRequest(_param0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)

+ func (mock *MockKinesisAPI) DescribeStreamSummary(_param0 *kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)

+ func (mock *MockKinesisAPI) DescribeStreamSummaryRequest(_param0 *kinesis.DescribeStreamSummaryInput) (*request.Request, *kinesis.DescribeStreamSummaryOutput)

+ func (mock *MockKinesisAPI) DescribeStreamSummaryWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamSummaryInput, ...) (*kinesis.DescribeStreamSummaryOutput, error)

+ func (mock *MockKinesisAPI) DescribeStreamWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) (*kinesis.DescribeStreamOutput, error)

+ func (mock *MockKinesisAPI) DisableEnhancedMonitoring(_param0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

+ func (mock *MockKinesisAPI) DisableEnhancedMonitoringRequest(_param0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

+ func (mock *MockKinesisAPI) DisableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.DisableEnhancedMonitoringInput, ...) (*kinesis.EnhancedMonitoringOutput, error)

+ func (mock *MockKinesisAPI) EnableEnhancedMonitoring(_param0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

+ func (mock *MockKinesisAPI) EnableEnhancedMonitoringRequest(_param0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

+ func (mock *MockKinesisAPI) EnableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.EnableEnhancedMonitoringInput, ...) (*kinesis.EnhancedMonitoringOutput, error)

+ func (mock *MockKinesisAPI) GetRecords(_param0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

+ func (mock *MockKinesisAPI) GetRecordsRequest(_param0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)

+ func (mock *MockKinesisAPI) GetRecordsWithContext(_param0 aws.Context, _param1 *kinesis.GetRecordsInput, ...) (*kinesis.GetRecordsOutput, error)

+ func (mock *MockKinesisAPI) GetShardIterator(_param0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)

+ func (mock *MockKinesisAPI) GetShardIteratorRequest(_param0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)

+ func (mock *MockKinesisAPI) GetShardIteratorWithContext(_param0 aws.Context, _param1 *kinesis.GetShardIteratorInput, ...) (*kinesis.GetShardIteratorOutput, error)

+ func (mock *MockKinesisAPI) IncreaseStreamRetentionPeriod(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

+ func (mock *MockKinesisAPI) IncreaseStreamRetentionPeriodRequest(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)

+ func (mock *MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.IncreaseStreamRetentionPeriodInput, ...) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

+ func (mock *MockKinesisAPI) ListShards(_param0 *kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)

+ func (mock *MockKinesisAPI) ListShardsRequest(_param0 *kinesis.ListShardsInput) (*request.Request, *kinesis.ListShardsOutput)

+ func (mock *MockKinesisAPI) ListShardsWithContext(_param0 aws.Context, _param1 *kinesis.ListShardsInput, ...) (*kinesis.ListShardsOutput, error)

+ func (mock *MockKinesisAPI) ListStreams(_param0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

+ func (mock *MockKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, ...) error

+ func (mock *MockKinesisAPI) ListStreamsPagesWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, ...) error

+ func (mock *MockKinesisAPI) ListStreamsRequest(_param0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)

+ func (mock *MockKinesisAPI) ListStreamsWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, ...) (*kinesis.ListStreamsOutput, error)

+ func (mock *MockKinesisAPI) ListTagsForStream(_param0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)

+ func (mock *MockKinesisAPI) ListTagsForStreamRequest(_param0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)

+ func (mock *MockKinesisAPI) ListTagsForStreamWithContext(_param0 aws.Context, _param1 *kinesis.ListTagsForStreamInput, ...) (*kinesis.ListTagsForStreamOutput, error)

+ func (mock *MockKinesisAPI) MergeShards(_param0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)

+ func (mock *MockKinesisAPI) MergeShardsRequest(_param0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)

+ func (mock *MockKinesisAPI) MergeShardsWithContext(_param0 aws.Context, _param1 *kinesis.MergeShardsInput, ...) (*kinesis.MergeShardsOutput, error)

+ func (mock *MockKinesisAPI) PutRecord(_param0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

+ func (mock *MockKinesisAPI) PutRecordRequest(_param0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)

+ func (mock *MockKinesisAPI) PutRecordWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordInput, ...) (*kinesis.PutRecordOutput, error)

+ func (mock *MockKinesisAPI) PutRecords(_param0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

+ func (mock *MockKinesisAPI) PutRecordsRequest(_param0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)

+ func (mock *MockKinesisAPI) PutRecordsWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordsInput, ...) (*kinesis.PutRecordsOutput, error)

+ func (mock *MockKinesisAPI) RemoveTagsFromStream(_param0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)

+ func (mock *MockKinesisAPI) RemoveTagsFromStreamRequest(_param0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)

+ func (mock *MockKinesisAPI) RemoveTagsFromStreamWithContext(_param0 aws.Context, _param1 *kinesis.RemoveTagsFromStreamInput, ...) (*kinesis.RemoveTagsFromStreamOutput, error)

+ func (mock *MockKinesisAPI) SplitShard(_param0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)

+ func (mock *MockKinesisAPI) SplitShardRequest(_param0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)

+ func (mock *MockKinesisAPI) SplitShardWithContext(_param0 aws.Context, _param1 *kinesis.SplitShardInput, ...) (*kinesis.SplitShardOutput, error)

+ func (mock *MockKinesisAPI) StartStreamEncryption(_param0 *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)

+ func (mock *MockKinesisAPI) StartStreamEncryptionRequest(_param0 *kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)

+ func (mock *MockKinesisAPI) StartStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StartStreamEncryptionInput, ...) (*kinesis.StartStreamEncryptionOutput, error)

+ func (mock *MockKinesisAPI) StopStreamEncryption(_param0 *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)

+ func (mock *MockKinesisAPI) StopStreamEncryptionRequest(_param0 *kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)

+ func (mock *MockKinesisAPI) StopStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StopStreamEncryptionInput, ...) (*kinesis.StopStreamEncryptionOutput, error)

+ func (mock *MockKinesisAPI) UpdateShardCount(_param0 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)

+ func (mock *MockKinesisAPI) UpdateShardCountRequest(_param0 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)

+ func (mock *MockKinesisAPI) UpdateShardCountWithContext(_param0 aws.Context, _param1 *kinesis.UpdateShardCountInput, ...) (*kinesis.UpdateShardCountOutput, error)

+ func (mock *MockKinesisAPI) VerifyWasCalled(invocationCountMatcher pegomock.Matcher) *VerifierKinesisAPI

+ func (mock *MockKinesisAPI) VerifyWasCalledInOrder(invocationCountMatcher pegomock.Matcher, ...) *VerifierKinesisAPI

+ func (mock *MockKinesisAPI) VerifyWasCalledOnce() *VerifierKinesisAPI

+ func (mock *MockKinesisAPI) WaitUntilStreamExists(_param0 *kinesis.DescribeStreamInput) error

+ func (mock *MockKinesisAPI) WaitUntilStreamExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) error

+ func (mock *MockKinesisAPI) WaitUntilStreamNotExists(_param0 *kinesis.DescribeStreamInput) error

+ func (mock *MockKinesisAPI) WaitUntilStreamNotExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) error

+ type VerifierKinesisAPI struct

+ func (verifier *VerifierKinesisAPI) AddTagsToStream(_param0 *kinesis.AddTagsToStreamInput) *KinesisAPI_AddTagsToStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) AddTagsToStreamRequest(_param0 *kinesis.AddTagsToStreamInput) *KinesisAPI_AddTagsToStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) AddTagsToStreamWithContext(_param0 aws.Context, _param1 *kinesis.AddTagsToStreamInput, ...) *KinesisAPI_AddTagsToStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) CreateStream(_param0 *kinesis.CreateStreamInput) *KinesisAPI_CreateStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) CreateStreamRequest(_param0 *kinesis.CreateStreamInput) *KinesisAPI_CreateStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) CreateStreamWithContext(_param0 aws.Context, _param1 *kinesis.CreateStreamInput, ...) *KinesisAPI_CreateStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DecreaseStreamRetentionPeriod(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) *KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DecreaseStreamRetentionPeriodRequest(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) *KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DecreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.DecreaseStreamRetentionPeriodInput, ...) *KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DeleteStream(_param0 *kinesis.DeleteStreamInput) *KinesisAPI_DeleteStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DeleteStreamRequest(_param0 *kinesis.DeleteStreamInput) *KinesisAPI_DeleteStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DeleteStreamWithContext(_param0 aws.Context, _param1 *kinesis.DeleteStreamInput, ...) *KinesisAPI_DeleteStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeLimits(_param0 *kinesis.DescribeLimitsInput) *KinesisAPI_DescribeLimits_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeLimitsRequest(_param0 *kinesis.DescribeLimitsInput) *KinesisAPI_DescribeLimitsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeLimitsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeLimitsInput, ...) *KinesisAPI_DescribeLimitsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStream(_param0 *kinesis.DescribeStreamInput) *KinesisAPI_DescribeStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, ...) *KinesisAPI_DescribeStreamPages_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamPagesWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamRequest(_param0 *kinesis.DescribeStreamInput) *KinesisAPI_DescribeStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamSummary(_param0 *kinesis.DescribeStreamSummaryInput) *KinesisAPI_DescribeStreamSummary_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamSummaryRequest(_param0 *kinesis.DescribeStreamSummaryInput) *KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamSummaryWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamSummaryInput, ...) *KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DescribeStreamWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) *KinesisAPI_DescribeStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DisableEnhancedMonitoring(_param0 *kinesis.DisableEnhancedMonitoringInput) *KinesisAPI_DisableEnhancedMonitoring_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DisableEnhancedMonitoringRequest(_param0 *kinesis.DisableEnhancedMonitoringInput) *KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) DisableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.DisableEnhancedMonitoringInput, ...) *KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) EnableEnhancedMonitoring(_param0 *kinesis.EnableEnhancedMonitoringInput) *KinesisAPI_EnableEnhancedMonitoring_OngoingVerification

+ func (verifier *VerifierKinesisAPI) EnableEnhancedMonitoringRequest(_param0 *kinesis.EnableEnhancedMonitoringInput) *KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) EnableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.EnableEnhancedMonitoringInput, ...) *KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetRecords(_param0 *kinesis.GetRecordsInput) *KinesisAPI_GetRecords_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetRecordsRequest(_param0 *kinesis.GetRecordsInput) *KinesisAPI_GetRecordsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetRecordsWithContext(_param0 aws.Context, _param1 *kinesis.GetRecordsInput, ...) *KinesisAPI_GetRecordsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetShardIterator(_param0 *kinesis.GetShardIteratorInput) *KinesisAPI_GetShardIterator_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetShardIteratorRequest(_param0 *kinesis.GetShardIteratorInput) *KinesisAPI_GetShardIteratorRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) GetShardIteratorWithContext(_param0 aws.Context, _param1 *kinesis.GetShardIteratorInput, ...) *KinesisAPI_GetShardIteratorWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) IncreaseStreamRetentionPeriod(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) *KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification

+ func (verifier *VerifierKinesisAPI) IncreaseStreamRetentionPeriodRequest(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) *KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) IncreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.IncreaseStreamRetentionPeriodInput, ...) *KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListShards(_param0 *kinesis.ListShardsInput) *KinesisAPI_ListShards_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListShardsRequest(_param0 *kinesis.ListShardsInput) *KinesisAPI_ListShardsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListShardsWithContext(_param0 aws.Context, _param1 *kinesis.ListShardsInput, ...) *KinesisAPI_ListShardsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListStreams(_param0 *kinesis.ListStreamsInput) *KinesisAPI_ListStreams_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, ...) *KinesisAPI_ListStreamsPages_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListStreamsPagesWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, ...) *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListStreamsRequest(_param0 *kinesis.ListStreamsInput) *KinesisAPI_ListStreamsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListStreamsWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, ...) *KinesisAPI_ListStreamsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListTagsForStream(_param0 *kinesis.ListTagsForStreamInput) *KinesisAPI_ListTagsForStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListTagsForStreamRequest(_param0 *kinesis.ListTagsForStreamInput) *KinesisAPI_ListTagsForStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) ListTagsForStreamWithContext(_param0 aws.Context, _param1 *kinesis.ListTagsForStreamInput, ...) *KinesisAPI_ListTagsForStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) MergeShards(_param0 *kinesis.MergeShardsInput) *KinesisAPI_MergeShards_OngoingVerification

+ func (verifier *VerifierKinesisAPI) MergeShardsRequest(_param0 *kinesis.MergeShardsInput) *KinesisAPI_MergeShardsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) MergeShardsWithContext(_param0 aws.Context, _param1 *kinesis.MergeShardsInput, ...) *KinesisAPI_MergeShardsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecord(_param0 *kinesis.PutRecordInput) *KinesisAPI_PutRecord_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecordRequest(_param0 *kinesis.PutRecordInput) *KinesisAPI_PutRecordRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecordWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordInput, ...) *KinesisAPI_PutRecordWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecords(_param0 *kinesis.PutRecordsInput) *KinesisAPI_PutRecords_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecordsRequest(_param0 *kinesis.PutRecordsInput) *KinesisAPI_PutRecordsRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) PutRecordsWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordsInput, ...) *KinesisAPI_PutRecordsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) RemoveTagsFromStream(_param0 *kinesis.RemoveTagsFromStreamInput) *KinesisAPI_RemoveTagsFromStream_OngoingVerification

+ func (verifier *VerifierKinesisAPI) RemoveTagsFromStreamRequest(_param0 *kinesis.RemoveTagsFromStreamInput) *KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) RemoveTagsFromStreamWithContext(_param0 aws.Context, _param1 *kinesis.RemoveTagsFromStreamInput, ...) *KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) SplitShard(_param0 *kinesis.SplitShardInput) *KinesisAPI_SplitShard_OngoingVerification

+ func (verifier *VerifierKinesisAPI) SplitShardRequest(_param0 *kinesis.SplitShardInput) *KinesisAPI_SplitShardRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) SplitShardWithContext(_param0 aws.Context, _param1 *kinesis.SplitShardInput, ...) *KinesisAPI_SplitShardWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StartStreamEncryption(_param0 *kinesis.StartStreamEncryptionInput) *KinesisAPI_StartStreamEncryption_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StartStreamEncryptionRequest(_param0 *kinesis.StartStreamEncryptionInput) *KinesisAPI_StartStreamEncryptionRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StartStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StartStreamEncryptionInput, ...) *KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StopStreamEncryption(_param0 *kinesis.StopStreamEncryptionInput) *KinesisAPI_StopStreamEncryption_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StopStreamEncryptionRequest(_param0 *kinesis.StopStreamEncryptionInput) *KinesisAPI_StopStreamEncryptionRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) StopStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StopStreamEncryptionInput, ...) *KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) UpdateShardCount(_param0 *kinesis.UpdateShardCountInput) *KinesisAPI_UpdateShardCount_OngoingVerification

+ func (verifier *VerifierKinesisAPI) UpdateShardCountRequest(_param0 *kinesis.UpdateShardCountInput) *KinesisAPI_UpdateShardCountRequest_OngoingVerification

+ func (verifier *VerifierKinesisAPI) UpdateShardCountWithContext(_param0 aws.Context, _param1 *kinesis.UpdateShardCountInput, ...) *KinesisAPI_UpdateShardCountWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) WaitUntilStreamExists(_param0 *kinesis.DescribeStreamInput) *KinesisAPI_WaitUntilStreamExists_OngoingVerification

+ func (verifier *VerifierKinesisAPI) WaitUntilStreamExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) *KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification

+ func (verifier *VerifierKinesisAPI) WaitUntilStreamNotExists(_param0 *kinesis.DescribeStreamInput) *KinesisAPI_WaitUntilStreamNotExists_OngoingVerification

+ func (verifier *VerifierKinesisAPI) WaitUntilStreamNotExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, ...) *KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification