dynamodbstreams

Jun 4, 2018

Changes in this version

+ const ServiceID

Mar 22, 2017

Changes in this version

type DynamoDBStreams

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

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

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

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

Feb 28, 2017

Changes in this version

+ type Identity struct

+ PrincipalId *string

+ Type *string

+ func (s *Identity) SetPrincipalId(v string) *Identity

+ func (s *Identity) SetType(v string) *Identity

+ func (s Identity) GoString() string

+ func (s Identity) String() string

type Record

+ UserIdentity *Identity

+ func (s *Record) SetUserIdentity(v *Identity) *Record

Feb 8, 2017

Changes in this version

+ const ErrCodeExpiredIteratorException

+ const ErrCodeInternalServerError

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeTrimmedDataAccessException

Dec 19, 2016

Changes in this version

+ const EndpointsID

Nov 1, 2016

Changes in this version

type DescribeStreamInput

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

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

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

type DescribeStreamOutput

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

type GetRecordsInput

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

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

type GetRecordsOutput

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

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

type GetShardIteratorInput

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

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

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

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

type GetShardIteratorOutput

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

type ListStreamsInput

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

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

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

type ListStreamsOutput

+ func (s *ListStreamsOutput) SetLastEvaluatedStreamArn(v string) *ListStreamsOutput

+ func (s *ListStreamsOutput) SetStreams(v []*Stream) *ListStreamsOutput

type Record

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

+ func (s *Record) SetDynamodb(v *StreamRecord) *Record

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

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

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

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

type SequenceNumberRange

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

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

type Shard

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

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

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

type Stream

+ func (s *Stream) SetStreamArn(v string) *Stream

+ func (s *Stream) SetStreamLabel(v string) *Stream

+ func (s *Stream) SetTableName(v string) *Stream

type StreamDescription

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

+ func (s *StreamDescription) SetKeySchema(v []*dynamodb.KeySchemaElement) *StreamDescription

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

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

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

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

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

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

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

type StreamRecord

+ func (s *StreamRecord) SetApproximateCreationDateTime(v time.Time) *StreamRecord

+ func (s *StreamRecord) SetKeys(v map[string]*dynamodb.AttributeValue) *StreamRecord

+ func (s *StreamRecord) SetNewImage(v map[string]*dynamodb.AttributeValue) *StreamRecord

+ func (s *StreamRecord) SetOldImage(v map[string]*dynamodb.AttributeValue) *StreamRecord

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

+ func (s *StreamRecord) SetSizeBytes(v int64) *StreamRecord

+ func (s *StreamRecord) SetStreamViewType(v string) *StreamRecord

Jun 7, 2016

Changes in this version

type StreamRecord

+ ApproximateCreationDateTime *time.Time

Apr 26, 2016

Changes in this version

type DescribeStreamInput

+ func (s *DescribeStreamInput) Validate() error

type GetRecordsInput

+ func (s *GetRecordsInput) Validate() error

type GetShardIteratorInput

+ func (s *GetShardIteratorInput) Validate() error

type ListStreamsInput

+ func (s *ListStreamsInput) Validate() error

Oct 29, 2015

Changes in this version

+ const ServiceName

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