kinesisdouble

package
v0.0.0-...-8548fdf Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00 For SDKVersion 1.28.13 Package kinesisdouble contains test double implementation of kinesisiface.KinesisAPI

Package kinesisdouble provides a TestDouble implementation of kinesisiface.KinesisAPI

Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00

Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KinesisDouble 

type KinesisDouble struct {
	kinesisiface.KinesisAPI
	*awsdouble.AWSTestDouble
}

KinesisDouble is TestDouble for kinesisiface.KinesisAPI

func NewDouble 

func NewDouble(t godouble.T, configurators ...func(*awsdouble.AWSTestDouble)) *KinesisDouble

Constructor for KinesisDouble Default configuration will ensure

  • API operations not explicitly stubbed will return an empty output struct pointer, and nil error. To simulate long polling, "Poll" operations will return these values after a random delay of up to 100ms.

  • WithContext methods implement a 'Fake' method that returns a cancellation error if the context is cancelled before the method is called.

  • Pages and PagesWithContext methods similarly implement a 'Fake' method that paginates over the underlying method.

    This allows tests to only stub the simple api methods and be generally unconcerned whether the SUT is using the Context or Pagination forms of the API.

func (*KinesisDouble) AddTagsToStream 

func (d *KinesisDouble) AddTagsToStream(i0 *kinesis.AddTagsToStreamInput) (r0 *kinesis.AddTagsToStreamOutput, r1 error)

func (*KinesisDouble) AddTagsToStreamRequest 

func (d *KinesisDouble) AddTagsToStreamRequest(i0 *kinesis.AddTagsToStreamInput) (r0 *request.Request, r1 *kinesis.AddTagsToStreamOutput)

func (*KinesisDouble) AddTagsToStreamWithContext 

func (d *KinesisDouble) AddTagsToStreamWithContext(i0 context.Context, i1 *kinesis.AddTagsToStreamInput, i2 ...request.Option) (r0 *kinesis.AddTagsToStreamOutput, r1 error)

func (*KinesisDouble) CreateStream 

func (d *KinesisDouble) CreateStream(i0 *kinesis.CreateStreamInput) (r0 *kinesis.CreateStreamOutput, r1 error)

func (*KinesisDouble) CreateStreamRequest 

func (d *KinesisDouble) CreateStreamRequest(i0 *kinesis.CreateStreamInput) (r0 *request.Request, r1 *kinesis.CreateStreamOutput)

func (*KinesisDouble) CreateStreamWithContext 

func (d *KinesisDouble) CreateStreamWithContext(i0 context.Context, i1 *kinesis.CreateStreamInput, i2 ...request.Option) (r0 *kinesis.CreateStreamOutput, r1 error)

func (*KinesisDouble) DecreaseStreamRetentionPeriod 

func (d *KinesisDouble) DecreaseStreamRetentionPeriod(i0 *kinesis.DecreaseStreamRetentionPeriodInput) (r0 *kinesis.DecreaseStreamRetentionPeriodOutput, r1 error)

func (*KinesisDouble) DecreaseStreamRetentionPeriodRequest 

func (d *KinesisDouble) DecreaseStreamRetentionPeriodRequest(i0 *kinesis.DecreaseStreamRetentionPeriodInput) (r0 *request.Request, r1 *kinesis.DecreaseStreamRetentionPeriodOutput)

func (*KinesisDouble) DecreaseStreamRetentionPeriodWithContext 

func (d *KinesisDouble) DecreaseStreamRetentionPeriodWithContext(i0 context.Context, i1 *kinesis.DecreaseStreamRetentionPeriodInput, i2 ...request.Option) (r0 *kinesis.DecreaseStreamRetentionPeriodOutput, r1 error)

func (*KinesisDouble) DeleteStream 

func (d *KinesisDouble) DeleteStream(i0 *kinesis.DeleteStreamInput) (r0 *kinesis.DeleteStreamOutput, r1 error)

func (*KinesisDouble) DeleteStreamRequest 

func (d *KinesisDouble) DeleteStreamRequest(i0 *kinesis.DeleteStreamInput) (r0 *request.Request, r1 *kinesis.DeleteStreamOutput)

func (*KinesisDouble) DeleteStreamWithContext 

func (d *KinesisDouble) DeleteStreamWithContext(i0 context.Context, i1 *kinesis.DeleteStreamInput, i2 ...request.Option) (r0 *kinesis.DeleteStreamOutput, r1 error)

