Versions in this module Expand all Collapse all v1 v1.42.9 Aug 3, 2023 v1.42.6 Nov 15, 2021 Changes in this version + const EndpointsID + const ErrCodeExpiredIteratorException + const ErrCodeInternalServerError + const ErrCodeLimitExceededException + const ErrCodeResourceNotFoundException + const ErrCodeTrimmedDataAccessException + const KeyTypeHash + const KeyTypeRange + const OperationTypeInsert + const OperationTypeModify + const OperationTypeRemove + const ServiceID + 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 + func KeyType_Values() []string + func OperationType_Values() []string + func ShardIteratorType_Values() []string + func StreamStatus_Values() []string + func StreamViewType_Values() []string + 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) 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) DescribeStreamWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.Option) (*DescribeStreamOutput, error) + func (c *DynamoDBStreams) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error) + func (c *DynamoDBStreams) GetRecordsRequest(input *GetRecordsInput) (req *request.Request, output *GetRecordsOutput) + func (c *DynamoDBStreams) GetRecordsWithContext(ctx aws.Context, input *GetRecordsInput, opts ...request.Option) (*GetRecordsOutput, error) + func (c *DynamoDBStreams) GetShardIterator(input *GetShardIteratorInput) (*GetShardIteratorOutput, error) + func (c *DynamoDBStreams) GetShardIteratorRequest(input *GetShardIteratorInput) (req *request.Request, output *GetShardIteratorOutput) + func (c *DynamoDBStreams) GetShardIteratorWithContext(ctx aws.Context, input *GetShardIteratorInput, opts ...request.Option) (*GetShardIteratorOutput, error) + func (c *DynamoDBStreams) ListStreams(input *ListStreamsInput) (*ListStreamsOutput, error) + func (c *DynamoDBStreams) ListStreamsRequest(input *ListStreamsInput) (req *request.Request, output *ListStreamsOutput) + func (c *DynamoDBStreams) ListStreamsWithContext(ctx aws.Context, input *ListStreamsInput, opts ...request.Option) (*ListStreamsOutput, error) + type ExpiredIteratorException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ExpiredIteratorException) Code() string + func (s *ExpiredIteratorException) Error() string + func (s *ExpiredIteratorException) Message() string + func (s *ExpiredIteratorException) OrigErr() error + func (s *ExpiredIteratorException) RequestID() string + func (s *ExpiredIteratorException) StatusCode() int + func (s ExpiredIteratorException) GoString() string + func (s ExpiredIteratorException) String() string + 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) String() string + type GetShardIteratorInput struct + SequenceNumber *string + ShardId *string + ShardIteratorType *string + StreamArn *string + 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 + 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) String() string + 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 InternalServerError struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InternalServerError) Code() string + func (s *InternalServerError) Error() string + func (s *InternalServerError) Message() string + func (s *InternalServerError) OrigErr() error + func (s *InternalServerError) RequestID() string + func (s *InternalServerError) StatusCode() int + func (s InternalServerError) GoString() string + func (s InternalServerError) String() string + type LimitExceededException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *LimitExceededException) Code() string + func (s *LimitExceededException) Error() string + func (s *LimitExceededException) Message() string + func (s *LimitExceededException) OrigErr() error + func (s *LimitExceededException) RequestID() string + func (s *LimitExceededException) StatusCode() int + func (s LimitExceededException) GoString() string + func (s LimitExceededException) String() string + 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) String() string + type Record struct + AwsRegion *string + Dynamodb *StreamRecord + EventID *string + EventName *string + 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 string) *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 ResourceNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceNotFoundException) Code() string + func (s *ResourceNotFoundException) Error() string + func (s *ResourceNotFoundException) Message() string + func (s *ResourceNotFoundException) OrigErr() error + func (s *ResourceNotFoundException) RequestID() string + func (s *ResourceNotFoundException) StatusCode() int + func (s ResourceNotFoundException) GoString() string + func (s ResourceNotFoundException) 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 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 *string + StreamViewType *string + 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 string) *StreamDescription + func (s *StreamDescription) SetStreamViewType(v string) *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 *string + 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 + func (s StreamRecord) GoString() string + func (s StreamRecord) String() string + type TrimmedDataAccessException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *TrimmedDataAccessException) Code() string + func (s *TrimmedDataAccessException) Error() string + func (s *TrimmedDataAccessException) Message() string + func (s *TrimmedDataAccessException) OrigErr() error + func (s *TrimmedDataAccessException) RequestID() string + func (s *TrimmedDataAccessException) StatusCode() int + func (s TrimmedDataAccessException) GoString() string + func (s TrimmedDataAccessException) String() string
Go to main page