dynastorev2

package module

Go to main page

Versions in this module

v0

v0.6.0

Feb 15, 2025

Changes in this version

type Store

+ func (t *Store[P, S, V]) ReadWithReverseSortResults(reverseSortResults bool) ReadOption[P, S]

v0.5.0

Jan 21, 2025

Changes in this version

type Store

+ func (t *Store[P, S, V]) ReadWithIndex(name, partKey, sortKey string) ReadOption[P, S]

v0.4.0

Jan 10, 2025

Changes in this version

+ func ApplyDeleteOptions[P Key, S Key](v *DeleteOptions[P, S], opts ...DeleteOption[P, S])

+ func ApplyReadOptions[P Key, S Key](v *ReadOptions[P, S], opts ...ReadOption[P, S])

+ func ApplyStoreOptions[P Key, S Key, V any](v *StoreOptions[P, S, V], opts ...StoreOption[P, S, V])

+ func ApplyWriteOptions[P Key, S Key, V any](v *WriteOptions[P, S, V], opts ...WriteOption[P, S, V])

type DeleteOption

+ Apply func(opts *DeleteOptions[P, S])

+ type DeleteOptions struct

type ReadOption

+ Apply func(opts *ReadOptions[P, S])

+ type ReadOptionFunc func(*ReadOptions[P, S])

+ func (fn ReadOptionFunc[P, S]) Apply(opts *ReadOptions[P, S])

+ type ReadOptions struct

type StoreOption

+ Apply func(opts *StoreOptions[P, S, V])

+ type StoreOptionFunc func(*StoreOptions[P, S, V])

+ func (fn StoreOptionFunc[P, S, V]) Apply(opts *StoreOptions[P, S, V])

+ type StoreOptions struct

type WriteOption

+ Apply func(opts *WriteOptions[P, S, V])

+ type WriteOptionFunc func(*WriteOptions[P, S, V])

+ func (fn WriteOptionFunc[P, S, V]) Apply(opts *WriteOptions[P, S, V])

+ type WriteOptions struct

v0.3.0

Apr 19, 2022

Changes in this version

+ var ErrKeyNotExists = errors.New(...)

v0.2.0

Apr 18, 2022

Changes in this version

type Store

+ func (t *Store[P, S, V]) WriteWithCreateConstraintDisabled(createConstraintDisabled bool) WriteOption[P, S, V]

v0.1.0

Apr 10, 2022

Changes in this version

+ const DefaultExpiresAttribute

+ const DefaultPartitionKeyAttribute

+ const DefaultPayloadAttribute

+ const DefaultSortKeyAttribute

+ const DefaultVersionAttribute

+ var ErrDeleteFailedKeyNotExists = errors.New(...)

+ var ErrReservedField = errors.New(...)

+ type DeleteOption interface

+ type Key interface

+ type OperationDetails struct

+ Name string

+ PartitionKey string

+ SortKey string

+ func OperationDetailsFromContext(ctx context.Context) *OperationDetails

+ type OperationResult struct

+ ConsumedCapacity *types.ConsumedCapacity

+ LastEvaluatedKey string

+ Version int64

+ type ReadOption interface

+ type Store struct

+ func New(client *dynamodb.Client, tableName string, options ...StoreOption[P, S, V]) *Store[P, S, V]

+ func (t *Store[P, S, V]) Create(ctx context.Context, partitionKey P, sortKey S, value V, ...) (*OperationResult, error)

+ func (t *Store[P, S, V]) Delete(ctx context.Context, partitionKey P, sortKey S, options ...DeleteOption[P, S]) error

+ func (t *Store[P, S, V]) DeleteWithCheck(enabled bool) DeleteOption[P, S]

+ func (t *Store[P, S, V]) Get(ctx context.Context, partitionKey P, sortKey S, options ...ReadOption[P, S]) (*OperationResult, V, error)

+ func (t *Store[P, S, V]) ListBySortKeyPrefix(ctx context.Context, partitionKey P, prefix string, ...) (*OperationResult, []V, error)

+ func (t *Store[P, S, V]) ReadWithConsistentRead(consistentRead bool) ReadOption[P, S]

+ func (t *Store[P, S, V]) ReadWithLastEvaluatedKey(lastEvaluatedKey string) ReadOption[P, S]

+ func (t *Store[P, S, V]) ReadWithLimit(limit int32) ReadOption[P, S]

+ func (t *Store[P, S, V]) Update(ctx context.Context, partitionKey P, sortKey S, value V, ...) (*OperationResult, error)

+ func (t *Store[P, S, V]) WriteWithExtraFields(extraFields map[string]any) WriteOption[P, S, V]

+ func (t *Store[P, S, V]) WriteWithTTL(ttl time.Duration) WriteOption[P, S, V]

+ func (t *Store[P, S, V]) WriteWithVersion(version int64) WriteOption[P, S, V]

+ type StoreHooks struct

+ RequestBuilt func(ctx context.Context, pk P, sk S, params any) context.Context

+ ResponseReceived func(ctx context.Context, pk P, sk S, params any) context.Context

+ type StoreOption interface

+ func WithStoreHooks(storeHooks *StoreHooks[P, S, V]) StoreOption[P, S, V]

+ type WriteOption interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL