dyc

package module

Go to main page

Versions in this module

v1

v1.4.0

Oct 5, 2024

Changes in this version

type Builder

+ func (s *Builder) GetClient() *Client

+ func (s *Builder) Return(val string) *Builder

v1.3.0

Apr 17, 2023

Changes in this version

type Builder

+ func (s *Builder) Ascending() *Builder

+ func (s *Builder) Cursor(cursor Map) *Builder

+ func (s *Builder) Descending() *Builder

+ func (s *Builder) PageToken() Map

+ func (s *Builder) ScanAll(ctx context.Context) (Maps, error)

+ func (s *Builder) WithPrimaryKeys(primaryKeys ...string) *Builder

type Client

+ func (c *Client) QueryIteratorV2(ctx context.Context, input *dynamodb.QueryInput, keys []string, ...) error

+ func (c *Client) ScanIteratorV2(ctx context.Context, input *dynamodb.ScanInput, keys []string, ...) error

+ type Map = map[string]*dynamodb.AttributeValue

+ type Maps = []Map

v1.2.0

Jan 22, 2022

v1.1.1

Feb 28, 2021

Changes in this version

type Builder

+ func (s *Builder) Builder() *Builder

v1.1.0

Feb 28, 2021

Changes in this version

type Builder

+ func (s *Builder) PutItem(ctx context.Context, data interface{}) (*dynamodb.PutItemOutput, error)

+ func (s *Builder) ToPut(item interface{}) (dynamodb.PutItemInput, error)

v1.0.0

Feb 27, 2021

Changes in this version

+ var ErrBadKeyParams = errors.New("expected an even amount of additionalKVs parameters")

+ var ErrBadKeyType = errors.New("strings are the only type of keys supported")

+ var ErrClientNotSet = errors.New("client not set")

+ var ErrKeyRequired = errors.New("key not set")

+ var ErrNotPointer = errors.New("provided result type is not a slice")

+ var ErrNotSlice = errors.New("provided value is not a slice")

+ var ErrQueryMisMatch = errors.New("inputs don't match query")

+ var ErrUnsupportedType = errors.New("unsupported type")

+ func Int(num int) *dynamodb.AttributeValue

+ func IntList(arr ...int) *dynamodb.AttributeValue

+ func PKSKExtractor(attrs map[string]*dynamodb.AttributeValue) map[string]*dynamodb.AttributeValue

+ func String(str string) *dynamodb.AttributeValue

+ func StringList(arr ...string) *dynamodb.AttributeValue

+ func StringSet(arr ...string) *dynamodb.AttributeValue

+ type Builder struct

+ func NewBuilder() *Builder

+ func (s *Builder) Client(client *Client) *Builder

+ func (s *Builder) Condition(query string, vals ...interface{}) *Builder

+ func (s *Builder) ConsistentRead(consistent bool) *Builder

+ func (s *Builder) DeleteItem(ctx context.Context) (*dynamodb.DeleteItemOutput, error)

+ func (s *Builder) GetItem(ctx context.Context) (*dynamodb.GetItemOutput, error)

+ func (s *Builder) IN(column string, vals ...interface{}) *Builder

+ func (s *Builder) INSlice(column string, val interface{}) *Builder

+ func (s *Builder) Index(index string) *Builder

+ func (s *Builder) Key(keyName string, value interface{}, additionalKVs ...interface{}) *Builder

+ func (s *Builder) Limit(limit int) *Builder

+ func (s *Builder) OrCondition(query string, vals ...interface{}) *Builder

+ func (s *Builder) OrIN(column string, vals ...interface{}) *Builder

+ func (s *Builder) OrINSlice(column string, val interface{}) *Builder

+ func (s *Builder) OrWhere(query string, vals ...interface{}) *Builder

+ func (s *Builder) ParallelScanIterate(ctx context.Context, workers int, fn func(output *dynamodb.ScanOutput) error, ...) error

+ func (s *Builder) QueryAll(ctx context.Context) ([]map[string]*dynamodb.AttributeValue, error)

+ func (s *Builder) QueryDelete(ctx context.Context, keyFn KeyExtractor) error

+ func (s *Builder) QueryIterate(ctx context.Context, fn func(output *dynamodb.QueryOutput) error) error

