Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

dynamodb

package

Go to main page

Versions in this module

v1

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

Changes in this version

+ type ShardIteratorEntry struct

+ EndSeq int64

+ ExpiresAt time.Time

+ StartSeq int64

+ TableName string

v1.1.1

Jul 20, 2026

Changes in this version

+ func FromStreamAttributeValue(av streamstypes.AttributeValue) (map[string]any, error)

+ func FromStreamItem(item map[string]streamstypes.AttributeValue) (map[string]any, error)

+ type WireDescribeStreamOutput struct

+ StreamDescription *WireStreamDescription

+ func ToWireDescribeStreamOutput(out *dynamodbstreams.DescribeStreamOutput) *WireDescribeStreamOutput

+ type WireGetRecordsOutput struct

+ NextShardIterator *string

+ Records []WireStreamRecord

+ func ToWireGetRecordsOutput(out *dynamodbstreams.GetRecordsOutput) (*WireGetRecordsOutput, error)

+ type WireStreamDescription struct

+ CreationRequestDateTime *float64

+ KeySchema []streamstypes.KeySchemaElement

+ LastEvaluatedShardID *string

+ Shards []streamstypes.Shard

+ StreamArn *string

+ StreamLabel *string

+ StreamStatus streamstypes.StreamStatus

+ StreamViewType streamstypes.StreamViewType

+ TableName *string

+ type WireStreamRecord struct

+ AwsRegion string

+ Dynamodb *WireStreamRecordData

+ EventID string

+ EventName streamstypes.OperationType

+ EventSource string

+ EventVersion string

+ UserIdentity *streamstypes.Identity

+ type WireStreamRecordData struct

+ ApproximateCreationDateTime *float64

+ Keys map[string]any

+ NewImage map[string]any

+ OldImage map[string]any

+ SequenceNumber *string

+ SizeBytes *int64

+ StreamViewType streamstypes.StreamViewType

+ func ToWireStreamRecordData(record *streamstypes.StreamRecord) (*WireStreamRecordData, error)

v1.1.0

Jul 19, 2026

Changes in this version

+ const MaxItemSize

+ const MaxPartitionKeySize

+ const MaxSortKeySize

+ var ErrEmptySequenceNumber = errors.New("empty sequence number")

+ var ErrIndexOutOfRange = errors.New("index out of bounds")

+ var ErrInvalidAttributeValue = errors.New("expected map[string]any for attribute value")

+ var ErrInvalidIndex = errors.New("invalid list index")

+ var ErrInvalidStatement = errors.New("invalid PartiQL statement")

+ var ErrInvalidTypeKeyCount = errors.New("expected exactly 1 type key")

+ var ErrNonListAccess = errors.New("cannot access index on non-list")

+ var ErrNonMapAccess = errors.New("cannot access key on non-map")

+ var ErrNonMapItem = errors.New("item is not a Map")

+ var ErrTypeMismatchB = errors.New("expected []byte or base64 string for B")

+ var ErrTypeMismatchBOOL = errors.New("expected bool for BOOL")

+ var ErrTypeMismatchL = errors.New("expected slice for L")

+ var ErrTypeMismatchM = errors.New("expected map for M")

+ var ErrTypeMismatchN = errors.New("expected string for N")

+ var ErrTypeMismatchS = errors.New("expected string for S")

+ var ErrUnclosedBracket = errors.New("unclosed bracket in path")

+ var ErrUnknownAttributeType = errors.New("unknown attribute type")

+ var ErrUnknownOperation = errors.New("UnknownOperationException")

+ var ErrValidation = errors.New("validation error")

+ var TTLGracePeriod = 0 * time.Second

+ func BuildKeyString(item map[string]any, attrName string) string

+ func CalculateAttrSize(v any) int64

+ func CalculateItemSize(item map[string]any) (int, error)

+ func EvaluateExpression(expression string, item map[string]any, attrValues map[string]any, ...) (bool, error)

+ func ReadCapacityUnits(item map[string]any) float64

