dynamodbstreams

Sep 3, 2015

Changes in this version

type DescribeStreamInput

+ ExclusiveStartShardId *string

+ StreamArn *string

type GetShardIteratorInput

+ ShardId *string

+ StreamArn *string

type ListStreamsInput

+ ExclusiveStartStreamArn *string

type ListStreamsOutput

+ LastEvaluatedStreamArn *string

type Record

+ AwsRegion *string

+ Dynamodb *StreamRecord

type Shard

+ ParentShardId *string

+ ShardId *string

type Stream

+ StreamArn *string

type StreamDescription

+ LastEvaluatedShardId *string

+ StreamArn *string

Jul 28, 2015

Changes in this version

+ const KeyTypeHash

+ const KeyTypeRange

+ const OperationTypeInsert

+ const OperationTypeModify

+ const OperationTypeRemove

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ const StreamStatusDisabled

+ const StreamStatusDisabling

+ const StreamStatusEnabled

+ const StreamStatusEnabling

+ const StreamViewTypeKeysOnly

+ const StreamViewTypeNewAndOldImages

+ const StreamViewTypeNewImage

+ const StreamViewTypeOldImage

Jul 14, 2015

Changes in this version

+ 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(config *aws.Config) *DynamoDBStreams

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

+ func (c *DynamoDBStreams) DescribeStreamRequest(input *DescribeStreamInput) (req *aws.Request, output *DescribeStreamOutput)

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

+ func (c *DynamoDBStreams) GetRecordsRequest(input *GetRecordsInput) (req *aws.Request, output *GetRecordsOutput)

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

+ func (c *DynamoDBStreams) GetShardIteratorRequest(input *GetShardIteratorInput) (req *aws.Request, output *GetShardIteratorOutput)

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

+ func (c *DynamoDBStreams) ListStreamsRequest(input *ListStreamsInput) (req *aws.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