+ func (s *Builder) QuerySingle(ctx context.Context) (map[string]*dynamodb.AttributeValue, error)

+ func (s *Builder) Result(val interface{}) *Builder

+ func (s *Builder) ScanDelete(ctx context.Context, keyFn KeyExtractor) error

+ func (s *Builder) ScanIterate(ctx context.Context, fn func(output *dynamodb.ScanOutput) error) error

+ func (s *Builder) SelectFields(fields ...string) *Builder

+ func (s *Builder) Sort(ascending bool) *Builder

+ func (s *Builder) Table(tbl string) *Builder

+ func (s *Builder) ToDelete() (dynamodb.DeleteItemInput, error)

+ func (s *Builder) ToGet() (dynamodb.GetItemInput, error)

+ func (s *Builder) ToQuery() (dynamodb.QueryInput, error)

+ func (s *Builder) ToScan() (dynamodb.ScanInput, error)

+ func (s *Builder) ToUpdate() (dynamodb.UpdateItemInput, error)

+ func (s *Builder) Update(query string, vals ...interface{}) *Builder

+ func (s *Builder) UpdateItem(ctx context.Context) (*dynamodb.UpdateItemOutput, error)

+ func (s *Builder) Where(query string, vals ...interface{}) *Builder

+ func (s *Builder) WhereKey(query string, vals ...interface{}) *Builder

+ type Client struct

+ func NewClient(db *dynamodb.DynamoDB) *Client

+ func (c *Client) BatchGetIterator(ctx context.Context, input *dynamodb.BatchGetItemInput, ...) error

+ func (c *Client) BatchPut(ctx context.Context, tableName string, items ...interface{}) (int, error)

+ func (c *Client) BatchWriter(ctx context.Context, tableName string, requests ...*dynamodb.WriteRequest) (int, error)

+ func (c *Client) Builder() *Builder

+ func (c *Client) ChunkWriteRequests(requests []*dynamodb.WriteRequest) [][]*dynamodb.WriteRequest

+ func (c *Client) CopyTable(parentCtx context.Context, dst string, src string, workers int, ...) error

+ func (c *Client) ExtractFields(data map[string]*dynamodb.AttributeValue, fields ...string) map[string]*dynamodb.AttributeValue

+ func (c *Client) ParallelScanIterator(ctx context.Context, input *dynamodb.ScanInput, workers int, ...) error

+ func (c *Client) QueryDeleter(ctx context.Context, table string, input *dynamodb.QueryInput, ...) error

+ func (c *Client) QueryIterator(ctx context.Context, input *dynamodb.QueryInput, ...) error

+ func (c *Client) ScanCount(ctx context.Context, input *dynamodb.ScanInput) (int64, error)

+ func (c *Client) ScanDeleter(ctx context.Context, table string, input *dynamodb.ScanInput, ...) error

+ func (c *Client) ScanIterator(ctx context.Context, input *dynamodb.ScanInput, ...) error

+ func (c *Client) ToBatchGetItemInput(tableName string, req []map[string]*dynamodb.AttributeValue) *dynamodb.BatchGetItemInput

+ type Iterator struct

+ func NewIteratorFromQuery(ctx context.Context, cli IteratorClient, input *dynamodb.QueryInput) *Iterator

+ func NewIteratorFromScan(ctx context.Context, cli IteratorClient, input *dynamodb.ScanInput) *Iterator

+ func (i *Iterator) Err() error

+ func (i *Iterator) Next() bool

+ func (i *Iterator) QueryValue() *dynamodb.QueryOutput

+ func (i *Iterator) ScanValue() *dynamodb.ScanOutput

+ func (i *Iterator) Value() interface{}

+ type IteratorClient interface

+ QueryRequest func(input *dynamodb.QueryInput) (req *request.Request, output *dynamodb.QueryOutput)

+ ScanRequest func(input *dynamodb.ScanInput) (req *request.Request, output *dynamodb.ScanOutput)

+ type KeyExtractor func(map[string]*dynamodb.AttributeValue) map[string]*dynamodb.AttributeValue

+ func FieldsExtractor(fields ...string) KeyExtractor

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