+ func ValidateDataTypes(item map[string]any) error

+ func ValidateItemSize(item map[string]any) error

+ func WithRegion(ctx context.Context, region string) context.Context

+ func WriteCapacityUnits(item map[string]any) float64

+ type Backup struct

+ AttributeDefinitions []models.AttributeDefinition

+ BackupArn string

+ BackupName string

+ BackupStatus string

+ BackupType string

+ BillingMode string

+ CreationDateTime time.Time

+ GlobalSecondaryIndexes []models.GlobalSecondaryIndex

+ Items []map[string]any

+ KeySchema []models.KeySchemaElement

+ LocalSecondaryIndexes []models.LocalSecondaryIndex

+ ProvisionedThroughput models.ProvisionedThroughputDescription

+ SSEEnabled bool

+ SSEKMSMasterKeyArn string

+ SSEType string

+ SizeBytes int64

+ StreamViewType string

+ StreamsEnabled bool

+ TableArn string

+ TableID string

+ TableName string

+ type CancellationReason struct

+ Code string

+ Item any

+ Message string

+ type ConfigProvider interface

+ GetDynamoDBSettings func() Settings

+ type DashboardHandlers struct

+ HandleDynamoDB func(http.ResponseWriter, *http.Request, string)

+ type DashboardProvider struct

+ Handlers DashboardHandlers

+ func NewDashboardProvider() *DashboardProvider

+ func (p *DashboardProvider) DashboardName() string

+ func (p *DashboardProvider) DashboardRoutePrefix() string

+ func (p *DashboardProvider) RegisterDashboardRoutes(group *echo.Group, _ any, _ string)

+ type DynamoDBHandler struct

+ Backend StorageBackend

+ DefaultRegion string

+ Streams StreamsBackend

+ func NewHandler(backend StorageBackend) *DynamoDBHandler

+ func (h *DynamoDBHandler) ChaosOperations() []string

+ func (h *DynamoDBHandler) ChaosRegions() []string

+ func (h *DynamoDBHandler) ChaosServiceName() string

+ func (h *DynamoDBHandler) DescribeTableInRegion(region, tableName string) *Table

+ func (h *DynamoDBHandler) ExecuteFISAction(ctx context.Context, action service.FISActionExecution) error

+ func (h *DynamoDBHandler) ExtractOperation(c *echo.Context) string

+ func (h *DynamoDBHandler) ExtractResource(c *echo.Context) string

+ func (h *DynamoDBHandler) FISActions() []service.FISActionDefinition

+ func (h *DynamoDBHandler) GetSupportedOperations() []string

+ func (h *DynamoDBHandler) Handler() echo.HandlerFunc

+ func (h *DynamoDBHandler) MatchPriority() int

+ func (h *DynamoDBHandler) Name() string

+ func (h *DynamoDBHandler) Purge(ctx context.Context, cutoff time.Time)

+ func (h *DynamoDBHandler) Regions() []string

+ func (h *DynamoDBHandler) Reset()

+ func (h *DynamoDBHandler) Restore(ctx context.Context, data []byte) error

+ func (h *DynamoDBHandler) RouteMatcher() service.Matcher

+ func (h *DynamoDBHandler) Shutdown(ctx context.Context)

+ func (h *DynamoDBHandler) Snapshot(ctx context.Context) []byte

+ func (h *DynamoDBHandler) StartWorker(ctx context.Context) error

+ func (h *DynamoDBHandler) TableNamesByRegion(region string) []string

+ func (h *DynamoDBHandler) WithJanitor(settings Settings, janitorTimeout ...time.Duration) *DynamoDBHandler

+ type Error struct

+ CancellationReasons []CancellationReason

+ Item any

+ Message string

+ Type string

+ func NewBackupInUseException(msg string) *Error

+ func NewConditionalCheckFailedException(msg string) *Error

+ func NewConditionalCheckFailedExceptionWithItem(msg string, item any) *Error

