dynamodb

Nov 25, 2022

Changes in this version

type Config

+ WssServerAddress *string

Nov 22, 2022

Changes in this version

+ const DefaultReadCapacityUnits

+ const DefaultWriteCapacityUnits

+ const DeleteTreeTimeoutSeconds

+ const StoreName

+ 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")

+ type Config struct

+ Bucket string

+ Region *string

+ type Store struct

+ func New(_ context.Context, endpoints []string, options *Config) (*Store, error)

+ func (ddb *Store) AtomicDelete(ctx context.Context, key string, previous *store.KVPair) (bool, error)

+ func (ddb *Store) AtomicPut(ctx context.Context, key string, value []byte, previous *store.KVPair, ...) (bool, *store.KVPair, error)

+ func (ddb *Store) Close() error

+ func (ddb *Store) Delete(ctx context.Context, key string) error

+ func (ddb *Store) DeleteTree(ctx context.Context, keyPrefix string) error

+ func (ddb *Store) Exists(ctx context.Context, key string, _ *store.ReadOptions) (bool, error)

+ func (ddb *Store) Get(ctx context.Context, key string, opts *store.ReadOptions) (*store.KVPair, error)

+ func (ddb *Store) List(ctx context.Context, directory string, opts *store.ReadOptions) ([]*store.KVPair, error)

+ func (ddb *Store) NewLock(_ context.Context, key string, opts *store.LockOptions) (store.Locker, error)

+ func (ddb *Store) Put(ctx context.Context, key string, value []byte, opts *store.WriteOptions) error

+ func (ddb *Store) Watch(_ context.Context, _ string, _ *store.ReadOptions) (<-chan *store.KVPair, error)

+ func (ddb *Store) WatchTree(_ context.Context, _ string, _ *store.ReadOptions) (<-chan []*store.KVPair, error)