dynamodbstreams

package

Go to main page

Versions in this module

v0

v0.4.0

May 26, 2018

v0.3.0

Mar 8, 2018

Changes in this version

type DescribeStreamRequest

+ Copy func(*DescribeStreamInput) DescribeStreamRequest

type GetRecordsRequest

+ Copy func(*GetRecordsInput) GetRecordsRequest

type GetShardIteratorRequest

+ Copy func(*GetShardIteratorInput) GetShardIteratorRequest

type KeyType

+ func (enum KeyType) MarshalValue() (string, error)

+ func (enum KeyType) MarshalValueBuf(b []byte) ([]byte, error)

type ListStreamsRequest

+ Copy func(*ListStreamsInput) ListStreamsRequest

type OperationType

+ func (enum OperationType) MarshalValue() (string, error)

+ func (enum OperationType) MarshalValueBuf(b []byte) ([]byte, error)

type ShardIteratorType

+ func (enum ShardIteratorType) MarshalValue() (string, error)

+ func (enum ShardIteratorType) MarshalValueBuf(b []byte) ([]byte, error)

type StreamStatus

+ func (enum StreamStatus) MarshalValue() (string, error)

+ func (enum StreamStatus) MarshalValueBuf(b []byte) ([]byte, error)

type StreamViewType

+ func (enum StreamViewType) MarshalValue() (string, error)

+ func (enum StreamViewType) MarshalValueBuf(b []byte) ([]byte, error)

v0.2.0

Jan 15, 2018

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeExpiredIteratorException

+ const ErrCodeInternalServerError

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeTrimmedDataAccessException

+ const ServiceName

+ type DescribeStreamInput struct

+ ExclusiveStartShardId *string

+ Limit *int64

+ StreamArn *string

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

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

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

+ func (s *DescribeStreamInput) Validate() error

+ func (s DescribeStreamInput) GoString() string

+ func (s DescribeStreamInput) String() string

+ type DescribeStreamOutput struct

+ StreamDescription *StreamDescription

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

+ func (s DescribeStreamOutput) GoString() string

+ func (s DescribeStreamOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeStreamOutput) String() string

+ type DescribeStreamRequest struct

+ Input *DescribeStreamInput

+ func (r DescribeStreamRequest) Send() (*DescribeStreamOutput, error)

+ type DynamoDBStreams struct

+ func New(config aws.Config) *DynamoDBStreams

+ func (c *DynamoDBStreams) DescribeStreamRequest(input *DescribeStreamInput) DescribeStreamRequest

+ func (c *DynamoDBStreams) GetRecordsRequest(input *GetRecordsInput) GetRecordsRequest

+ func (c *DynamoDBStreams) GetShardIteratorRequest(input *GetShardIteratorInput) GetShardIteratorRequest

+ func (c *DynamoDBStreams) ListStreamsRequest(input *ListStreamsInput) ListStreamsRequest

+ type GetRecordsInput struct

+ Limit *int64

+ ShardIterator *string

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

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

+ func (s *GetRecordsInput) Validate() error

+ func (s GetRecordsInput) GoString() string

+ func (s GetRecordsInput) String() string

+ type GetRecordsOutput struct

+ NextShardIterator *string

+ Records []Record

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

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

+ func (s GetRecordsOutput) GoString() string

+ func (s GetRecordsOutput) SDKResponseMetadata() aws.Response

+ func (s GetRecordsOutput) String() string

+ type GetRecordsRequest struct

+ Input *GetRecordsInput

+ func (r GetRecordsRequest) Send() (*GetRecordsOutput, error)

+ type GetShardIteratorInput struct

+ SequenceNumber *string

+ ShardId *string

+ ShardIteratorType ShardIteratorType

+ StreamArn *string

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

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

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

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

+ func (s *GetShardIteratorInput) Validate() error

+ func (s GetShardIteratorInput) GoString() string

+ func (s GetShardIteratorInput) String() string

+ type GetShardIteratorOutput struct

+ ShardIterator *string

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

+ func (s GetShardIteratorOutput) GoString() string

+ func (s GetShardIteratorOutput) SDKResponseMetadata() aws.Response

+ func (s GetShardIteratorOutput) String() string

+ type GetShardIteratorRequest struct

+ Input *GetShardIteratorInput

+ func (r GetShardIteratorRequest) Send() (*GetShardIteratorOutput, error)

+ 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 KeyType string

+ const KeyTypeHash

+ const KeyTypeRange

+ type ListStreamsInput struct

+ ExclusiveStartStreamArn *string

+ Limit *int64

+ TableName *string

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

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

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

+ func (s *ListStreamsInput) Validate() error

+ func (s ListStreamsInput) GoString() string

+ func (s ListStreamsInput) String() string

+ type ListStreamsOutput struct

+ LastEvaluatedStreamArn *string

+ Streams []Stream

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

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

+ func (s ListStreamsOutput) GoString() string

+ func (s ListStreamsOutput) SDKResponseMetadata() aws.Response

+ func (s ListStreamsOutput) String() string

+ type ListStreamsRequest struct

+ Input *ListStreamsInput

+ func (r ListStreamsRequest) Send() (*ListStreamsOutput, error)

+ type OperationType string

+ const OperationTypeInsert

+ const OperationTypeModify

+ const OperationTypeRemove

+ type Record struct

+ AwsRegion *string

+ Dynamodb *StreamRecord

+ EventID *string

+ EventName OperationType

+ EventSource *string

+ EventVersion *string

+ UserIdentity *Identity

+ 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 OperationType) *Record

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

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

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

+ func (s Record) GoString() string

+ func (s Record) String() string

+ type SequenceNumberRange struct

+ EndingSequenceNumber *string

+ StartingSequenceNumber *string

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

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

+ func (s SequenceNumberRange) GoString() string

+ func (s SequenceNumberRange) String() string

+ type Shard struct

+ ParentShardId *string

+ SequenceNumberRange *SequenceNumberRange

+ ShardId *string

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

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

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

+ func (s Shard) GoString() string

+ func (s Shard) String() string

+ type ShardIteratorType string

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ type Stream struct

+ StreamArn *string

+ StreamLabel *string

+ TableName *string

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

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

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

+ 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 StreamStatus

+ StreamViewType StreamViewType

+ TableName *string

+ 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 StreamStatus) *StreamDescription

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

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

+ func (s StreamDescription) GoString() string

+ func (s StreamDescription) String() string

+ type StreamRecord struct

+ ApproximateCreationDateTime *time.Time

+ Keys map[string]dynamodb.AttributeValue

+ NewImage map[string]dynamodb.AttributeValue

+ OldImage map[string]dynamodb.AttributeValue

+ SequenceNumber *string

+ SizeBytes *int64

+ StreamViewType StreamViewType

+ 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 StreamViewType) *StreamRecord

+ func (s StreamRecord) GoString() string

+ func (s StreamRecord) String() string

+ type StreamStatus string

+ const StreamStatusDisabled

+ const StreamStatusDisabling

+ const StreamStatusEnabled

+ const StreamStatusEnabling

+ type StreamViewType string

+ const StreamViewTypeKeysOnly

+ const StreamViewTypeNewAndOldImages

+ const StreamViewTypeNewImage

+ const StreamViewTypeOldImage

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