+ func NewDuplicateItemException(msg string) *Error

+ func NewExpiredIteratorException(msg string) *Error

+ func NewExportNotFoundException(msg string) *Error

+ func NewImportNotFoundException(msg string) *Error

+ func NewInternalServerError(msg string) *Error

+ func NewItemCollectionSizeLimitExceededException(msg string) *Error

+ func NewLimitExceededException(msg string) *Error

+ func NewPolicyNotFoundException(msg string) *Error

+ func NewProvisionedThroughputExceededException(msg string) *Error

+ func NewReplicatedWriteConflictException(msg string) *Error

+ func NewRequestLimitExceeded(msg string) *Error

+ func NewResourceInUseException(msg string) *Error

+ func NewResourceNotFoundException(msg string) *Error

+ func NewShardIteratorCreationException(msg string) *Error

+ func NewThrottlingException(msg string) *Error

+ func NewTransactionCanceledException(msg string, reasons []CancellationReason) *Error

+ func NewTransactionInProgressException(msg string) *Error

+ func NewTrimmedDataAccessException(msg string) *Error

+ func NewValidationException(msg string) *Error

+ func (e *Error) Error() string

+ type ExpressionCache struct

+ func NewExpressionCache(capacity int) *ExpressionCache

+ func (c *ExpressionCache) Close()

+ func (c *ExpressionCache) Get(key string) (any, bool)

+ func (c *ExpressionCache) Put(key string, value any)

+ func (c *ExpressionCache) Sweep()

+ type InMemoryDB struct

+ func NewInMemoryDB() *InMemoryDB

+ func (db *InMemoryDB) BatchExecuteStatement(ctx context.Context, input *sdkdynamodb.BatchExecuteStatementInput) (*sdkdynamodb.BatchExecuteStatementOutput, error)

+ func (db *InMemoryDB) BatchGetItem(ctx context.Context, input *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error)

+ func (db *InMemoryDB) BatchWriteItem(ctx context.Context, input *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error)

+ func (db *InMemoryDB) Close()

+ func (db *InMemoryDB) CreateBackup(ctx context.Context, input *sdkdynamodb.CreateBackupInput) (*sdkdynamodb.CreateBackupOutput, error)

+ func (db *InMemoryDB) CreateGlobalTable(_ context.Context, input *dynamodb.CreateGlobalTableInput) (*dynamodb.CreateGlobalTableOutput, error)

+ func (db *InMemoryDB) CreateTable(ctx context.Context, input *dynamodb.CreateTableInput) (*dynamodb.CreateTableOutput, error)

+ func (db *InMemoryDB) CreateTableInRegion(ctx context.Context, input *dynamodb.CreateTableInput, region string) (*dynamodb.CreateTableOutput, error)

+ func (db *InMemoryDB) DeleteBackup(ctx context.Context, input *sdkdynamodb.DeleteBackupInput) (*sdkdynamodb.DeleteBackupOutput, error)

+ func (db *InMemoryDB) DeleteItem(ctx context.Context, input *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

+ func (db *InMemoryDB) DeleteResourcePolicy(_ context.Context, input *dynamodb.DeleteResourcePolicyInput) (*dynamodb.DeleteResourcePolicyOutput, error)

+ func (db *InMemoryDB) DeleteTable(ctx context.Context, input *dynamodb.DeleteTableInput) (*dynamodb.DeleteTableOutput, error)

+ func (db *InMemoryDB) DescribeBackup(ctx context.Context, input *sdkdynamodb.DescribeBackupInput) (*sdkdynamodb.DescribeBackupOutput, error)

+ func (db *InMemoryDB) DescribeContributorInsights(ctx context.Context, input *dynamodb.DescribeContributorInsightsInput) (*dynamodb.DescribeContributorInsightsOutput, error)

+ func (db *InMemoryDB) DescribeEndpoints(ctx context.Context, _ *dynamodb.DescribeEndpointsInput) (*dynamodb.DescribeEndpointsOutput, error)

+ func (db *InMemoryDB) DescribeGlobalTable(_ context.Context, input *dynamodb.DescribeGlobalTableInput) (*dynamodb.DescribeGlobalTableOutput, error)

+ func (db *InMemoryDB) DescribeGlobalTableSettings(_ context.Context, input *dynamodb.DescribeGlobalTableSettingsInput) (*dynamodb.DescribeGlobalTableSettingsOutput, error)

+ func (db *InMemoryDB) DescribeImport(ctx context.Context, input *dynamodb.DescribeImportInput) (*dynamodb.DescribeImportOutput, error)

+ func (db *InMemoryDB) DescribeKinesisStreamingDestination(ctx context.Context, input *dynamodb.DescribeKinesisStreamingDestinationInput) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error)