func (*KinesisDouble) DeregisterStreamConsumer 

func (d *KinesisDouble) DeregisterStreamConsumer(i0 *kinesis.DeregisterStreamConsumerInput) (r0 *kinesis.DeregisterStreamConsumerOutput, r1 error)

func (*KinesisDouble) DeregisterStreamConsumerRequest 

func (d *KinesisDouble) DeregisterStreamConsumerRequest(i0 *kinesis.DeregisterStreamConsumerInput) (r0 *request.Request, r1 *kinesis.DeregisterStreamConsumerOutput)

func (*KinesisDouble) DeregisterStreamConsumerWithContext 

func (d *KinesisDouble) DeregisterStreamConsumerWithContext(i0 context.Context, i1 *kinesis.DeregisterStreamConsumerInput, i2 ...request.Option) (r0 *kinesis.DeregisterStreamConsumerOutput, r1 error)

func (*KinesisDouble) DescribeLimits 

func (d *KinesisDouble) DescribeLimits(i0 *kinesis.DescribeLimitsInput) (r0 *kinesis.DescribeLimitsOutput, r1 error)

func (*KinesisDouble) DescribeLimitsRequest 

func (d *KinesisDouble) DescribeLimitsRequest(i0 *kinesis.DescribeLimitsInput) (r0 *request.Request, r1 *kinesis.DescribeLimitsOutput)

func (*KinesisDouble) DescribeLimitsWithContext 

func (d *KinesisDouble) DescribeLimitsWithContext(i0 context.Context, i1 *kinesis.DescribeLimitsInput, i2 ...request.Option) (r0 *kinesis.DescribeLimitsOutput, r1 error)

func (*KinesisDouble) DescribeStream 

func (d *KinesisDouble) DescribeStream(i0 *kinesis.DescribeStreamInput) (r0 *kinesis.DescribeStreamOutput, r1 error)

func (*KinesisDouble) DescribeStreamConsumer 

func (d *KinesisDouble) DescribeStreamConsumer(i0 *kinesis.DescribeStreamConsumerInput) (r0 *kinesis.DescribeStreamConsumerOutput, r1 error)

func (*KinesisDouble) DescribeStreamConsumerRequest 

func (d *KinesisDouble) DescribeStreamConsumerRequest(i0 *kinesis.DescribeStreamConsumerInput) (r0 *request.Request, r1 *kinesis.DescribeStreamConsumerOutput)

func (*KinesisDouble) DescribeStreamConsumerWithContext 

func (d *KinesisDouble) DescribeStreamConsumerWithContext(i0 context.Context, i1 *kinesis.DescribeStreamConsumerInput, i2 ...request.Option) (r0 *kinesis.DescribeStreamConsumerOutput, r1 error)

func (*KinesisDouble) DescribeStreamPages 

func (d *KinesisDouble) DescribeStreamPages(i0 *kinesis.DescribeStreamInput, i1 func(*kinesis.DescribeStreamOutput, bool) bool) (r0 error)

func (*KinesisDouble) DescribeStreamPagesWithContext 

