ddb

Nov 24, 2024

Changes in this version

type DynamoDB

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

type Storage

+ func (db *Storage[T]) BatchPut(ctx context.Context, entities []T, opts ...interface{ WriterOpt(T) }) ([]T, error)

+ func (db *Storage[T]) BatchRemove(ctx context.Context, keys []T, opts ...interface{ WriterOpt(T) }) ([]T, error)

Nov 24, 2024

Changes in this version

+ func AllOf[T any](seq ...interface{ WriterOpt(T) }) interface

+ func OneOf[T any](seq ...interface{ WriterOpt(T) }) interface

type ConditionExpression

+ func (ce ConditionExpression[T, A]) Optimistic(val A) interface{ ... }

Nov 23, 2024

Changes in this version

+ var WithConfig = opts.FMap(optsFromConfig)

+ var WithDefaultDDB = opts.From(optsDefaultDDB)

+ var WithDynamoDB = opts.ForType[Options, DynamoDB]()

Jul 13, 2023

Changes in this version

+ func Decode(av types.AttributeValue, val interface{}, coder ...Coder) (err error)

+ func Encode(val interface{}, coder ...Coder) (types.AttributeValue, error)

+ type CodecOf interface

+ Decode func(*A) Coder

+ Encode func(A) Coder

+ func Codec(a string) CodecOf[T, A]

+ type Coder func(map[string]types.AttributeValue) (map[string]types.AttributeValue, error)

+ type ConditionExpression struct

+ func ClauseFor(attr ...string) ConditionExpression[T, A]

+ func (ce ConditionExpression[T, A]) Between(a, b A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Contains(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Eq(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Exists() interface{ ... }

+ func (ce ConditionExpression[T, A]) Ge(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Gt(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) HasPrefix(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) In(seq ...A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Is(val string) interface{ ... }

+ func (ce ConditionExpression[T, A]) Le(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Lt(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) Ne(val A) interface{ ... }

+ func (ce ConditionExpression[T, A]) NotExists() interface{ ... }

+ type DynamoDB interface

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

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

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

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

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

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

+ type Option func(*Options)

+ func WithGlobalSecondaryIndex(index string) Option

+ func WithHashKey(hashKey string) Option

+ func WithPrefixes(prefixes curie.Prefixes) Option

+ func WithService(service DynamoDB) Option

+ func WithSortKey(sortKey string) Option

+ func WithStrictType(strict bool) Option

+ func WithTable(table string) Option

+ type Options struct

+ type Storage struct

+ func Must(keyval *Storage[T], err error) *Storage[T]

+ func New(opts ...Option) (*Storage[T], error)

+ func (db *Storage[T]) BatchGet(ctx context.Context, keys []T, opts ...interface{ GetterOpt(T) }) ([]T, error)

+ func (db *Storage[T]) Get(ctx context.Context, key T, opts ...interface{ GetterOpt(T) }) (T, error)

+ func (db *Storage[T]) Match(ctx context.Context, key T, opts ...interface{ MatcherOpt(T) }) ([]T, interface{ ... }, error)

+ func (db *Storage[T]) MatchKey(ctx context.Context, key dynamo.Thing, opts ...interface{ MatcherOpt(T) }) ([]T, interface{ ... }, error)

+ func (db *Storage[T]) Put(ctx context.Context, entity T, opts ...interface{ WriterOpt(T) }) error

+ func (db *Storage[T]) Remove(ctx context.Context, key T, opts ...interface{ WriterOpt(T) }) (T, error)

+ func (db *Storage[T]) Update(ctx context.Context, entity T, opts ...interface{ WriterOpt(T) }) (T, error)

+ func (db *Storage[T]) UpdateWith(ctx context.Context, expression UpdateItemExpression[T], ...) (T, error)

+ type UpdateExpression struct

+ func UpdateFor(attr ...string) UpdateExpression[T, A]

+ func (ue UpdateExpression[T, A]) Add(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Append(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Dec(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Inc(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Minus(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Prepend(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Remove() interface{ ... }

+ func (ue UpdateExpression[T, A]) Set(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) SetNotExists(val A) interface{ ... }

+ func (ue UpdateExpression[T, A]) Union(val A) interface{ ... }

+ type UpdateItemExpression struct

+ func Updater(entity T, opts ...interface{ UpdateExpression(T) }) UpdateItemExpression[T]