+ func (db *InMemoryDB) DescribeLimits(_ context.Context, _ *dynamodb.DescribeLimitsInput) (*dynamodb.DescribeLimitsOutput, error)

+ func (db *InMemoryDB) DescribeStream(_ context.Context, input *dynamodbstreams.DescribeStreamInput) (*dynamodbstreams.DescribeStreamOutput, error)

+ func (db *InMemoryDB) DescribeTable(ctx context.Context, input *dynamodb.DescribeTableInput) (*dynamodb.DescribeTableOutput, error)

+ func (db *InMemoryDB) DescribeTimeToLive(ctx context.Context, input *dynamodb.DescribeTimeToLiveInput) (*dynamodb.DescribeTimeToLiveOutput, error)

+ func (db *InMemoryDB) DisableKinesisStreamingDestination(ctx context.Context, input *dynamodb.DisableKinesisStreamingDestinationInput) (*dynamodb.DisableKinesisStreamingDestinationOutput, error)

+ func (db *InMemoryDB) DisableStream(ctx context.Context, tableName string) error

+ func (db *InMemoryDB) EnableKinesisStreamingDestination(ctx context.Context, input *dynamodb.EnableKinesisStreamingDestinationInput) (*dynamodb.EnableKinesisStreamingDestinationOutput, error)

+ func (db *InMemoryDB) EnableStream(ctx context.Context, tableName, viewType string) error

+ func (db *InMemoryDB) ExecuteTransaction(ctx context.Context, input *dynamodb.ExecuteTransactionInput) (*dynamodb.ExecuteTransactionOutput, error)

