Versions in this module Expand all Collapse all v0 v0.5.1 Mar 30, 2022 v0.5.0 Mar 30, 2022 Changes in this version + const DefaultReadCapacityUnits + const DefaultWriteCapacityUnits + const DeleteTreeTimeoutSeconds + const TableCreateTimeoutSeconds + var ErrBucketOptionMissing = errors.New("missing dynamodb bucket/table name") + var ErrDeleteTreeTimeout = errors.New("delete batch timed out") + var ErrLockAcquireCancelled = errors.New("stop called before lock was acquired") + var ErrMultipleEndpointsUnsupported = errors.New("dynamodb only supports one endpoint") + var ErrTableCreateTimeout = errors.New("dynamodb table creation timed out") + func New(endpoints []string, options *store.Config) (store.Store, error) + func Register() + type DynamoDB struct + func (ddb *DynamoDB) AtomicDelete(_ context.Context, key string, previous *store.KVPair) (bool, error) + func (ddb *DynamoDB) AtomicPut(_ context.Context, key string, value []byte, previous *store.KVPair, ...) (bool, *store.KVPair, error) + func (ddb *DynamoDB) Close() error + func (ddb *DynamoDB) Delete(_ context.Context, key string) error + func (ddb *DynamoDB) DeleteTree(_ context.Context, keyPrefix string) error + func (ddb *DynamoDB) Exists(_ context.Context, key string, _ *store.ReadOptions) (bool, error) + func (ddb *DynamoDB) Get(_ context.Context, key string, options *store.ReadOptions) (*store.KVPair, error) + func (ddb *DynamoDB) List(_ context.Context, directory string, options *store.ReadOptions) ([]*store.KVPair, error) + func (ddb *DynamoDB) NewLock(_ context.Context, key string, options *store.LockOptions) (store.Locker, error) + func (ddb *DynamoDB) Put(_ context.Context, key string, value []byte, options *store.WriteOptions) error + func (ddb *DynamoDB) Watch(_ context.Context, _ string, _ <-chan struct{}, _ *store.ReadOptions) (<-chan *store.KVPair, error) + func (ddb *DynamoDB) WatchTree(_ context.Context, _ string, _ <-chan struct{}, _ *store.ReadOptions) (<-chan []*store.KVPair, error)
Go to main page