func (d *KinesisDouble) DescribeStreamPagesWithContext(i0 context.Context, i1 *kinesis.DescribeStreamInput, i2 func(*kinesis.DescribeStreamOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KinesisDouble) DescribeStreamRequest 

func (d *KinesisDouble) DescribeStreamRequest(i0 *kinesis.DescribeStreamInput) (r0 *request.Request, r1 *kinesis.DescribeStreamOutput)

func (*KinesisDouble) DescribeStreamSummary 

func (d *KinesisDouble) DescribeStreamSummary(i0 *kinesis.DescribeStreamSummaryInput) (r0 *kinesis.DescribeStreamSummaryOutput, r1 error)

func (*KinesisDouble) DescribeStreamSummaryRequest 

func (d *KinesisDouble) DescribeStreamSummaryRequest(i0 *kinesis.DescribeStreamSummaryInput) (r0 *request.Request, r1 *kinesis.DescribeStreamSummaryOutput)

func (*KinesisDouble) DescribeStreamSummaryWithContext 

func (d *KinesisDouble) DescribeStreamSummaryWithContext(i0 context.Context, i1 *kinesis.DescribeStreamSummaryInput, i2 ...request.Option) (r0 *kinesis.DescribeStreamSummaryOutput, r1 error)

func (*KinesisDouble) DescribeStreamWithContext 

func (d *KinesisDouble) DescribeStreamWithContext(i0 context.Context, i1 *kinesis.DescribeStreamInput, i2 ...request.Option) (r0 *kinesis.DescribeStreamOutput, r1 error)

func (*KinesisDouble) DisableEnhancedMonitoring 

func (d *KinesisDouble) DisableEnhancedMonitoring(i0 *kinesis.DisableEnhancedMonitoringInput) (r0 *kinesis.EnhancedMonitoringOutput, r1 error)

func (*KinesisDouble) DisableEnhancedMonitoringRequest 

func (d *KinesisDouble) DisableEnhancedMonitoringRequest(i0 *kinesis.DisableEnhancedMonitoringInput) (r0 *request.Request, r1 *kinesis.EnhancedMonitoringOutput)

func (*KinesisDouble) DisableEnhancedMonitoringWithContext 

func (d *KinesisDouble) DisableEnhancedMonitoringWithContext(i0 context.Context, i1 *kinesis.DisableEnhancedMonitoringInput, i2 ...request.Option) (r0 *kinesis.EnhancedMonitoringOutput, r1 error)

func (*KinesisDouble) EnableEnhancedMonitoring 

func (d *KinesisDouble) EnableEnhancedMonitoring(i0 *kinesis.EnableEnhancedMonitoringInput) (r0 *kinesis.EnhancedMonitoringOutput, r1 error)

func (*KinesisDouble) EnableEnhancedMonitoringRequest 

func (d *KinesisDouble) EnableEnhancedMonitoringRequest(i0 *kinesis.EnableEnhancedMonitoringInput) (r0 *request.Request, r1 *kinesis.EnhancedMonitoringOutput)

func (*KinesisDouble) EnableEnhancedMonitoringWithContext 

func (d *KinesisDouble) EnableEnhancedMonitoringWithContext(i0 context.Context, i1 *kinesis.EnableEnhancedMonitoringInput, i2 ...request.Option) (r0 *kinesis.EnhancedMonitoringOutput, r1 error)

func (*KinesisDouble) GetRecords 

func (d *KinesisDouble) GetRecords(i0 *kinesis.GetRecordsInput) (r0 *kinesis.GetRecordsOutput, r1 error)

func (*KinesisDouble) GetRecordsRequest 

func (d *KinesisDouble) GetRecordsRequest(i0 *kinesis.GetRecordsInput) (r0 *request.Request, r1 *kinesis.GetRecordsOutput)

func (*KinesisDouble) GetRecordsWithContext 

func (d *KinesisDouble) GetRecordsWithContext(i0 context.Context, i1 *kinesis.GetRecordsInput, i2 ...request.Option) (r0 *kinesis.GetRecordsOutput, r1 error)

func (*KinesisDouble) GetShardIterator 

func (d *KinesisDouble) GetShardIterator(i0 *kinesis.GetShardIteratorInput) (r0 *kinesis.GetShardIteratorOutput, r1 error)

func (*KinesisDouble) GetShardIteratorRequest 

func (d *KinesisDouble) GetShardIteratorRequest(i0 *kinesis.GetShardIteratorInput) (r0 *request.Request, r1 *kinesis.GetShardIteratorOutput)

func (*KinesisDouble) GetShardIteratorWithContext 

func (d *KinesisDouble) GetShardIteratorWithContext(i0 context.Context, i1 *kinesis.GetShardIteratorInput, i2 ...request.Option) (r0 *kinesis.GetShardIteratorOutput, r1 error)

func (*KinesisDouble) IncreaseStreamRetentionPeriod 

func (d *KinesisDouble) IncreaseStreamRetentionPeriod(i0 *kinesis.IncreaseStreamRetentionPeriodInput) (r0 *kinesis.IncreaseStreamRetentionPeriodOutput, r1 error)

func (*KinesisDouble) IncreaseStreamRetentionPeriodRequest 

func (d *KinesisDouble) IncreaseStreamRetentionPeriodRequest(i0 *kinesis.IncreaseStreamRetentionPeriodInput) (r0 *request.Request, r1 *kinesis.IncreaseStreamRetentionPeriodOutput)

func (*KinesisDouble) IncreaseStreamRetentionPeriodWithContext 

func (d *KinesisDouble) IncreaseStreamRetentionPeriodWithContext(i0 context.Context, i1 *kinesis.IncreaseStreamRetentionPeriodInput, i2 ...request.Option) (r0 *kinesis.IncreaseStreamRetentionPeriodOutput, r1 error)

func (*KinesisDouble) ListShards 

func (d *KinesisDouble) ListShards(i0 *kinesis.ListShardsInput) (r0 *kinesis.ListShardsOutput, r1 error)

func (*KinesisDouble) ListShardsRequest 

func (d *KinesisDouble) ListShardsRequest(i0 *kinesis.ListShardsInput) (r0 *request.Request, r1 *kinesis.ListShardsOutput)

func (*KinesisDouble) ListShardsWithContext 

func (d *KinesisDouble) ListShardsWithContext(i0 context.Context, i1 *kinesis.ListShardsInput, i2 ...request.Option) (r0 *kinesis.ListShardsOutput, r1 error)

func (*KinesisDouble) ListStreamConsumers 

func (d *KinesisDouble) ListStreamConsumers(i0 *kinesis.ListStreamConsumersInput) (r0 *kinesis.ListStreamConsumersOutput, r1 error)

func (*KinesisDouble) ListStreamConsumersPages 

func (d *KinesisDouble) ListStreamConsumersPages(i0 *kinesis.ListStreamConsumersInput, i1 func(*kinesis.ListStreamConsumersOutput, bool) bool) (r0 error)

func (*KinesisDouble) ListStreamConsumersPagesWithContext 

func (d *KinesisDouble) ListStreamConsumersPagesWithContext(i0 context.Context, i1 *kinesis.ListStreamConsumersInput, i2 func(*kinesis.ListStreamConsumersOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KinesisDouble) ListStreamConsumersRequest 

func (d *KinesisDouble) ListStreamConsumersRequest(i0 *kinesis.ListStreamConsumersInput) (r0 *request.Request, r1 *kinesis.ListStreamConsumersOutput)

func (*KinesisDouble) ListStreamConsumersWithContext 

func (d *KinesisDouble) ListStreamConsumersWithContext(i0 context.Context, i1 *kinesis.ListStreamConsumersInput, i2 ...request.Option) (r0 *kinesis.ListStreamConsumersOutput, r1 error)

func (*KinesisDouble) ListStreams 

func (d *KinesisDouble) ListStreams(i0 *kinesis.ListStreamsInput) (r0 *kinesis.ListStreamsOutput, r1 error)

func (*KinesisDouble) ListStreamsPages 

func (d *KinesisDouble) ListStreamsPages(i0 *kinesis.ListStreamsInput, i1 func(*kinesis.ListStreamsOutput, bool) bool) (r0 error)

func (*KinesisDouble) ListStreamsPagesWithContext 

func (d *KinesisDouble) ListStreamsPagesWithContext(i0 context.Context, i1 *kinesis.ListStreamsInput, i2 func(*kinesis.ListStreamsOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KinesisDouble) ListStreamsRequest 

func (d *KinesisDouble) ListStreamsRequest(i0 *kinesis.ListStreamsInput) (r0 *request.Request, r1 *kinesis.ListStreamsOutput)

func (*KinesisDouble) ListStreamsWithContext 

func (d *KinesisDouble) ListStreamsWithContext(i0 context.Context, i1 *kinesis.ListStreamsInput, i2 ...request.Option) (r0 *kinesis.ListStreamsOutput, r1 error)

func (*KinesisDouble) ListTagsForStream 

func (d *KinesisDouble) ListTagsForStream(i0 *kinesis.ListTagsForStreamInput) (r0 *kinesis.ListTagsForStreamOutput, r1 error)

func (*KinesisDouble) ListTagsForStreamRequest 

func (d *KinesisDouble) ListTagsForStreamRequest(i0 *kinesis.ListTagsForStreamInput) (r0 *request.Request, r1 *kinesis.ListTagsForStreamOutput)

func (*KinesisDouble) ListTagsForStreamWithContext 

func (d *KinesisDouble) ListTagsForStreamWithContext(i0 context.Context, i1 *kinesis.ListTagsForStreamInput, i2 ...request.Option) (r0 *kinesis.ListTagsForStreamOutput, r1 error)

func (*KinesisDouble) MergeShards 

func (d *KinesisDouble) MergeShards(i0 *kinesis.MergeShardsInput) (r0 *kinesis.MergeShardsOutput, r1 error)

func (*KinesisDouble) MergeShardsRequest 

func (d *KinesisDouble) MergeShardsRequest(i0 *kinesis.MergeShardsInput) (r0 *request.Request, r1 *kinesis.MergeShardsOutput)

func (*KinesisDouble) MergeShardsWithContext 

func (d *KinesisDouble) MergeShardsWithContext(i0 context.Context, i1 *kinesis.MergeShardsInput, i2 ...request.Option) (r0 *kinesis.MergeShardsOutput, r1 error)

func (*KinesisDouble) PutRecord 

func (d *KinesisDouble) PutRecord(i0 *kinesis.PutRecordInput) (r0 *kinesis.PutRecordOutput, r1 error)

func (*KinesisDouble) PutRecordRequest 

func (d *KinesisDouble) PutRecordRequest(i0 *kinesis.PutRecordInput) (r0 *request.Request, r1 *kinesis.PutRecordOutput)

func (*KinesisDouble) PutRecordWithContext 

func (d *KinesisDouble) PutRecordWithContext(i0 context.Context, i1 *kinesis.PutRecordInput, i2 ...request.Option) (r0 *kinesis.PutRecordOutput, r1 error)

func (*KinesisDouble) PutRecords 

func (d *KinesisDouble) PutRecords(i0 *kinesis.PutRecordsInput) (r0 *kinesis.PutRecordsOutput, r1 error)

func (*KinesisDouble) PutRecordsRequest 

func (d *KinesisDouble) PutRecordsRequest(i0 *kinesis.PutRecordsInput) (r0 *request.Request, r1 *kinesis.PutRecordsOutput)

func (*KinesisDouble) PutRecordsWithContext 

func (d *KinesisDouble) PutRecordsWithContext(i0 context.Context, i1 *kinesis.PutRecordsInput, i2 ...request.Option) (r0 *kinesis.PutRecordsOutput, r1 error)

func (*KinesisDouble) RegisterStreamConsumer 

func (d *KinesisDouble) RegisterStreamConsumer(i0 *kinesis.RegisterStreamConsumerInput) (r0 *kinesis.RegisterStreamConsumerOutput, r1 error)

func (*KinesisDouble) RegisterStreamConsumerRequest 

func (d *KinesisDouble) RegisterStreamConsumerRequest(i0 *kinesis.RegisterStreamConsumerInput) (r0 *request.Request, r1 *kinesis.RegisterStreamConsumerOutput)

func (*KinesisDouble) RegisterStreamConsumerWithContext 

func (d *KinesisDouble) RegisterStreamConsumerWithContext(i0 context.Context, i1 *kinesis.RegisterStreamConsumerInput, i2 ...request.Option) (r0 *kinesis.RegisterStreamConsumerOutput, r1 error)

func (*KinesisDouble) RemoveTagsFromStream 

func (d *KinesisDouble) RemoveTagsFromStream(i0 *kinesis.RemoveTagsFromStreamInput) (r0 *kinesis.RemoveTagsFromStreamOutput, r1 error)

func (*KinesisDouble) RemoveTagsFromStreamRequest 

func (d *KinesisDouble) RemoveTagsFromStreamRequest(i0 *kinesis.RemoveTagsFromStreamInput) (r0 *request.Request, r1 *kinesis.RemoveTagsFromStreamOutput)

func (*KinesisDouble) RemoveTagsFromStreamWithContext 

func (d *KinesisDouble) RemoveTagsFromStreamWithContext(i0 context.Context, i1 *kinesis.RemoveTagsFromStreamInput, i2 ...request.Option) (r0 *kinesis.RemoveTagsFromStreamOutput, r1 error)

func (*KinesisDouble) SplitShard 

func (d *KinesisDouble) SplitShard(i0 *kinesis.SplitShardInput) (r0 *kinesis.SplitShardOutput, r1 error)

func (*KinesisDouble) SplitShardRequest 

func (d *KinesisDouble) SplitShardRequest(i0 *kinesis.SplitShardInput) (r0 *request.Request, r1 *kinesis.SplitShardOutput)

func (*KinesisDouble) SplitShardWithContext 

func (d *KinesisDouble) SplitShardWithContext(i0 context.Context, i1 *kinesis.SplitShardInput, i2 ...request.Option) (r0 *kinesis.SplitShardOutput, r1 error)

func (*KinesisDouble) StartStreamEncryption 

func (d *KinesisDouble) StartStreamEncryption(i0 *kinesis.StartStreamEncryptionInput) (r0 *kinesis.StartStreamEncryptionOutput, r1 error)

func (*KinesisDouble) StartStreamEncryptionRequest 

func (d *KinesisDouble) StartStreamEncryptionRequest(i0 *kinesis.StartStreamEncryptionInput) (r0 *request.Request, r1 *kinesis.StartStreamEncryptionOutput)

func (*KinesisDouble) StartStreamEncryptionWithContext 

func (d *KinesisDouble) StartStreamEncryptionWithContext(i0 context.Context, i1 *kinesis.StartStreamEncryptionInput, i2 ...request.Option) (r0 *kinesis.StartStreamEncryptionOutput, r1 error)

func (*KinesisDouble) StopStreamEncryption 

func (d *KinesisDouble) StopStreamEncryption(i0 *kinesis.StopStreamEncryptionInput) (r0 *kinesis.StopStreamEncryptionOutput, r1 error)

func (*KinesisDouble) StopStreamEncryptionRequest 

func (d *KinesisDouble) StopStreamEncryptionRequest(i0 *kinesis.StopStreamEncryptionInput) (r0 *request.Request, r1 *kinesis.StopStreamEncryptionOutput)

func (*KinesisDouble) StopStreamEncryptionWithContext 

func (d *KinesisDouble) StopStreamEncryptionWithContext(i0 context.Context, i1 *kinesis.StopStreamEncryptionInput, i2 ...request.Option) (r0 *kinesis.StopStreamEncryptionOutput, r1 error)

func (*KinesisDouble) SubscribeToShard 

func (d *KinesisDouble) SubscribeToShard(i0 *kinesis.SubscribeToShardInput) (r0 *kinesis.SubscribeToShardOutput, r1 error)

func (*KinesisDouble) SubscribeToShardRequest 

func (d *KinesisDouble) SubscribeToShardRequest(i0 *kinesis.SubscribeToShardInput) (r0 *request.Request, r1 *kinesis.SubscribeToShardOutput)

func (*KinesisDouble) SubscribeToShardWithContext 

func (d *KinesisDouble) SubscribeToShardWithContext(i0 context.Context, i1 *kinesis.SubscribeToShardInput, i2 ...request.Option) (r0 *kinesis.SubscribeToShardOutput, r1 error)

func (*KinesisDouble) UpdateShardCount 

func (d *KinesisDouble) UpdateShardCount(i0 *kinesis.UpdateShardCountInput) (r0 *kinesis.UpdateShardCountOutput, r1 error)

func (*KinesisDouble) UpdateShardCountRequest 

func (d *KinesisDouble) UpdateShardCountRequest(i0 *kinesis.UpdateShardCountInput) (r0 *request.Request, r1 *kinesis.UpdateShardCountOutput)

func (*KinesisDouble) UpdateShardCountWithContext 

func (d *KinesisDouble) UpdateShardCountWithContext(i0 context.Context, i1 *kinesis.UpdateShardCountInput, i2 ...request.Option) (r0 *kinesis.UpdateShardCountOutput, r1 error)

func (*KinesisDouble) WaitUntilStreamExists 

func (d *KinesisDouble) WaitUntilStreamExists(i0 *kinesis.DescribeStreamInput) (r0 error)

func (*KinesisDouble) WaitUntilStreamExistsWithContext 

func (d *KinesisDouble) WaitUntilStreamExistsWithContext(i0 context.Context, i1 *kinesis.DescribeStreamInput, i2 ...request.WaiterOption) (r0 error)

func (*KinesisDouble) WaitUntilStreamNotExists 

func (d *KinesisDouble) WaitUntilStreamNotExists(i0 *kinesis.DescribeStreamInput) (r0 error)

func (*KinesisDouble) WaitUntilStreamNotExistsWithContext 

func (d *KinesisDouble) WaitUntilStreamNotExistsWithContext(i0 context.Context, i1 *kinesis.DescribeStreamInput, i2 ...request.WaiterOption) (r0 error)

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.