+ func (db *InMemoryDB) GetItem(ctx context.Context, input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

+ func (db *InMemoryDB) GetRecentEvents(tableName string) []models.StreamRecord

+ func (db *InMemoryDB) GetRecords(ctx context.Context, input *dynamodbstreams.GetRecordsInput) (*dynamodbstreams.GetRecordsOutput, error)

+ func (db *InMemoryDB) GetResourcePolicy(_ context.Context, input *dynamodb.GetResourcePolicyInput) (*dynamodb.GetResourcePolicyOutput, error)

+ func (db *InMemoryDB) GetShardIterator(_ context.Context, input *dynamodbstreams.GetShardIteratorInput) (*dynamodbstreams.GetShardIteratorOutput, error)

+ func (db *InMemoryDB) GetTable(name string) (*Table, bool)

+ func (db *InMemoryDB) GetTableInRegion(name string, region string) (*Table, bool)

+ func (db *InMemoryDB) ImportTable(ctx context.Context, input *dynamodb.ImportTableInput) (*dynamodb.ImportTableOutput, error)

+ func (db *InMemoryDB) IsReplicationPaused(tableARNOrName string) bool

+ func (db *InMemoryDB) ListAllTables() []*Table

+ func (db *InMemoryDB) ListContributorInsights(ctx context.Context, _ *dynamodb.ListContributorInsightsInput) (*dynamodb.ListContributorInsightsOutput, error)

+ func (db *InMemoryDB) ListGlobalTables(_ context.Context, input *dynamodb.ListGlobalTablesInput) (*dynamodb.ListGlobalTablesOutput, error)

+ func (db *InMemoryDB) ListImports(ctx context.Context, input *dynamodb.ListImportsInput) (*dynamodb.ListImportsOutput, error)

+ func (db *InMemoryDB) ListStreams(ctx context.Context, input *dynamodbstreams.ListStreamsInput) (*dynamodbstreams.ListStreamsOutput, error)

+ func (db *InMemoryDB) ListTables(ctx context.Context, input *dynamodb.ListTablesInput) (*dynamodb.ListTablesOutput, error)

+ func (db *InMemoryDB) ListTagsOfResource(_ context.Context, input *dynamodb.ListTagsOfResourceInput) (*dynamodb.ListTagsOfResourceOutput, error)

+ func (db *InMemoryDB) Purge(ctx context.Context, cutoff time.Time)

+ func (db *InMemoryDB) PutItem(ctx context.Context, input *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

+ func (db *InMemoryDB) PutResourcePolicy(_ context.Context, input *dynamodb.PutResourcePolicyInput) (*dynamodb.PutResourcePolicyOutput, error)

+ func (db *InMemoryDB) Query(ctx context.Context, input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

+ func (db *InMemoryDB) QueryWithContext(ctx context.Context, input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

+ func (db *InMemoryDB) Regions() []string

+ func (db *InMemoryDB) Reset()

+ func (db *InMemoryDB) Restore(ctx context.Context, data []byte) error

+ func (db *InMemoryDB) Scan(ctx context.Context, input *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

+ func (db *InMemoryDB) ScanWithContext(ctx context.Context, input *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

+ func (db *InMemoryDB) SetCreateDelay(d time.Duration)

+ func (db *InMemoryDB) SetDefaultRegion(region string)

+ func (db *InMemoryDB) SetEnforceThroughput(enabled bool)

+ func (db *InMemoryDB) SetKinesisEmitter(emitter KinesisEmitter)

+ func (db *InMemoryDB) SetS3Backend(s3 S3Accessor)

+ func (db *InMemoryDB) Snapshot(ctx context.Context) []byte

+ func (db *InMemoryDB) TableNamesByRegion(region string) []string

+ func (db *InMemoryDB) TagResource(_ context.Context, input *dynamodb.TagResourceInput) (*dynamodb.TagResourceOutput, error)

+ func (db *InMemoryDB) TaggedTables() []TaggedTableInfo

+ func (db *InMemoryDB) TransactGetItems(ctx context.Context, input *dynamodb.TransactGetItemsInput) (*dynamodb.TransactGetItemsOutput, error)

+ func (db *InMemoryDB) TransactWriteItems(ctx context.Context, input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, error)

+ func (db *InMemoryDB) UntagResource(_ context.Context, input *dynamodb.UntagResourceInput) (*dynamodb.UntagResourceOutput, error)

+ func (db *InMemoryDB) UpdateContributorInsights(ctx context.Context, input *dynamodb.UpdateContributorInsightsInput) (*dynamodb.UpdateContributorInsightsOutput, error)

+ func (db *InMemoryDB) UpdateGlobalTable(_ context.Context, input *dynamodb.UpdateGlobalTableInput) (*dynamodb.UpdateGlobalTableOutput, error)

+ func (db *InMemoryDB) UpdateGlobalTableSettings(_ context.Context, input *dynamodb.UpdateGlobalTableSettingsInput) (*dynamodb.UpdateGlobalTableSettingsOutput, error)

+ func (db *InMemoryDB) UpdateItem(ctx context.Context, input *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

+ func (db *InMemoryDB) UpdateKinesisStreamingDestination(ctx context.Context, input *dynamodb.UpdateKinesisStreamingDestinationInput) (*dynamodb.UpdateKinesisStreamingDestinationOutput, error)

+ func (db *InMemoryDB) UpdateTable(ctx context.Context, input *dynamodb.UpdateTableInput) (*dynamodb.UpdateTableOutput, error)

+ func (db *InMemoryDB) UpdateTableReplicaAutoScaling(ctx context.Context, input *dynamodb.UpdateTableReplicaAutoScalingInput) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error)

+ func (db *InMemoryDB) UpdateTimeToLive(ctx context.Context, input *dynamodb.UpdateTimeToLiveInput) (*dynamodb.UpdateTimeToLiveOutput, error)

+ type Janitor struct

+ Backend *InMemoryDB

+ Interval time.Duration

+ TaskTimeout time.Duration

+ func NewJanitor(backend *InMemoryDB, settings Settings) *Janitor

+ func (j *Janitor) Run(ctx context.Context)

+ func (j *Janitor) SweepOnce(ctx context.Context)

+ type KinesisDestinationEntry struct

+ Precision string

+ StreamARN string

+ type KinesisEmitter interface

+ EmitDynamoDBStreamRecord func(streamARN, tableName string, record models.StreamRecord)

+ type ParsedCondition struct

+ func ParseConditionStr(expression string) (*ParsedCondition, error)

+ func (c *ParsedCondition) Evaluate(item map[string]any, attrValues map[string]any, attrNames map[string]string) bool

+ type Projector struct

+ func ParseProjector(expression string, attrNames map[string]string) (*Projector, error)

+ func (p *Projector) Project(item map[string]any) map[string]any

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type S3Accessor interface

+ GetObject func(ctx context.Context, in *s3sdk.GetObjectInput) (*s3sdk.GetObjectOutput, error)

+ ListObjectsV2 func(ctx context.Context, in *s3sdk.ListObjectsV2Input) (*s3sdk.ListObjectsV2Output, error)

+ PutObject func(ctx context.Context, in *s3sdk.PutObjectInput) (*s3sdk.PutObjectOutput, error)

+ type Settings struct

+ CreateDelay time.Duration

+ DefaultRegion string

+ EnforceThroughput bool

+ JanitorInterval time.Duration

+ TTLSweepBatchSize int

+ type ShardIteratorStore struct

+ func NewShardIteratorStore() *ShardIteratorStore

+ func (s *ShardIteratorStore) Delete(token string)

+ func (s *ShardIteratorStore) Get(token string) *shardIteratorEntry

+ func (s *ShardIteratorStore) Put(tableName string, startSeq int64) (string, error)

+ func (s *ShardIteratorStore) PutWithEnd(tableName string, startSeq, endSeq int64) (string, error)

+ func (s *ShardIteratorStore) Size() int

+ func (s *ShardIteratorStore) Sweep()

+ type StorageBackend interface

+ BatchExecuteStatement func(context.Context, *dynamodb.BatchExecuteStatementInput) (*dynamodb.BatchExecuteStatementOutput, error)

+ BatchGetItem func(context.Context, *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error)

+ BatchWriteItem func(context.Context, *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error)

+ CreateBackup func(context.Context, *dynamodb.CreateBackupInput) (*dynamodb.CreateBackupOutput, error)

+ CreateGlobalTable func(context.Context, *dynamodb.CreateGlobalTableInput) (*dynamodb.CreateGlobalTableOutput, error)

+ CreateTable func(context.Context, *dynamodb.CreateTableInput) (*dynamodb.CreateTableOutput, error)

+ DeleteBackup func(context.Context, *dynamodb.DeleteBackupInput) (*dynamodb.DeleteBackupOutput, error)

+ DeleteItem func(context.Context, *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

+ DeleteResourcePolicy func(context.Context, *dynamodb.DeleteResourcePolicyInput) (*dynamodb.DeleteResourcePolicyOutput, error)

+ DeleteTable func(context.Context, *dynamodb.DeleteTableInput) (*dynamodb.DeleteTableOutput, error)

+ DescribeBackup func(context.Context, *dynamodb.DescribeBackupInput) (*dynamodb.DescribeBackupOutput, error)

+ DescribeContributorInsights func(context.Context, *dynamodb.DescribeContributorInsightsInput) (*dynamodb.DescribeContributorInsightsOutput, error)

+ DescribeEndpoints func(context.Context, *dynamodb.DescribeEndpointsInput) (*dynamodb.DescribeEndpointsOutput, error)

+ DescribeGlobalTable func(context.Context, *dynamodb.DescribeGlobalTableInput) (*dynamodb.DescribeGlobalTableOutput, error)

+ DescribeGlobalTableSettings func(context.Context, *dynamodb.DescribeGlobalTableSettingsInput) (*dynamodb.DescribeGlobalTableSettingsOutput, error)

+ DescribeImport func(context.Context, *dynamodb.DescribeImportInput) (*dynamodb.DescribeImportOutput, error)

+ DescribeKinesisStreamingDestination func(context.Context, *dynamodb.DescribeKinesisStreamingDestinationInput) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error)

+ DescribeLimits func(context.Context, *dynamodb.DescribeLimitsInput) (*dynamodb.DescribeLimitsOutput, error)

+ DescribeTable func(context.Context, *dynamodb.DescribeTableInput) (*dynamodb.DescribeTableOutput, error)

+ DescribeTimeToLive func(context.Context, *dynamodb.DescribeTimeToLiveInput) (*dynamodb.DescribeTimeToLiveOutput, error)

+ DisableKinesisStreamingDestination func(context.Context, *dynamodb.DisableKinesisStreamingDestinationInput) (*dynamodb.DisableKinesisStreamingDestinationOutput, error)

+ EnableKinesisStreamingDestination func(context.Context, *dynamodb.EnableKinesisStreamingDestinationInput) (*dynamodb.EnableKinesisStreamingDestinationOutput, error)

+ ExecuteTransaction func(context.Context, *dynamodb.ExecuteTransactionInput) (*dynamodb.ExecuteTransactionOutput, error)

+ GetItem func(context.Context, *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

+ GetResourcePolicy func(context.Context, *dynamodb.GetResourcePolicyInput) (*dynamodb.GetResourcePolicyOutput, error)

+ ImportTable func(context.Context, *dynamodb.ImportTableInput) (*dynamodb.ImportTableOutput, error)

+ ListContributorInsights func(context.Context, *dynamodb.ListContributorInsightsInput) (*dynamodb.ListContributorInsightsOutput, error)

+ ListGlobalTables func(context.Context, *dynamodb.ListGlobalTablesInput) (*dynamodb.ListGlobalTablesOutput, error)

+ ListImports func(context.Context, *dynamodb.ListImportsInput) (*dynamodb.ListImportsOutput, error)

+ ListTables func(context.Context, *dynamodb.ListTablesInput) (*dynamodb.ListTablesOutput, error)

+ ListTagsOfResource func(context.Context, *dynamodb.ListTagsOfResourceInput) (*dynamodb.ListTagsOfResourceOutput, error)

+ PutItem func(context.Context, *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

+ PutResourcePolicy func(context.Context, *dynamodb.PutResourcePolicyInput) (*dynamodb.PutResourcePolicyOutput, error)

+ Query func(context.Context, *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

+ Scan func(context.Context, *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

+ TagResource func(context.Context, *dynamodb.TagResourceInput) (*dynamodb.TagResourceOutput, error)

+ TransactGetItems func(context.Context, *dynamodb.TransactGetItemsInput) (*dynamodb.TransactGetItemsOutput, error)

+ TransactWriteItems func(context.Context, *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, error)

+ UntagResource func(context.Context, *dynamodb.UntagResourceInput) (*dynamodb.UntagResourceOutput, error)

+ UpdateContributorInsights func(context.Context, *dynamodb.UpdateContributorInsightsInput) (*dynamodb.UpdateContributorInsightsOutput, error)

+ UpdateGlobalTable func(context.Context, *dynamodb.UpdateGlobalTableInput) (*dynamodb.UpdateGlobalTableOutput, error)

+ UpdateGlobalTableSettings func(context.Context, *dynamodb.UpdateGlobalTableSettingsInput) (*dynamodb.UpdateGlobalTableSettingsOutput, error)

+ UpdateItem func(context.Context, *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

+ UpdateKinesisStreamingDestination func(context.Context, *dynamodb.UpdateKinesisStreamingDestinationInput) (*dynamodb.UpdateKinesisStreamingDestinationOutput, error)

+ UpdateTable func(context.Context, *dynamodb.UpdateTableInput) (*dynamodb.UpdateTableOutput, error)

+ UpdateTableReplicaAutoScaling func(context.Context, *dynamodb.UpdateTableReplicaAutoScalingInput) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error)

+ UpdateTimeToLive func(context.Context, *dynamodb.UpdateTimeToLiveInput) (*dynamodb.UpdateTimeToLiveOutput, error)

+ type StoredGlobalTable struct

+ BillingMode string

+ CreationDateTime time.Time

+ GlobalTableArn string

+ GlobalTableName string

+ ReplicaSettings map[string]*StoredReplicaSettings

+ ReplicationGroup []string

+ WriteCapacityUnits *int64

+ type StoredReplicaSettings struct

+ ReadCapacityUnits *int64

+ TableClass string

+ type StreamShard struct

+ EndingSequenceNum int64

+ ParentShardID string

+ ShardID string

+ StartingSequenceNum int64

+ type StreamsBackend interface

+ DescribeStream func(ctx context.Context, input *dynamodbstreams.DescribeStreamInput) (*dynamodbstreams.DescribeStreamOutput, error)

+ DisableStream func(ctx context.Context, tableName string) error

+ EnableStream func(ctx context.Context, tableName, viewType string) error

+ GetRecentEvents func(tableName string) []models.StreamRecord

+ GetRecords func(ctx context.Context, input *dynamodbstreams.GetRecordsInput) (*dynamodbstreams.GetRecordsOutput, error)

+ GetShardIterator func(ctx context.Context, input *dynamodbstreams.GetShardIteratorInput) (*dynamodbstreams.GetShardIteratorOutput, error)

+ ListStreams func(ctx context.Context, input *dynamodbstreams.ListStreamsInput) (*dynamodbstreams.ListStreamsOutput, error)

+ type Table struct

+ AttributeDefinitions []models.AttributeDefinition

+ AutoScaling *autoScalingSettings

+ BillingMode string

+ ContributorInsightsEnabled bool

+ CreationDateTime time.Time

+ DeletionProtectionEnabled bool

+ GlobalSecondaryIndexes []models.GlobalSecondaryIndex

+ GlobalTableName string

+ Items []map[string]any

+ KeySchema []models.KeySchemaElement

+ KinesisDestinations []KinesisDestinationEntry

+ LocalSecondaryIndexes []models.LocalSecondaryIndex

+ Name string

+ OnDemandMaxReadRRU *int64

+ OnDemandMaxWriteRRU *int64

+ PITREnabled bool

+ ProvisionedThroughput models.ProvisionedThroughputDescription

+ Replicas []models.ReplicaDescription

+ ResourcePolicy string

+ SSEEnabled bool

+ SSEKMSMasterKeyArn string

+ SSEType string

+ Status string

+ StreamARN string

+ StreamCreatedAt time.Time

+ StreamHead int

+ StreamRecords []models.StreamRecord

+ StreamViewType string

+ StreamsEnabled bool

+ TTLAttribute string

+ TableArn string

+ TableClass string

+ TableID string

+ Tags *tags.Tags

+ type TaggedTableInfo struct

+ ARN string

+ Tags map[string]string

+ type Throttler struct

+ func NewThrottler(enabled bool) *Throttler

+ func (t *Throttler) ConsumeRead(key string, units float64) error

+ func (t *Throttler) ConsumeWrite(key string, units float64) error

+ func (t *Throttler) DeleteTable(key string)

+ func (t *Throttler) SetTableCapacity(key string, rcu, wcu int64)