kinesis

package

Go to main page

Versions in this module

v1

v1.13.54

May 22, 2018

v1.13.9

Mar 6, 2018

Changes in this version

+ const ErrCodeExpiredNextTokenException

type Kinesis

+ func (c *Kinesis) ListShards(input *ListShardsInput) (*ListShardsOutput, error)

+ func (c *Kinesis) ListShardsRequest(input *ListShardsInput) (req *request.Request, output *ListShardsOutput)

+ func (c *Kinesis) ListShardsWithContext(ctx aws.Context, input *ListShardsInput, opts ...request.Option) (*ListShardsOutput, error)

+ type ListShardsInput struct

+ ExclusiveStartShardId *string

+ MaxResults *int64

+ NextToken *string

+ StreamCreationTimestamp *time.Time

+ StreamName *string

+ func (s *ListShardsInput) SetExclusiveStartShardId(v string) *ListShardsInput

+ func (s *ListShardsInput) SetMaxResults(v int64) *ListShardsInput

+ func (s *ListShardsInput) SetNextToken(v string) *ListShardsInput

+ func (s *ListShardsInput) SetStreamCreationTimestamp(v time.Time) *ListShardsInput

+ func (s *ListShardsInput) SetStreamName(v string) *ListShardsInput

+ func (s *ListShardsInput) Validate() error

+ func (s ListShardsInput) GoString() string

+ func (s ListShardsInput) String() string

+ type ListShardsOutput struct

+ NextToken *string

+ Shards []*Shard

+ func (s *ListShardsOutput) SetNextToken(v string) *ListShardsOutput

+ func (s *ListShardsOutput) SetShards(v []*Shard) *ListShardsOutput

+ func (s ListShardsOutput) GoString() string

+ func (s ListShardsOutput) String() string

v1.12.67

Jan 22, 2018

Changes in this version

+ type DescribeStreamSummaryInput struct

+ StreamName *string

+ func (s *DescribeStreamSummaryInput) SetStreamName(v string) *DescribeStreamSummaryInput

+ func (s *DescribeStreamSummaryInput) Validate() error

+ func (s DescribeStreamSummaryInput) GoString() string

+ func (s DescribeStreamSummaryInput) String() string

+ type DescribeStreamSummaryOutput struct

+ StreamDescriptionSummary *StreamDescriptionSummary

+ func (s *DescribeStreamSummaryOutput) SetStreamDescriptionSummary(v *StreamDescriptionSummary) *DescribeStreamSummaryOutput

+ func (s DescribeStreamSummaryOutput) GoString() string

+ func (s DescribeStreamSummaryOutput) String() string

type Kinesis

+ func (c *Kinesis) DescribeStreamSummary(input *DescribeStreamSummaryInput) (*DescribeStreamSummaryOutput, error)

+ func (c *Kinesis) DescribeStreamSummaryRequest(input *DescribeStreamSummaryInput) (req *request.Request, output *DescribeStreamSummaryOutput)

+ func (c *Kinesis) DescribeStreamSummaryWithContext(ctx aws.Context, input *DescribeStreamSummaryInput, opts ...request.Option) (*DescribeStreamSummaryOutput, error)

+ type StreamDescriptionSummary struct

+ EncryptionType *string

+ EnhancedMonitoring []*EnhancedMetrics

+ KeyId *string

+ OpenShardCount *int64

+ RetentionPeriodHours *int64

+ StreamARN *string

+ StreamCreationTimestamp *time.Time

+ StreamName *string

+ StreamStatus *string

+ func (s *StreamDescriptionSummary) SetEncryptionType(v string) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetEnhancedMonitoring(v []*EnhancedMetrics) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetKeyId(v string) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetOpenShardCount(v int64) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetRetentionPeriodHours(v int64) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetStreamARN(v string) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetStreamCreationTimestamp(v time.Time) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetStreamName(v string) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetStreamStatus(v string) *StreamDescriptionSummary

+ func (s StreamDescriptionSummary) GoString() string

+ func (s StreamDescriptionSummary) String() string

v1.10.51

Sep 22, 2017

v1.10.18

Jul 27, 2017

Changes in this version

+ const EncryptionTypeKms

+ const EncryptionTypeNone

+ const ErrCodeKMSAccessDeniedException

+ const ErrCodeKMSDisabledException

+ const ErrCodeKMSInvalidStateException

+ const ErrCodeKMSNotFoundException

+ const ErrCodeKMSOptInRequired

+ const ErrCodeKMSThrottlingException

type Kinesis

+ func (c *Kinesis) StartStreamEncryption(input *StartStreamEncryptionInput) (*StartStreamEncryptionOutput, error)

+ func (c *Kinesis) StartStreamEncryptionRequest(input *StartStreamEncryptionInput) (req *request.Request, output *StartStreamEncryptionOutput)

+ func (c *Kinesis) StartStreamEncryptionWithContext(ctx aws.Context, input *StartStreamEncryptionInput, opts ...request.Option) (*StartStreamEncryptionOutput, error)

+ func (c *Kinesis) StopStreamEncryption(input *StopStreamEncryptionInput) (*StopStreamEncryptionOutput, error)

+ func (c *Kinesis) StopStreamEncryptionRequest(input *StopStreamEncryptionInput) (req *request.Request, output *StopStreamEncryptionOutput)

+ func (c *Kinesis) StopStreamEncryptionWithContext(ctx aws.Context, input *StopStreamEncryptionInput, opts ...request.Option) (*StopStreamEncryptionOutput, error)

type PutRecordOutput

+ EncryptionType *string

+ func (s *PutRecordOutput) SetEncryptionType(v string) *PutRecordOutput

type PutRecordsOutput

+ EncryptionType *string

+ func (s *PutRecordsOutput) SetEncryptionType(v string) *PutRecordsOutput

type Record

+ EncryptionType *string

+ func (s *Record) SetEncryptionType(v string) *Record

+ type StartStreamEncryptionInput struct

+ EncryptionType *string

+ KeyId *string

+ StreamName *string

+ func (s *StartStreamEncryptionInput) SetEncryptionType(v string) *StartStreamEncryptionInput

+ func (s *StartStreamEncryptionInput) SetKeyId(v string) *StartStreamEncryptionInput

+ func (s *StartStreamEncryptionInput) SetStreamName(v string) *StartStreamEncryptionInput

+ func (s *StartStreamEncryptionInput) Validate() error

+ func (s StartStreamEncryptionInput) GoString() string

+ func (s StartStreamEncryptionInput) String() string

+ type StartStreamEncryptionOutput struct

+ func (s StartStreamEncryptionOutput) GoString() string

+ func (s StartStreamEncryptionOutput) String() string

+ type StopStreamEncryptionInput struct

+ EncryptionType *string

+ KeyId *string

+ StreamName *string

+ func (s *StopStreamEncryptionInput) SetEncryptionType(v string) *StopStreamEncryptionInput

+ func (s *StopStreamEncryptionInput) SetKeyId(v string) *StopStreamEncryptionInput

+ func (s *StopStreamEncryptionInput) SetStreamName(v string) *StopStreamEncryptionInput

+ func (s *StopStreamEncryptionInput) Validate() error

+ func (s StopStreamEncryptionInput) GoString() string

+ func (s StopStreamEncryptionInput) String() string

+ type StopStreamEncryptionOutput struct

+ func (s StopStreamEncryptionOutput) GoString() string

+ func (s StopStreamEncryptionOutput) String() string

type StreamDescription

+ EncryptionType *string

+ KeyId *string

+ func (s *StreamDescription) SetEncryptionType(v string) *StreamDescription

+ func (s *StreamDescription) SetKeyId(v string) *StreamDescription

v1.9.0

Jun 19, 2017

Changes in this version

type Kinesis

+ func (c *Kinesis) AddTagsToStreamWithContext(ctx aws.Context, input *AddTagsToStreamInput, opts ...request.Option) (*AddTagsToStreamOutput, error)

+ func (c *Kinesis) CreateStreamWithContext(ctx aws.Context, input *CreateStreamInput, opts ...request.Option) (*CreateStreamOutput, error)

+ func (c *Kinesis) DecreaseStreamRetentionPeriodWithContext(ctx aws.Context, input *DecreaseStreamRetentionPeriodInput, ...) (*DecreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) DeleteStreamWithContext(ctx aws.Context, input *DeleteStreamInput, opts ...request.Option) (*DeleteStreamOutput, error)

+ func (c *Kinesis) DescribeLimitsWithContext(ctx aws.Context, input *DescribeLimitsInput, opts ...request.Option) (*DescribeLimitsOutput, error)

+ func (c *Kinesis) DescribeStreamPagesWithContext(ctx aws.Context, input *DescribeStreamInput, ...) error

+ func (c *Kinesis) DescribeStreamWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.Option) (*DescribeStreamOutput, error)

+ func (c *Kinesis) DisableEnhancedMonitoringWithContext(ctx aws.Context, input *DisableEnhancedMonitoringInput, opts ...request.Option) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) EnableEnhancedMonitoringWithContext(ctx aws.Context, input *EnableEnhancedMonitoringInput, opts ...request.Option) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) GetRecordsWithContext(ctx aws.Context, input *GetRecordsInput, opts ...request.Option) (*GetRecordsOutput, error)

+ func (c *Kinesis) GetShardIteratorWithContext(ctx aws.Context, input *GetShardIteratorInput, opts ...request.Option) (*GetShardIteratorOutput, error)

+ func (c *Kinesis) IncreaseStreamRetentionPeriodWithContext(ctx aws.Context, input *IncreaseStreamRetentionPeriodInput, ...) (*IncreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) ListStreamsPagesWithContext(ctx aws.Context, input *ListStreamsInput, ...) error

+ func (c *Kinesis) ListStreamsWithContext(ctx aws.Context, input *ListStreamsInput, opts ...request.Option) (*ListStreamsOutput, error)

+ func (c *Kinesis) ListTagsForStreamWithContext(ctx aws.Context, input *ListTagsForStreamInput, opts ...request.Option) (*ListTagsForStreamOutput, error)

+ func (c *Kinesis) MergeShardsWithContext(ctx aws.Context, input *MergeShardsInput, opts ...request.Option) (*MergeShardsOutput, error)

+ func (c *Kinesis) PutRecordWithContext(ctx aws.Context, input *PutRecordInput, opts ...request.Option) (*PutRecordOutput, error)

+ func (c *Kinesis) PutRecordsWithContext(ctx aws.Context, input *PutRecordsInput, opts ...request.Option) (*PutRecordsOutput, error)

+ func (c *Kinesis) RemoveTagsFromStreamWithContext(ctx aws.Context, input *RemoveTagsFromStreamInput, opts ...request.Option) (*RemoveTagsFromStreamOutput, error)

+ func (c *Kinesis) SplitShardWithContext(ctx aws.Context, input *SplitShardInput, opts ...request.Option) (*SplitShardOutput, error)

+ func (c *Kinesis) UpdateShardCountWithContext(ctx aws.Context, input *UpdateShardCountInput, opts ...request.Option) (*UpdateShardCountOutput, error)

+ func (c *Kinesis) WaitUntilStreamExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.WaiterOption) error

+ func (c *Kinesis) WaitUntilStreamNotExists(input *DescribeStreamInput) error

+ func (c *Kinesis) WaitUntilStreamNotExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.WaiterOption) error

v1.7.0

Feb 23, 2017

v1.6.20

Feb 10, 2017

Changes in this version

+ const ErrCodeExpiredIteratorException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeLimitExceededException

+ const ErrCodeProvisionedThroughputExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

v1.6.16

Jan 24, 2017

Changes in this version

+ const EndpointsID

+ const ScalingTypeUniformScaling

type AddTagsToStreamInput

+ func (s *AddTagsToStreamInput) SetStreamName(v string) *AddTagsToStreamInput

+ func (s *AddTagsToStreamInput) SetTags(v map[string]*string) *AddTagsToStreamInput

type CreateStreamInput

+ func (s *CreateStreamInput) SetShardCount(v int64) *CreateStreamInput

+ func (s *CreateStreamInput) SetStreamName(v string) *CreateStreamInput

type DecreaseStreamRetentionPeriodInput

+ func (s *DecreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *DecreaseStreamRetentionPeriodInput

+ func (s *DecreaseStreamRetentionPeriodInput) SetStreamName(v string) *DecreaseStreamRetentionPeriodInput

type DeleteStreamInput

+ func (s *DeleteStreamInput) SetStreamName(v string) *DeleteStreamInput

+ type DescribeLimitsInput struct

+ func (s DescribeLimitsInput) GoString() string

+ func (s DescribeLimitsInput) String() string

+ type DescribeLimitsOutput struct

+ OpenShardCount *int64

+ ShardLimit *int64

+ func (s *DescribeLimitsOutput) SetOpenShardCount(v int64) *DescribeLimitsOutput

+ func (s *DescribeLimitsOutput) SetShardLimit(v int64) *DescribeLimitsOutput

+ func (s DescribeLimitsOutput) GoString() string

+ func (s DescribeLimitsOutput) String() string

type DescribeStreamInput

+ func (s *DescribeStreamInput) SetExclusiveStartShardId(v string) *DescribeStreamInput

+ func (s *DescribeStreamInput) SetLimit(v int64) *DescribeStreamInput

+ func (s *DescribeStreamInput) SetStreamName(v string) *DescribeStreamInput

type DescribeStreamOutput

+ func (s *DescribeStreamOutput) SetStreamDescription(v *StreamDescription) *DescribeStreamOutput

type DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) SetShardLevelMetrics(v []*string) *DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) SetStreamName(v string) *DisableEnhancedMonitoringInput

type EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) SetShardLevelMetrics(v []*string) *EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) SetStreamName(v string) *EnableEnhancedMonitoringInput

type EnhancedMetrics

+ func (s *EnhancedMetrics) SetShardLevelMetrics(v []*string) *EnhancedMetrics

type EnhancedMonitoringOutput

+ func (s *EnhancedMonitoringOutput) SetCurrentShardLevelMetrics(v []*string) *EnhancedMonitoringOutput

+ func (s *EnhancedMonitoringOutput) SetDesiredShardLevelMetrics(v []*string) *EnhancedMonitoringOutput

+ func (s *EnhancedMonitoringOutput) SetStreamName(v string) *EnhancedMonitoringOutput

type GetRecordsInput

+ func (s *GetRecordsInput) SetLimit(v int64) *GetRecordsInput

+ func (s *GetRecordsInput) SetShardIterator(v string) *GetRecordsInput

type GetRecordsOutput

+ func (s *GetRecordsOutput) SetMillisBehindLatest(v int64) *GetRecordsOutput

+ func (s *GetRecordsOutput) SetNextShardIterator(v string) *GetRecordsOutput

+ func (s *GetRecordsOutput) SetRecords(v []*Record) *GetRecordsOutput

type GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetShardId(v string) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetShardIteratorType(v string) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetStartingSequenceNumber(v string) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetStreamName(v string) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetTimestamp(v time.Time) *GetShardIteratorInput

type GetShardIteratorOutput

+ func (s *GetShardIteratorOutput) SetShardIterator(v string) *GetShardIteratorOutput

type HashKeyRange

+ func (s *HashKeyRange) SetEndingHashKey(v string) *HashKeyRange

+ func (s *HashKeyRange) SetStartingHashKey(v string) *HashKeyRange

type IncreaseStreamRetentionPeriodInput

+ func (s *IncreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *IncreaseStreamRetentionPeriodInput

+ func (s *IncreaseStreamRetentionPeriodInput) SetStreamName(v string) *IncreaseStreamRetentionPeriodInput

type Kinesis

+ func (c *Kinesis) DescribeLimits(input *DescribeLimitsInput) (*DescribeLimitsOutput, error)

+ func (c *Kinesis) DescribeLimitsRequest(input *DescribeLimitsInput) (req *request.Request, output *DescribeLimitsOutput)

+ func (c *Kinesis) UpdateShardCount(input *UpdateShardCountInput) (*UpdateShardCountOutput, error)

+ func (c *Kinesis) UpdateShardCountRequest(input *UpdateShardCountInput) (req *request.Request, output *UpdateShardCountOutput)

type ListStreamsInput

+ func (s *ListStreamsInput) SetExclusiveStartStreamName(v string) *ListStreamsInput

+ func (s *ListStreamsInput) SetLimit(v int64) *ListStreamsInput

type ListStreamsOutput

+ func (s *ListStreamsOutput) SetHasMoreStreams(v bool) *ListStreamsOutput

+ func (s *ListStreamsOutput) SetStreamNames(v []*string) *ListStreamsOutput

type ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) SetExclusiveStartTagKey(v string) *ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) SetLimit(v int64) *ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) SetStreamName(v string) *ListTagsForStreamInput

type ListTagsForStreamOutput

+ func (s *ListTagsForStreamOutput) SetHasMoreTags(v bool) *ListTagsForStreamOutput

+ func (s *ListTagsForStreamOutput) SetTags(v []*Tag) *ListTagsForStreamOutput

type MergeShardsInput

+ func (s *MergeShardsInput) SetAdjacentShardToMerge(v string) *MergeShardsInput

+ func (s *MergeShardsInput) SetShardToMerge(v string) *MergeShardsInput

+ func (s *MergeShardsInput) SetStreamName(v string) *MergeShardsInput

type PutRecordInput

+ func (s *PutRecordInput) SetData(v []byte) *PutRecordInput

+ func (s *PutRecordInput) SetExplicitHashKey(v string) *PutRecordInput

+ func (s *PutRecordInput) SetPartitionKey(v string) *PutRecordInput

+ func (s *PutRecordInput) SetSequenceNumberForOrdering(v string) *PutRecordInput

+ func (s *PutRecordInput) SetStreamName(v string) *PutRecordInput

type PutRecordOutput

+ func (s *PutRecordOutput) SetSequenceNumber(v string) *PutRecordOutput

+ func (s *PutRecordOutput) SetShardId(v string) *PutRecordOutput

type PutRecordsInput

+ func (s *PutRecordsInput) SetRecords(v []*PutRecordsRequestEntry) *PutRecordsInput

+ func (s *PutRecordsInput) SetStreamName(v string) *PutRecordsInput

type PutRecordsOutput

+ func (s *PutRecordsOutput) SetFailedRecordCount(v int64) *PutRecordsOutput

+ func (s *PutRecordsOutput) SetRecords(v []*PutRecordsResultEntry) *PutRecordsOutput

type PutRecordsRequestEntry

+ func (s *PutRecordsRequestEntry) SetData(v []byte) *PutRecordsRequestEntry

+ func (s *PutRecordsRequestEntry) SetExplicitHashKey(v string) *PutRecordsRequestEntry

+ func (s *PutRecordsRequestEntry) SetPartitionKey(v string) *PutRecordsRequestEntry

type PutRecordsResultEntry

+ func (s *PutRecordsResultEntry) SetErrorCode(v string) *PutRecordsResultEntry

+ func (s *PutRecordsResultEntry) SetErrorMessage(v string) *PutRecordsResultEntry

+ func (s *PutRecordsResultEntry) SetSequenceNumber(v string) *PutRecordsResultEntry

+ func (s *PutRecordsResultEntry) SetShardId(v string) *PutRecordsResultEntry

type Record

+ func (s *Record) SetApproximateArrivalTimestamp(v time.Time) *Record

+ func (s *Record) SetData(v []byte) *Record

+ func (s *Record) SetPartitionKey(v string) *Record

+ func (s *Record) SetSequenceNumber(v string) *Record

type RemoveTagsFromStreamInput

+ func (s *RemoveTagsFromStreamInput) SetStreamName(v string) *RemoveTagsFromStreamInput

+ func (s *RemoveTagsFromStreamInput) SetTagKeys(v []*string) *RemoveTagsFromStreamInput

type SequenceNumberRange

+ func (s *SequenceNumberRange) SetEndingSequenceNumber(v string) *SequenceNumberRange

+ func (s *SequenceNumberRange) SetStartingSequenceNumber(v string) *SequenceNumberRange

type Shard

+ func (s *Shard) SetAdjacentParentShardId(v string) *Shard

+ func (s *Shard) SetHashKeyRange(v *HashKeyRange) *Shard

+ func (s *Shard) SetParentShardId(v string) *Shard

+ func (s *Shard) SetSequenceNumberRange(v *SequenceNumberRange) *Shard

+ func (s *Shard) SetShardId(v string) *Shard

type SplitShardInput

+ func (s *SplitShardInput) SetNewStartingHashKey(v string) *SplitShardInput

+ func (s *SplitShardInput) SetShardToSplit(v string) *SplitShardInput

+ func (s *SplitShardInput) SetStreamName(v string) *SplitShardInput

type StreamDescription

+ StreamCreationTimestamp *time.Time

+ func (s *StreamDescription) SetEnhancedMonitoring(v []*EnhancedMetrics) *StreamDescription

+ func (s *StreamDescription) SetHasMoreShards(v bool) *StreamDescription

+ func (s *StreamDescription) SetRetentionPeriodHours(v int64) *StreamDescription

+ func (s *StreamDescription) SetShards(v []*Shard) *StreamDescription

+ func (s *StreamDescription) SetStreamARN(v string) *StreamDescription

+ func (s *StreamDescription) SetStreamCreationTimestamp(v time.Time) *StreamDescription

+ func (s *StreamDescription) SetStreamName(v string) *StreamDescription

+ func (s *StreamDescription) SetStreamStatus(v string) *StreamDescription

type Tag

+ func (s *Tag) SetKey(v string) *Tag

+ func (s *Tag) SetValue(v string) *Tag

+ type UpdateShardCountInput struct

+ ScalingType *string

+ StreamName *string

+ TargetShardCount *int64

+ func (s *UpdateShardCountInput) SetScalingType(v string) *UpdateShardCountInput

+ func (s *UpdateShardCountInput) SetStreamName(v string) *UpdateShardCountInput

+ func (s *UpdateShardCountInput) SetTargetShardCount(v int64) *UpdateShardCountInput

+ func (s *UpdateShardCountInput) Validate() error

+ func (s UpdateShardCountInput) GoString() string

+ func (s UpdateShardCountInput) String() string

+ type UpdateShardCountOutput struct

+ CurrentShardCount *int64

+ StreamName *string

+ TargetShardCount *int64

+ func (s *UpdateShardCountOutput) SetCurrentShardCount(v int64) *UpdateShardCountOutput

+ func (s *UpdateShardCountOutput) SetStreamName(v string) *UpdateShardCountOutput

+ func (s *UpdateShardCountOutput) SetTargetShardCount(v int64) *UpdateShardCountOutput

+ func (s UpdateShardCountOutput) GoString() string

+ func (s UpdateShardCountOutput) String() string

v1.4.5

Aug 30, 2016

v1.3.0

Aug 2, 2016

Changes in this version

type AddTagsToStreamInput

+ func (s *AddTagsToStreamInput) Validate() error

type CreateStreamInput

+ func (s *CreateStreamInput) Validate() error

type DecreaseStreamRetentionPeriodInput

+ func (s *DecreaseStreamRetentionPeriodInput) Validate() error

type DeleteStreamInput

+ func (s *DeleteStreamInput) Validate() error

type DescribeStreamInput

+ func (s *DescribeStreamInput) Validate() error

type DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) Validate() error

type EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) Validate() error

type GetRecordsInput

+ func (s *GetRecordsInput) Validate() error

type GetShardIteratorInput

+ func (s *GetShardIteratorInput) Validate() error

type IncreaseStreamRetentionPeriodInput

+ func (s *IncreaseStreamRetentionPeriodInput) Validate() error

type ListStreamsInput

+ func (s *ListStreamsInput) Validate() error

type ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) Validate() error

type MergeShardsInput

+ func (s *MergeShardsInput) Validate() error

type PutRecordInput

+ func (s *PutRecordInput) Validate() error

type PutRecordsInput

+ func (s *PutRecordsInput) Validate() error

type PutRecordsRequestEntry

+ func (s *PutRecordsRequestEntry) Validate() error

type RemoveTagsFromStreamInput

+ func (s *RemoveTagsFromStreamInput) Validate() error

type SplitShardInput

+ func (s *SplitShardInput) Validate() error

v1.1.19

Apr 19, 2016

Changes in this version

+ const MetricsNameAll

+ const MetricsNameIncomingBytes

+ const MetricsNameIncomingRecords

+ const MetricsNameIteratorAgeMilliseconds

+ const MetricsNameOutgoingBytes

+ const MetricsNameOutgoingRecords

+ const MetricsNameReadProvisionedThroughputExceeded

+ const MetricsNameWriteProvisionedThroughputExceeded

+ const ShardIteratorTypeAtTimestamp

+ type DisableEnhancedMonitoringInput struct

+ ShardLevelMetrics []*string

+ StreamName *string

+ func (s DisableEnhancedMonitoringInput) GoString() string

+ func (s DisableEnhancedMonitoringInput) String() string

+ type EnableEnhancedMonitoringInput struct

+ ShardLevelMetrics []*string

+ StreamName *string

+ func (s EnableEnhancedMonitoringInput) GoString() string

+ func (s EnableEnhancedMonitoringInput) String() string

+ type EnhancedMetrics struct

+ ShardLevelMetrics []*string

+ func (s EnhancedMetrics) GoString() string

+ func (s EnhancedMetrics) String() string

+ type EnhancedMonitoringOutput struct

+ CurrentShardLevelMetrics []*string

+ DesiredShardLevelMetrics []*string

+ StreamName *string

+ func (s EnhancedMonitoringOutput) GoString() string

+ func (s EnhancedMonitoringOutput) String() string

type GetShardIteratorInput

+ Timestamp *time.Time

type Kinesis

+ func (c *Kinesis) DisableEnhancedMonitoring(input *DisableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) DisableEnhancedMonitoringRequest(input *DisableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput)

+ func (c *Kinesis) EnableEnhancedMonitoring(input *EnableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) EnableEnhancedMonitoringRequest(input *EnableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput)

type StreamDescription

+ EnhancedMonitoring []*EnhancedMetrics

v1.0.8

Jan 12, 2016

v1.0.2

Nov 24, 2015

Changes in this version

+ const ServiceName

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ const StreamStatusActive

+ const StreamStatusCreating

+ const StreamStatusDeleting

+ const StreamStatusUpdating

+ type AddTagsToStreamInput struct

+ StreamName *string

+ Tags map[string]*string

+ func (s AddTagsToStreamInput) GoString() string

+ func (s AddTagsToStreamInput) String() string

+ type AddTagsToStreamOutput struct

+ func (s AddTagsToStreamOutput) GoString() string

+ func (s AddTagsToStreamOutput) String() string

+ type CreateStreamInput struct

+ ShardCount *int64

+ StreamName *string

+ func (s CreateStreamInput) GoString() string

+ func (s CreateStreamInput) String() string

+ type CreateStreamOutput struct

+ func (s CreateStreamOutput) GoString() string

+ func (s CreateStreamOutput) String() string

+ type DecreaseStreamRetentionPeriodInput struct

+ RetentionPeriodHours *int64

+ StreamName *string

+ func (s DecreaseStreamRetentionPeriodInput) GoString() string

+ func (s DecreaseStreamRetentionPeriodInput) String() string

+ type DecreaseStreamRetentionPeriodOutput struct

+ func (s DecreaseStreamRetentionPeriodOutput) GoString() string

+ func (s DecreaseStreamRetentionPeriodOutput) String() string

+ type DeleteStreamInput struct

+ StreamName *string

+ func (s DeleteStreamInput) GoString() string

+ func (s DeleteStreamInput) String() string

+ type DeleteStreamOutput struct

+ func (s DeleteStreamOutput) GoString() string

+ func (s DeleteStreamOutput) String() string

+ type DescribeStreamInput struct

+ ExclusiveStartShardId *string

+ Limit *int64

+ StreamName *string

+ func (s DescribeStreamInput) GoString() string

+ func (s DescribeStreamInput) String() string

+ type DescribeStreamOutput struct

+ StreamDescription *StreamDescription

+ func (s DescribeStreamOutput) GoString() string

+ func (s DescribeStreamOutput) String() string

+ type GetRecordsInput struct

+ Limit *int64

+ ShardIterator *string

+ func (s GetRecordsInput) GoString() string

+ func (s GetRecordsInput) String() string

+ type GetRecordsOutput struct

+ MillisBehindLatest *int64

+ NextShardIterator *string

+ Records []*Record

+ func (s GetRecordsOutput) GoString() string

+ func (s GetRecordsOutput) String() string

+ type GetShardIteratorInput struct

+ ShardId *string

+ ShardIteratorType *string

