dynamo

Jul 12, 2022

Changes in this version

type Client

+ func (c *Client) Delete(ctx context.Context, key Keyable) error

+ func (c *Client) NewDeleteInput(key map[string]types.AttributeValue, cond ...string) *dynamodb.DeleteItemInput

Jul 12, 2022

Changes in this version

type Key

+ CExpr *string

+ ENames map[string]string

+ func (k *Key) ExprAttrNames() map[string]string

Jul 12, 2022

Changes in this version

type Client

+ func NewClient(api APIBehavior, tbl Table) (*Client, error)

type Table

+ func (t Table) HashKey() string

+ func (t Table) SortKey() string

Jul 9, 2022

Changes in this version

+ const DomainKeyName

+ const HashKeyName

+ const SortKeyName

+ type APIBehavior interface

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

+ BatchWriteItem func(context.Context, *dynamodb.BatchWriteItemInput, ...func(*dynamodb.Options)) (*dynamodb.BatchWriteItemOutput, 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)

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

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

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

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

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

+ type Client struct

+ func (c *Client) Item(ctx context.Context, key Keyable) (map[string]types.AttributeValue, error)

+ func (c *Client) NewGetItemIn(k Keyable) *dynamodb.GetItemInput

+ func (c *Client) NewPutInput(item map[string]types.AttributeValue, cond ...string) *dynamodb.PutItemInput

+ func (c *Client) Put(ctx context.Context, item map[string]types.AttributeValue) error

+ func (c *Client) TableName() string

+ func (c *Client) Write(ctx context.Context, row Writable) error

+ type FormatterError interface

+ FormatForError func() string

+ type Key struct

+ ConditionExpr *string

+ Domain string

+ ExprNames map[string]string

+ Hash string

+ Sort string

+ func (k *Key) ConditionExpression() *string

+ func (k *Key) ExpressionAttrNames() map[string]string

+ func (k *Key) FormatForError() string

+ func (k *Key) Full() map[string]types.AttributeValue

+ type Keyable interface

+ ConditionExpr func() *string

+ ExprAttrNames func() map[string]string

+ Full func() map[string]types.AttributeValue

+ type Table struct

+ func NewTable(name, hash, sort string, idx map[string]string) (Table, error)

+ func (t Table) Name() string

+ type Writable interface

+ ConditionExpr func() *string

+ ExprAttrNames func() map[string]string

+ ToDBKey func() map[string]types.AttributeValue

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