mock

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KinesisAPI_AddTagsToStreamRequest_OngoingVerification 

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

func (*KinesisAPI_AddTagsToStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_AddTagsToStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_AddTagsToStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_AddTagsToStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_AddTagsToStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_AddTagsToStream_OngoingVerification 

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

func (*KinesisAPI_AddTagsToStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_AddTagsToStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_CreateStreamRequest_OngoingVerification 

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

func (*KinesisAPI_CreateStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_CreateStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_CreateStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_CreateStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_CreateStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_CreateStream_OngoingVerification 

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

func (*KinesisAPI_CreateStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_CreateStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriodRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriodWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DecreaseStreamRetentionPeriod_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DeleteStreamRequest_OngoingVerification 

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

func (*KinesisAPI_DeleteStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DeleteStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DeleteStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_DeleteStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DeleteStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DeleteStream_OngoingVerification 

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

func (*KinesisAPI_DeleteStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DeleteStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeLimitsRequest_OngoingVerification 

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

func (*KinesisAPI_DescribeLimitsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeLimitsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeLimitsWithContext_OngoingVerification 

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

func (*KinesisAPI_DescribeLimitsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeLimitsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeLimits_OngoingVerification 

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

func (*KinesisAPI_DescribeLimits_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeLimits_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetAllCapturedArguments 

func (c *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.DescribeStreamInput, _param2 []func(*kinesis.DescribeStreamOutput, bool) bool, _param3 [][]request.Option)

func (*KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetCapturedArguments 

func (c *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool, []request.Option)

type KinesisAPI_DescribeStreamPages_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamPages_OngoingVerification) GetAllCapturedArguments 

func (c *KinesisAPI_DescribeStreamPages_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.DescribeStreamInput, _param1 []func(*kinesis.DescribeStreamOutput, bool) bool)

func (*KinesisAPI_DescribeStreamPages_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamRequest_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStreamSummaryRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStreamSummaryWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamSummary_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamSummary_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStreamSummary_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_DescribeStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DescribeStream_OngoingVerification 

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

func (*KinesisAPI_DescribeStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DescribeStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification 

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

func (*KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DisableEnhancedMonitoringRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification 

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

func (*KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DisableEnhancedMonitoringWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_DisableEnhancedMonitoring_OngoingVerification 

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

func (*KinesisAPI_DisableEnhancedMonitoring_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_DisableEnhancedMonitoring_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification 

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

func (*KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_EnableEnhancedMonitoringRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification 

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

func (*KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_EnableEnhancedMonitoringWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_EnableEnhancedMonitoring_OngoingVerification 

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

func (*KinesisAPI_EnableEnhancedMonitoring_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_EnableEnhancedMonitoring_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetRecordsRequest_OngoingVerification 

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

func (*KinesisAPI_GetRecordsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetRecordsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetRecordsWithContext_OngoingVerification 

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

func (*KinesisAPI_GetRecordsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetRecordsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetRecords_OngoingVerification 

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

func (*KinesisAPI_GetRecords_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetRecords_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetShardIteratorRequest_OngoingVerification 

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

func (*KinesisAPI_GetShardIteratorRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetShardIteratorRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetShardIteratorWithContext_OngoingVerification 

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

func (*KinesisAPI_GetShardIteratorWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetShardIteratorWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_GetShardIterator_OngoingVerification 

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

func (*KinesisAPI_GetShardIterator_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_GetShardIterator_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriodRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriodWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_IncreaseStreamRetentionPeriod_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListShardsRequest_OngoingVerification 

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

func (*KinesisAPI_ListShardsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListShardsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListShardsWithContext_OngoingVerification 

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

func (*KinesisAPI_ListShardsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListShardsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListShards_OngoingVerification 

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

func (*KinesisAPI_ListShards_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListShards_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListStreamsPagesWithContext_OngoingVerification 

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

func (*KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetAllCapturedArguments 

func (c *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetAllCapturedArguments() (_param0 []aws.Context, _param1 []*kinesis.ListStreamsInput, _param2 []func(*kinesis.ListStreamsOutput, bool) bool, _param3 [][]request.Option)

func (*KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetCapturedArguments 

func (c *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification) GetCapturedArguments() (aws.Context, *kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool, []request.Option)

type KinesisAPI_ListStreamsPages_OngoingVerification 

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

func (*KinesisAPI_ListStreamsPages_OngoingVerification) GetAllCapturedArguments 

func (c *KinesisAPI_ListStreamsPages_OngoingVerification) GetAllCapturedArguments() (_param0 []*kinesis.ListStreamsInput, _param1 []func(*kinesis.ListStreamsOutput, bool) bool)

func (*KinesisAPI_ListStreamsPages_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListStreamsRequest_OngoingVerification 

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

func (*KinesisAPI_ListStreamsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListStreamsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListStreamsWithContext_OngoingVerification 

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

func (*KinesisAPI_ListStreamsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListStreamsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListStreams_OngoingVerification 

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

func (*KinesisAPI_ListStreams_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListStreams_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListTagsForStreamRequest_OngoingVerification 

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

func (*KinesisAPI_ListTagsForStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListTagsForStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListTagsForStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_ListTagsForStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListTagsForStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_ListTagsForStream_OngoingVerification 

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

func (*KinesisAPI_ListTagsForStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_ListTagsForStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_MergeShardsRequest_OngoingVerification 

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

func (*KinesisAPI_MergeShardsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_MergeShardsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_MergeShardsWithContext_OngoingVerification 

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

func (*KinesisAPI_MergeShardsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_MergeShardsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_MergeShards_OngoingVerification 

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

func (*KinesisAPI_MergeShards_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_MergeShards_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecordRequest_OngoingVerification 

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

func (*KinesisAPI_PutRecordRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecordRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecordWithContext_OngoingVerification 

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

func (*KinesisAPI_PutRecordWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecordWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecord_OngoingVerification 

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

func (*KinesisAPI_PutRecord_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecord_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecordsRequest_OngoingVerification 

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

func (*KinesisAPI_PutRecordsRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecordsRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecordsWithContext_OngoingVerification 

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

func (*KinesisAPI_PutRecordsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecordsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_PutRecords_OngoingVerification 

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

func (*KinesisAPI_PutRecords_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_PutRecords_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification 

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

func (*KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_RemoveTagsFromStreamRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification 

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

func (*KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_RemoveTagsFromStreamWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_RemoveTagsFromStream_OngoingVerification 

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

func (*KinesisAPI_RemoveTagsFromStream_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_RemoveTagsFromStream_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_SplitShardRequest_OngoingVerification 

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

func (*KinesisAPI_SplitShardRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_SplitShardRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_SplitShardWithContext_OngoingVerification 

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

func (*KinesisAPI_SplitShardWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_SplitShardWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_SplitShard_OngoingVerification 

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

func (*KinesisAPI_SplitShard_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_SplitShard_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StartStreamEncryptionRequest_OngoingVerification 

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

func (*KinesisAPI_StartStreamEncryptionRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StartStreamEncryptionRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification 

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

func (*KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StartStreamEncryptionWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StartStreamEncryption_OngoingVerification 

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

func (*KinesisAPI_StartStreamEncryption_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StartStreamEncryption_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StopStreamEncryptionRequest_OngoingVerification 

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

func (*KinesisAPI_StopStreamEncryptionRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StopStreamEncryptionRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification 

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

func (*KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StopStreamEncryptionWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_StopStreamEncryption_OngoingVerification 

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

func (*KinesisAPI_StopStreamEncryption_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_StopStreamEncryption_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_UpdateShardCountRequest_OngoingVerification 

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

func (*KinesisAPI_UpdateShardCountRequest_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_UpdateShardCountRequest_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_UpdateShardCountWithContext_OngoingVerification 

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

func (*KinesisAPI_UpdateShardCountWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_UpdateShardCountWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_UpdateShardCount_OngoingVerification 

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

func (*KinesisAPI_UpdateShardCount_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_UpdateShardCount_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification 

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

func (*KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_WaitUntilStreamExistsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_WaitUntilStreamExists_OngoingVerification 

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

func (*KinesisAPI_WaitUntilStreamExists_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_WaitUntilStreamExists_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification 

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

func (*KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_WaitUntilStreamNotExistsWithContext_OngoingVerification) GetCapturedArguments 

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

type KinesisAPI_WaitUntilStreamNotExists_OngoingVerification 

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

func (*KinesisAPI_WaitUntilStreamNotExists_OngoingVerification) GetAllCapturedArguments 

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

func (*KinesisAPI_WaitUntilStreamNotExists_OngoingVerification) GetCapturedArguments 

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

type MockKinesisAPI 

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

func NewMockKinesisAPI 

func NewMockKinesisAPI() *MockKinesisAPI

func (*MockKinesisAPI) AddTagsToStream 

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

func (*MockKinesisAPI) AddTagsToStreamRequest 

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

func (*MockKinesisAPI) AddTagsToStreamWithContext 

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

func (*MockKinesisAPI) CreateStream 

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

func (*MockKinesisAPI) CreateStreamRequest 

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

func (*MockKinesisAPI) CreateStreamWithContext 

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

func (*MockKinesisAPI) DecreaseStreamRetentionPeriod 

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

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodRequest 

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

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext 

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

func (*MockKinesisAPI) DeleteStream 

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

func (*MockKinesisAPI) DeleteStreamRequest 

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

func (*MockKinesisAPI) DeleteStreamWithContext 

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

func (*MockKinesisAPI) DescribeLimits 

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

func (*MockKinesisAPI) DescribeLimitsRequest 

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

func (*MockKinesisAPI) DescribeLimitsWithContext 

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

func (*MockKinesisAPI) DescribeStream 

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

func (*MockKinesisAPI) DescribeStreamPages 

func (mock *MockKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, _param1 func(*kinesis.DescribeStreamOutput, bool) bool) error

func (*MockKinesisAPI) DescribeStreamPagesWithContext 

func (mock *MockKinesisAPI) DescribeStreamPagesWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 func(*kinesis.DescribeStreamOutput, bool) bool, _param3 ...request.Option) error

func (*MockKinesisAPI) DescribeStreamRequest 

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

func (*MockKinesisAPI) DescribeStreamSummary 

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

func (*MockKinesisAPI) DescribeStreamSummaryRequest 

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

func (*MockKinesisAPI) DescribeStreamSummaryWithContext 

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

func (*MockKinesisAPI) DescribeStreamWithContext 

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

func (*MockKinesisAPI) DisableEnhancedMonitoring 

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

func (*MockKinesisAPI) DisableEnhancedMonitoringRequest 

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

func (*MockKinesisAPI) DisableEnhancedMonitoringWithContext 

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

func (*MockKinesisAPI) EnableEnhancedMonitoring 

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

func (*MockKinesisAPI) EnableEnhancedMonitoringRequest 

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

func (*MockKinesisAPI) EnableEnhancedMonitoringWithContext 

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

func (*MockKinesisAPI) GetRecords 

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

func (*MockKinesisAPI) GetRecordsRequest 

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

func (*MockKinesisAPI) GetRecordsWithContext 

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

func (*MockKinesisAPI) GetShardIterator 

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

func (*MockKinesisAPI) GetShardIteratorRequest 

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

func (*MockKinesisAPI) GetShardIteratorWithContext 

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

func (*MockKinesisAPI) IncreaseStreamRetentionPeriod 

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

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodRequest 

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

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext 

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

func (*MockKinesisAPI) ListShards 

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

func (*MockKinesisAPI) ListShardsRequest 

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

func (*MockKinesisAPI) ListShardsWithContext 

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

func (*MockKinesisAPI) ListStreams 

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

func (*MockKinesisAPI) ListStreamsPages 

func (mock *MockKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, _param1 func(*kinesis.ListStreamsOutput, bool) bool) error

func (*MockKinesisAPI) ListStreamsPagesWithContext 

func (mock *MockKinesisAPI) ListStreamsPagesWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, _param2 func(*kinesis.ListStreamsOutput, bool) bool, _param3 ...request.Option) error

func (*MockKinesisAPI) ListStreamsRequest 

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

func (*MockKinesisAPI) ListStreamsWithContext 

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

func (*MockKinesisAPI) ListTagsForStream 

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

func (*MockKinesisAPI) ListTagsForStreamRequest 

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

func (*MockKinesisAPI) ListTagsForStreamWithContext 

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

func (*MockKinesisAPI) MergeShards 

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

func (*MockKinesisAPI) MergeShardsRequest 

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

func (*MockKinesisAPI) MergeShardsWithContext 

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

func (*MockKinesisAPI) PutRecord 

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

func (*MockKinesisAPI) PutRecordRequest 

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

func (*MockKinesisAPI) PutRecordWithContext 

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

func (*MockKinesisAPI) PutRecords 

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

func (*MockKinesisAPI) PutRecordsRequest 

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

func (*MockKinesisAPI) PutRecordsWithContext 

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

func (*MockKinesisAPI) RemoveTagsFromStream 

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

func (*MockKinesisAPI) RemoveTagsFromStreamRequest 

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

func (*MockKinesisAPI) RemoveTagsFromStreamWithContext 

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

func (*MockKinesisAPI) SplitShard 

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

func (*MockKinesisAPI) SplitShardRequest 

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

func (*MockKinesisAPI) SplitShardWithContext 

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

func (*MockKinesisAPI) StartStreamEncryption 

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

func (*MockKinesisAPI) StartStreamEncryptionRequest 

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

func (*MockKinesisAPI) StartStreamEncryptionWithContext 

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

func (*MockKinesisAPI) StopStreamEncryption 

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

func (*MockKinesisAPI) StopStreamEncryptionRequest 

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

func (*MockKinesisAPI) StopStreamEncryptionWithContext 

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

func (*MockKinesisAPI) UpdateShardCount 

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

func (*MockKinesisAPI) UpdateShardCountRequest 

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

func (*MockKinesisAPI) UpdateShardCountWithContext 

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

func (*MockKinesisAPI) VerifyWasCalled 

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

func (*MockKinesisAPI) VerifyWasCalledInOrder 

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

func (*MockKinesisAPI) VerifyWasCalledOnce 

func (mock *MockKinesisAPI) VerifyWasCalledOnce() *VerifierKinesisAPI

func (*MockKinesisAPI) WaitUntilStreamExists 

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

func (*MockKinesisAPI) WaitUntilStreamExistsWithContext 

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

func (*MockKinesisAPI) WaitUntilStreamNotExists 

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

func (*MockKinesisAPI) WaitUntilStreamNotExistsWithContext 

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

type VerifierKinesisAPI 

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

func (*VerifierKinesisAPI) AddTagsToStream 

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

func (*VerifierKinesisAPI) AddTagsToStreamRequest 

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

func (*VerifierKinesisAPI) AddTagsToStreamWithContext 

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

func (*VerifierKinesisAPI) CreateStream 

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

func (*VerifierKinesisAPI) CreateStreamRequest 

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

func (*VerifierKinesisAPI) CreateStreamWithContext 

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

func (*VerifierKinesisAPI) DecreaseStreamRetentionPeriod 

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

func (*VerifierKinesisAPI) DecreaseStreamRetentionPeriodRequest 

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

func (*VerifierKinesisAPI) DecreaseStreamRetentionPeriodWithContext 

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

func (*VerifierKinesisAPI) DeleteStream 

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

func (*VerifierKinesisAPI) DeleteStreamRequest 

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

func (*VerifierKinesisAPI) DeleteStreamWithContext 

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

func (*VerifierKinesisAPI) DescribeLimits 

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

func (*VerifierKinesisAPI) DescribeLimitsRequest 

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

func (*VerifierKinesisAPI) DescribeLimitsWithContext 

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

func (*VerifierKinesisAPI) DescribeStream 

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

func (*VerifierKinesisAPI) DescribeStreamPages 

func (verifier *VerifierKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, _param1 func(*kinesis.DescribeStreamOutput, bool) bool) *KinesisAPI_DescribeStreamPages_OngoingVerification

func (*VerifierKinesisAPI) DescribeStreamPagesWithContext 

func (verifier *VerifierKinesisAPI) DescribeStreamPagesWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 func(*kinesis.DescribeStreamOutput, bool) bool, _param3 ...request.Option) *KinesisAPI_DescribeStreamPagesWithContext_OngoingVerification

func (*VerifierKinesisAPI) DescribeStreamRequest 

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

func (*VerifierKinesisAPI) DescribeStreamSummary 

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

func (*VerifierKinesisAPI) DescribeStreamSummaryRequest 

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

func (*VerifierKinesisAPI) DescribeStreamSummaryWithContext 

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

func (*VerifierKinesisAPI) DescribeStreamWithContext 

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

func (*VerifierKinesisAPI) DisableEnhancedMonitoring 

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

func (*VerifierKinesisAPI) DisableEnhancedMonitoringRequest 

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

func (*VerifierKinesisAPI) DisableEnhancedMonitoringWithContext 

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

func (*VerifierKinesisAPI) EnableEnhancedMonitoring 

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

func (*VerifierKinesisAPI) EnableEnhancedMonitoringRequest 

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

func (*VerifierKinesisAPI) EnableEnhancedMonitoringWithContext 

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

func (*VerifierKinesisAPI) GetRecords 

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

func (*VerifierKinesisAPI) GetRecordsRequest 

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

func (*VerifierKinesisAPI) GetRecordsWithContext 

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

func (*VerifierKinesisAPI) GetShardIterator 

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

func (*VerifierKinesisAPI) GetShardIteratorRequest 

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

func (*VerifierKinesisAPI) GetShardIteratorWithContext 

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

func (*VerifierKinesisAPI) IncreaseStreamRetentionPeriod 

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

func (*VerifierKinesisAPI) IncreaseStreamRetentionPeriodRequest 

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

func (*VerifierKinesisAPI) IncreaseStreamRetentionPeriodWithContext 

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

func (*VerifierKinesisAPI) ListShards 

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

func (*VerifierKinesisAPI) ListShardsRequest 

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

func (*VerifierKinesisAPI) ListShardsWithContext 

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

func (*VerifierKinesisAPI) ListStreams 

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

func (*VerifierKinesisAPI) ListStreamsPages 

func (verifier *VerifierKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, _param1 func(*kinesis.ListStreamsOutput, bool) bool) *KinesisAPI_ListStreamsPages_OngoingVerification

func (*VerifierKinesisAPI) ListStreamsPagesWithContext 

func (verifier *VerifierKinesisAPI) ListStreamsPagesWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, _param2 func(*kinesis.ListStreamsOutput, bool) bool, _param3 ...request.Option) *KinesisAPI_ListStreamsPagesWithContext_OngoingVerification

func (*VerifierKinesisAPI) ListStreamsRequest 

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

func (*VerifierKinesisAPI) ListStreamsWithContext 

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

func (*VerifierKinesisAPI) ListTagsForStream 

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

func (*VerifierKinesisAPI) ListTagsForStreamRequest 

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

func (*VerifierKinesisAPI) ListTagsForStreamWithContext 

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

func (*VerifierKinesisAPI) MergeShards 

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

func (*VerifierKinesisAPI) MergeShardsRequest 

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

func (*VerifierKinesisAPI) MergeShardsWithContext 

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

func (*VerifierKinesisAPI) PutRecord 

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

func (*VerifierKinesisAPI) PutRecordRequest 

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

func (*VerifierKinesisAPI) PutRecordWithContext 

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

func (*VerifierKinesisAPI) PutRecords 

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

func (*VerifierKinesisAPI) PutRecordsRequest 

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

func (*VerifierKinesisAPI) PutRecordsWithContext 

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

func (*VerifierKinesisAPI) RemoveTagsFromStream 

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

func (*VerifierKinesisAPI) RemoveTagsFromStreamRequest 

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

func (*VerifierKinesisAPI) RemoveTagsFromStreamWithContext 

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

func (*VerifierKinesisAPI) SplitShard 

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

func (*VerifierKinesisAPI) SplitShardRequest 

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

func (*VerifierKinesisAPI) SplitShardWithContext 

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

func (*VerifierKinesisAPI) StartStreamEncryption 

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

func (*VerifierKinesisAPI) StartStreamEncryptionRequest 

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

func (*VerifierKinesisAPI) StartStreamEncryptionWithContext 

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

func (*VerifierKinesisAPI) StopStreamEncryption 

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

func (*VerifierKinesisAPI) StopStreamEncryptionRequest 

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

func (*VerifierKinesisAPI) StopStreamEncryptionWithContext 

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

func (*VerifierKinesisAPI) UpdateShardCount 

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

func (*VerifierKinesisAPI) UpdateShardCountRequest 

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

func (*VerifierKinesisAPI) UpdateShardCountWithContext 

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

func (*VerifierKinesisAPI) WaitUntilStreamExists 

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

func (*VerifierKinesisAPI) WaitUntilStreamExistsWithContext 

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

func (*VerifierKinesisAPI) WaitUntilStreamNotExists 

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

func (*VerifierKinesisAPI) WaitUntilStreamNotExistsWithContext 

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

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.