kinesisiface

package

Go to main page

Versions in this module

v1

v1.13.9

Mar 6, 2018

Changes in this version

type KinesisAPI

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

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

+ DescribeStreamSummaryWithContext func(aws.Context, *kinesis.DescribeStreamSummaryInput, ...request.Option) (*kinesis.DescribeStreamSummaryOutput, error)

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

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

+ ListShardsWithContext func(aws.Context, *kinesis.ListShardsInput, ...request.Option) (*kinesis.ListShardsOutput, error)

v1.10.18

Jul 27, 2017

Changes in this version

type KinesisAPI

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

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

+ StartStreamEncryptionWithContext func(aws.Context, *kinesis.StartStreamEncryptionInput, ...request.Option) (*kinesis.StartStreamEncryptionOutput, error)

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

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

+ StopStreamEncryptionWithContext func(aws.Context, *kinesis.StopStreamEncryptionInput, ...request.Option) (*kinesis.StopStreamEncryptionOutput, error)

v1.9.0

Jun 19, 2017

Changes in this version

type KinesisAPI

+ AddTagsToStreamWithContext func(aws.Context, *kinesis.AddTagsToStreamInput, ...request.Option) (*kinesis.AddTagsToStreamOutput, error)

+ CreateStreamWithContext func(aws.Context, *kinesis.CreateStreamInput, ...request.Option) (*kinesis.CreateStreamOutput, error)

+ DecreaseStreamRetentionPeriodWithContext func(aws.Context, *kinesis.DecreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

+ DeleteStreamWithContext func(aws.Context, *kinesis.DeleteStreamInput, ...request.Option) (*kinesis.DeleteStreamOutput, error)

+ DescribeLimitsWithContext func(aws.Context, *kinesis.DescribeLimitsInput, ...request.Option) (*kinesis.DescribeLimitsOutput, error)

+ DescribeStreamPagesWithContext func(aws.Context, *kinesis.DescribeStreamInput, ...) error

+ DescribeStreamWithContext func(aws.Context, *kinesis.DescribeStreamInput, ...request.Option) (*kinesis.DescribeStreamOutput, error)

+ DisableEnhancedMonitoringWithContext func(aws.Context, *kinesis.DisableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

+ EnableEnhancedMonitoringWithContext func(aws.Context, *kinesis.EnableEnhancedMonitoringInput, ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

+ GetRecordsWithContext func(aws.Context, *kinesis.GetRecordsInput, ...request.Option) (*kinesis.GetRecordsOutput, error)

+ GetShardIteratorWithContext func(aws.Context, *kinesis.GetShardIteratorInput, ...request.Option) (*kinesis.GetShardIteratorOutput, error)

+ IncreaseStreamRetentionPeriodWithContext func(aws.Context, *kinesis.IncreaseStreamRetentionPeriodInput, ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

+ ListStreamsPagesWithContext func(aws.Context, *kinesis.ListStreamsInput, ...) error

+ ListStreamsWithContext func(aws.Context, *kinesis.ListStreamsInput, ...request.Option) (*kinesis.ListStreamsOutput, error)

+ ListTagsForStreamWithContext func(aws.Context, *kinesis.ListTagsForStreamInput, ...request.Option) (*kinesis.ListTagsForStreamOutput, error)

+ MergeShardsWithContext func(aws.Context, *kinesis.MergeShardsInput, ...request.Option) (*kinesis.MergeShardsOutput, error)

+ PutRecordWithContext func(aws.Context, *kinesis.PutRecordInput, ...request.Option) (*kinesis.PutRecordOutput, error)

+ PutRecordsWithContext func(aws.Context, *kinesis.PutRecordsInput, ...request.Option) (*kinesis.PutRecordsOutput, error)

+ RemoveTagsFromStreamWithContext func(aws.Context, *kinesis.RemoveTagsFromStreamInput, ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error)

+ SplitShardWithContext func(aws.Context, *kinesis.SplitShardInput, ...request.Option) (*kinesis.SplitShardOutput, error)

+ UpdateShardCountWithContext func(aws.Context, *kinesis.UpdateShardCountInput, ...request.Option) (*kinesis.UpdateShardCountOutput, error)

+ WaitUntilStreamExistsWithContext func(aws.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error

+ WaitUntilStreamNotExists func(*kinesis.DescribeStreamInput) error

+ WaitUntilStreamNotExistsWithContext func(aws.Context, *kinesis.DescribeStreamInput, ...request.WaiterOption) error

v1.6.20

Feb 10, 2017

v1.6.16

Jan 24, 2017

Changes in this version

type KinesisAPI

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

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

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

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

+ WaitUntilStreamExists func(*kinesis.DescribeStreamInput) error

v1.3.0

Aug 2, 2016

Changes in this version

type KinesisAPI

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

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

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

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

v1.0.8

Jan 12, 2016

v1.0.2

Nov 24, 2015

Changes in this version

+ type KinesisAPI interface

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

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

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

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

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

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

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

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

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

+ DescribeStreamPages func(*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool) error

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

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

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

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

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

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

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

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

+ ListStreamsPages func(*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool) error

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

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

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

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

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

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

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

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

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

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

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

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL