Versions in this module Expand all Collapse all v1 v1.1.9 Mar 8, 2016 Changes in this version + const KeyTypeHash + const KeyTypeRange + const OperationTypeInsert + const OperationTypeModify + const OperationTypeRemove + const ServiceName + const ShardIteratorTypeAfterSequenceNumber + const ShardIteratorTypeAtSequenceNumber + const ShardIteratorTypeLatest + const ShardIteratorTypeTrimHorizon + const StreamStatusDisabled + const StreamStatusDisabling + const StreamStatusEnabled + const StreamStatusEnabling + const StreamViewTypeKeysOnly + const StreamViewTypeNewAndOldImages + const StreamViewTypeNewImage + const StreamViewTypeOldImage + type DescribeStreamInput struct + ExclusiveStartShardId *string + Limit *int64 + StreamArn *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 DynamoDBStreams struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *DynamoDBStreams + func (c *DynamoDBStreams) DescribeStream(input *DescribeStreamInput) (*DescribeStreamOutput, error) + func (c *DynamoDBStreams) DescribeStreamRequest(input *DescribeStreamInput) (req *request.Request, output *DescribeStreamOutput) + func (c *DynamoDBStreams) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error) + func (c *DynamoDBStreams) GetRecordsRequest(input *GetRecordsInput) (req *request.Request, output *GetRecordsOutput) + func (c *DynamoDBStreams) GetShardIterator(input *GetShardIteratorInput) (*GetShardIteratorOutput, error) + func (c *DynamoDBStreams) GetShardIteratorRequest(input *GetShardIteratorInput) (req *request.Request, output *GetShardIteratorOutput) + func (c *DynamoDBStreams) ListStreams(input *ListStreamsInput) (*ListStreamsOutput, error) + func (c *DynamoDBStreams) ListStreamsRequest(input *ListStreamsInput) (req *request.Request, output *ListStreamsOutput) + type GetRecordsInput struct + Limit *int64 + ShardIterator *string + func (s GetRecordsInput) GoString() string + func (s GetRecordsInput) String() string + type GetRecordsOutput struct + NextShardIterator *string + Records []*Record + func (s GetRecordsOutput) GoString() string + func (s GetRecordsOutput) String() string + type GetShardIteratorInput struct + SequenceNumber *string + ShardId *string + ShardIteratorType *string + StreamArn *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 ListStreamsInput struct + ExclusiveStartStreamArn *string + Limit *int64 + TableName *string + func (s ListStreamsInput) GoString() string + func (s ListStreamsInput) String() string + type ListStreamsOutput struct + LastEvaluatedStreamArn *string + Streams []*Stream + func (s ListStreamsOutput) GoString() string + func (s ListStreamsOutput) String() string + type Record struct + AwsRegion *string + Dynamodb *StreamRecord + EventID *string + EventName *string + EventSource *string + EventVersion *string + func (s Record) GoString() string + func (s Record) String() string + type SequenceNumberRange struct + EndingSequenceNumber *string + StartingSequenceNumber *string + func (s SequenceNumberRange) GoString() string + func (s SequenceNumberRange) String() string + type Shard struct + ParentShardId *string + SequenceNumberRange *SequenceNumberRange + ShardId *string + func (s Shard) GoString() string + func (s Shard) String() string + type Stream struct + StreamArn *string + StreamLabel *string + TableName *string + func (s Stream) GoString() string + func (s Stream) String() string + type StreamDescription struct + CreationRequestDateTime *time.Time + KeySchema []*dynamodb.KeySchemaElement + LastEvaluatedShardId *string + Shards []*Shard + StreamArn *string + StreamLabel *string + StreamStatus *string + StreamViewType *string + TableName *string + func (s StreamDescription) GoString() string + func (s StreamDescription) String() string + type StreamRecord struct + Keys map[string]*dynamodb.AttributeValue + NewImage map[string]*dynamodb.AttributeValue + OldImage map[string]*dynamodb.AttributeValue + SequenceNumber *string + SizeBytes *int64 + StreamViewType *string + func (s StreamRecord) GoString() string + func (s StreamRecord) String() string