Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dynamodbstreams

package

Go to main page

Versions in this module

v0

v0.7.0

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

v0.6.8

Jul 23, 2015

v0.6.7

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