+ StartingSequenceNumber *string

+ StreamName *string

+ func (s GetShardIteratorInput) GoString() string

+ func (s GetShardIteratorInput) String() string

+ type GetShardIteratorOutput struct

+ ShardIterator *string

+ func (s GetShardIteratorOutput) GoString() string

+ func (s GetShardIteratorOutput) String() string

+ type HashKeyRange struct

+ EndingHashKey *string

+ StartingHashKey *string

+ func (s HashKeyRange) GoString() string

+ func (s HashKeyRange) String() string

+ type IncreaseStreamRetentionPeriodInput struct

+ RetentionPeriodHours *int64

+ StreamName *string

+ func (s IncreaseStreamRetentionPeriodInput) GoString() string

+ func (s IncreaseStreamRetentionPeriodInput) String() string

+ type IncreaseStreamRetentionPeriodOutput struct

+ func (s IncreaseStreamRetentionPeriodOutput) GoString() string

+ func (s IncreaseStreamRetentionPeriodOutput) String() string

+ type Kinesis struct

+ func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kinesis

+ func (c *Kinesis) AddTagsToStream(input *AddTagsToStreamInput) (*AddTagsToStreamOutput, error)

+ func (c *Kinesis) AddTagsToStreamRequest(input *AddTagsToStreamInput) (req *request.Request, output *AddTagsToStreamOutput)

+ func (c *Kinesis) CreateStream(input *CreateStreamInput) (*CreateStreamOutput, error)

+ func (c *Kinesis) CreateStreamRequest(input *CreateStreamInput) (req *request.Request, output *CreateStreamOutput)

+ func (c *Kinesis) DecreaseStreamRetentionPeriod(input *DecreaseStreamRetentionPeriodInput) (*DecreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) DecreaseStreamRetentionPeriodRequest(input *DecreaseStreamRetentionPeriodInput) (req *request.Request, output *DecreaseStreamRetentionPeriodOutput)

+ func (c *Kinesis) DeleteStream(input *DeleteStreamInput) (*DeleteStreamOutput, error)

+ func (c *Kinesis) DeleteStreamRequest(input *DeleteStreamInput) (req *request.Request, output *DeleteStreamOutput)

+ func (c *Kinesis) DescribeStream(input *DescribeStreamInput) (*DescribeStreamOutput, error)

+ func (c *Kinesis) DescribeStreamPages(input *DescribeStreamInput, ...) error

+ func (c *Kinesis) DescribeStreamRequest(input *DescribeStreamInput) (req *request.Request, output *DescribeStreamOutput)

+ func (c *Kinesis) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error)

+ func (c *Kinesis) GetRecordsRequest(input *GetRecordsInput) (req *request.Request, output *GetRecordsOutput)

+ func (c *Kinesis) GetShardIterator(input *GetShardIteratorInput) (*GetShardIteratorOutput, error)

+ func (c *Kinesis) GetShardIteratorRequest(input *GetShardIteratorInput) (req *request.Request, output *GetShardIteratorOutput)

+ func (c *Kinesis) IncreaseStreamRetentionPeriod(input *IncreaseStreamRetentionPeriodInput) (*IncreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) IncreaseStreamRetentionPeriodRequest(input *IncreaseStreamRetentionPeriodInput) (req *request.Request, output *IncreaseStreamRetentionPeriodOutput)

+ func (c *Kinesis) ListStreams(input *ListStreamsInput) (*ListStreamsOutput, error)

+ func (c *Kinesis) ListStreamsPages(input *ListStreamsInput, ...) error

+ func (c *Kinesis) ListStreamsRequest(input *ListStreamsInput) (req *request.Request, output *ListStreamsOutput)

+ func (c *Kinesis) ListTagsForStream(input *ListTagsForStreamInput) (*ListTagsForStreamOutput, error)

+ func (c *Kinesis) ListTagsForStreamRequest(input *ListTagsForStreamInput) (req *request.Request, output *ListTagsForStreamOutput)

+ func (c *Kinesis) MergeShards(input *MergeShardsInput) (*MergeShardsOutput, error)

+ func (c *Kinesis) MergeShardsRequest(input *MergeShardsInput) (req *request.Request, output *MergeShardsOutput)

+ func (c *Kinesis) PutRecord(input *PutRecordInput) (*PutRecordOutput, error)

+ func (c *Kinesis) PutRecordRequest(input *PutRecordInput) (req *request.Request, output *PutRecordOutput)

+ func (c *Kinesis) PutRecords(input *PutRecordsInput) (*PutRecordsOutput, error)

+ func (c *Kinesis) PutRecordsRequest(input *PutRecordsInput) (req *request.Request, output *PutRecordsOutput)

+ func (c *Kinesis) RemoveTagsFromStream(input *RemoveTagsFromStreamInput) (*RemoveTagsFromStreamOutput, error)

+ func (c *Kinesis) RemoveTagsFromStreamRequest(input *RemoveTagsFromStreamInput) (req *request.Request, output *RemoveTagsFromStreamOutput)

+ func (c *Kinesis) SplitShard(input *SplitShardInput) (*SplitShardOutput, error)

+ func (c *Kinesis) SplitShardRequest(input *SplitShardInput) (req *request.Request, output *SplitShardOutput)

+ func (c *Kinesis) WaitUntilStreamExists(input *DescribeStreamInput) error

+ type ListStreamsInput struct

+ ExclusiveStartStreamName *string

+ Limit *int64

+ func (s ListStreamsInput) GoString() string

+ func (s ListStreamsInput) String() string

+ type ListStreamsOutput struct

+ HasMoreStreams *bool

+ StreamNames []*string

+ func (s ListStreamsOutput) GoString() string

+ func (s ListStreamsOutput) String() string

+ type ListTagsForStreamInput struct

+ ExclusiveStartTagKey *string

+ Limit *int64

+ StreamName *string

+ func (s ListTagsForStreamInput) GoString() string

+ func (s ListTagsForStreamInput) String() string

+ type ListTagsForStreamOutput struct

+ HasMoreTags *bool

+ Tags []*Tag

+ func (s ListTagsForStreamOutput) GoString() string

+ func (s ListTagsForStreamOutput) String() string

+ type MergeShardsInput struct

+ AdjacentShardToMerge *string

+ ShardToMerge *string

+ StreamName *string

+ func (s MergeShardsInput) GoString() string

+ func (s MergeShardsInput) String() string

+ type MergeShardsOutput struct

+ func (s MergeShardsOutput) GoString() string

+ func (s MergeShardsOutput) String() string

+ type PutRecordInput struct

+ Data []byte

+ ExplicitHashKey *string

+ PartitionKey *string

+ SequenceNumberForOrdering *string

+ StreamName *string

+ func (s PutRecordInput) GoString() string

+ func (s PutRecordInput) String() string

+ type PutRecordOutput struct

+ SequenceNumber *string

+ ShardId *string

+ func (s PutRecordOutput) GoString() string

+ func (s PutRecordOutput) String() string

+ type PutRecordsInput struct

+ Records []*PutRecordsRequestEntry

+ StreamName *string

+ func (s PutRecordsInput) GoString() string

+ func (s PutRecordsInput) String() string

+ type PutRecordsOutput struct

+ FailedRecordCount *int64

+ Records []*PutRecordsResultEntry

+ func (s PutRecordsOutput) GoString() string

+ func (s PutRecordsOutput) String() string

+ type PutRecordsRequestEntry struct

+ Data []byte

+ ExplicitHashKey *string

+ PartitionKey *string

+ func (s PutRecordsRequestEntry) GoString() string

+ func (s PutRecordsRequestEntry) String() string

+ type PutRecordsResultEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ SequenceNumber *string

+ ShardId *string

+ func (s PutRecordsResultEntry) GoString() string

+ func (s PutRecordsResultEntry) String() string

+ type Record struct

+ ApproximateArrivalTimestamp *time.Time

+ Data []byte

+ PartitionKey *string

+ SequenceNumber *string

+ func (s Record) GoString() string

+ func (s Record) String() string

+ type RemoveTagsFromStreamInput struct

+ StreamName *string

+ TagKeys []*string

+ func (s RemoveTagsFromStreamInput) GoString() string

+ func (s RemoveTagsFromStreamInput) String() string

+ type RemoveTagsFromStreamOutput struct

+ func (s RemoveTagsFromStreamOutput) GoString() string

+ func (s RemoveTagsFromStreamOutput) String() string

+ type SequenceNumberRange struct

+ EndingSequenceNumber *string

+ StartingSequenceNumber *string

+ func (s SequenceNumberRange) GoString() string

+ func (s SequenceNumberRange) String() string

+ type Shard struct

+ AdjacentParentShardId *string

+ HashKeyRange *HashKeyRange

+ ParentShardId *string

+ SequenceNumberRange *SequenceNumberRange

+ ShardId *string

+ func (s Shard) GoString() string

+ func (s Shard) String() string

+ type SplitShardInput struct

+ NewStartingHashKey *string

+ ShardToSplit *string

+ StreamName *string

+ func (s SplitShardInput) GoString() string

+ func (s SplitShardInput) String() string

+ type SplitShardOutput struct

+ func (s SplitShardOutput) GoString() string

+ func (s SplitShardOutput) String() string

+ type StreamDescription struct

+ HasMoreShards *bool

+ RetentionPeriodHours *int64

+ Shards []*Shard

+ StreamARN *string

+ StreamName *string

+ StreamStatus *string

+ func (s StreamDescription) GoString() string

+ func (s StreamDescription) String() string

+ type Tag struct

+ Key *string

+ Value *string

+ func (s Tag) GoString() string

+ func (s Tag) String() string

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