dynamo

package module

Go to main page

Versions in this module

v1

v1.2.3

May 8, 2019

v1.2.2

May 6, 2019

Changes in this version

type BatchGet

+ func (bg *BatchGet) AllWithContext(ctx aws.Context, out interface{}) error

+ type ConditionCheck struct

+ func (check *ConditionCheck) If(expr string, args ...interface{}) *ConditionCheck

+ func (check *ConditionCheck) IfExists() *ConditionCheck

+ func (check *ConditionCheck) IfNotExists() *ConditionCheck

+ func (check *ConditionCheck) Range(rangeKey string, value interface{}) *ConditionCheck

type ConsumedCapacity

+ Read float64

+ Write float64

type CreateTable

+ func (ct *CreateTable) OnDemand(enabled bool) *CreateTable

type DB

+ func (db *DB) GetTx() *GetTx

+ func (db *DB) WriteTx() *WriteTx

type Description

+ OnDemand bool

+ type GetTx struct

+ func (tx *GetTx) All(out interface{}) error

+ func (tx *GetTx) AllWithContext(ctx aws.Context, out interface{}) error

+ func (tx *GetTx) ConsumedCapacity(cc *ConsumedCapacity) *GetTx

+ func (tx *GetTx) Get(q *Query) *GetTx

+ func (tx *GetTx) GetOne(q *Query, out interface{}) *GetTx

+ func (tx *GetTx) Run() error

+ func (tx *GetTx) RunWithContext(ctx aws.Context) error

type Table

+ func (table Table) Check(hashKey string, value interface{}) *ConditionCheck

type UpdateTable

+ func (ut *UpdateTable) OnDemand(enabled bool) *UpdateTable

+ type WriteTx struct

+ func (tx *WriteTx) Check(check *ConditionCheck) *WriteTx

+ func (tx *WriteTx) ConsumedCapacity(cc *ConsumedCapacity) *WriteTx

+ func (tx *WriteTx) Delete(d *Delete) *WriteTx

+ func (tx *WriteTx) Idempotent(enabled bool) *WriteTx

+ func (tx *WriteTx) Put(p *Put) *WriteTx

+ func (tx *WriteTx) Run() error

+ func (tx *WriteTx) RunWithContext(ctx aws.Context) error

+ func (tx *WriteTx) Update(u *Update) *WriteTx

v1.0.0

Mar 31, 2018

Changes in this version

+ const ActiveStatus

+ const BeginsWith

+ const Between

+ const BinaryType

+ const CreatingStatus

+ const DeletingStatus

+ const Equal

+ const Greater

+ const GreaterOrEqual

+ const Less

+ const LessOrEqual

+ const NoneType

+ const NotEqual

+ const NumberType

+ const StringType

+ const UpdatingStatus

+ var ErrNotFound = errors.New("dynamo: no item found")

+ var ErrTooMany = errors.New("dynamo: too many items")

+ var RetryTimeout = 1 * time.Minute

+ func Marshal(v interface{}) (*dynamodb.AttributeValue, error)

+ func MarshalItem(v interface{}) (map[string]*dynamodb.AttributeValue, error)

+ func Unmarshal(av *dynamodb.AttributeValue, out interface{}) error

+ func UnmarshalItem(item map[string]*dynamodb.AttributeValue, out interface{}) error

+ type Batch struct

+ func (b Batch) Get(keys ...Keyed) *BatchGet

+ func (b Batch) Write() *BatchWrite

+ type BatchGet struct

+ func (bg *BatchGet) All(out interface{}) error

+ func (bg *BatchGet) And(keys ...Keyed) *BatchGet

+ func (bg *BatchGet) Consistent(on bool) *BatchGet

+ func (bg *BatchGet) ConsumedCapacity(cc *ConsumedCapacity) *BatchGet

+ func (bg *BatchGet) Iter() Iter

+ type BatchWrite struct

+ func (bw *BatchWrite) ConsumedCapacity(cc *ConsumedCapacity) *BatchWrite

+ func (bw *BatchWrite) Delete(keys ...Keyed) *BatchWrite

+ func (bw *BatchWrite) Put(items ...interface{}) *BatchWrite

+ func (bw *BatchWrite) Run() (wrote int, err error)

+ func (bw *BatchWrite) RunWithContext(ctx aws.Context) (wrote int, err error)

+ type Coder interface

+ func AWSEncoding(v interface{}) Coder

+ type ConsumedCapacity struct

+ GSI map[string]float64

+ LSI map[string]float64

+ Table float64

+ TableName string

+ Total float64

+ type CreateTable struct

+ func (ct *CreateTable) Index(index Index) *CreateTable

+ func (ct *CreateTable) Project(index string, projection IndexProjection, includeAttribs ...string) *CreateTable

+ func (ct *CreateTable) Provision(readUnits, writeUnits int64) *CreateTable

+ func (ct *CreateTable) ProvisionIndex(index string, readUnits, writeUnits int64) *CreateTable

+ func (ct *CreateTable) Run() error

+ func (ct *CreateTable) RunWithContext(ctx aws.Context) error

+ func (ct *CreateTable) Stream(view StreamView) *CreateTable

+ type DB struct

+ func New(p client.ConfigProvider, cfgs ...*aws.Config) *DB

+ func NewFromIface(client dynamodbiface.DynamoDBAPI) *DB

+ func (db *DB) Client() dynamodbiface.DynamoDBAPI

+ func (db *DB) CreateTable(name string, from interface{}) *CreateTable

+ func (db *DB) ListTables() *ListTables

+ func (db *DB) Table(name string) Table

+ type Delete struct

+ func (d *Delete) ConsumedCapacity(cc *ConsumedCapacity) *Delete

+ func (d *Delete) If(expr string, args ...interface{}) *Delete

+ func (d *Delete) OldValue(out interface{}) error

+ func (d *Delete) OldValueWithContext(ctx aws.Context, out interface{}) error

+ func (d *Delete) Range(name string, value interface{}) *Delete

+ func (d *Delete) Run() error

+ func (d *Delete) RunWithContext(ctx aws.Context) error

+ type DeleteTable struct

+ func (dt *DeleteTable) Run() error

+ func (dt *DeleteTable) RunWithContext(ctx aws.Context) error

+ type DescribeTable struct

+ func (dt *DescribeTable) Run() (Description, error)

+ func (dt *DescribeTable) RunWithContext(ctx aws.Context) (Description, error)

+ type Description struct

+ ARN string

+ Created time.Time

+ GSI []Index

+ HashKey string

+ HashKeyType KeyType

+ Items int64

+ LSI []Index

+ LatestStreamARN string

+ LatestStreamLabel string

+ Name string

+ RangeKey string

+ RangeKeyType KeyType

+ Size int64

+ Status Status

+ StreamEnabled bool

+ StreamView StreamView

+ Throughput Throughput

+ func (d Description) Active() bool

+ type Index struct

+ ARN string

+ Backfilling bool

+ HashKey string

+ HashKeyType KeyType

+ Items int64

+ Local bool

+ Name string

+ ProjectionAttribs []string

+ ProjectionType IndexProjection

+ RangeKey string

+ RangeKeyType KeyType

+ Size int64

+ Status Status

+ Throughput Throughput

+ type IndexProjection string

+ var AllProjection IndexProjection = dynamodb.ProjectionTypeAll

+ var IncludeProjection IndexProjection = dynamodb.ProjectionTypeInclude

+ var KeysOnlyProjection IndexProjection = dynamodb.ProjectionTypeKeysOnly

+ type Iter interface

+ Err func() error

+ Next func(out interface{}) bool

+ NextWithContext func(ctx aws.Context, out interface{}) bool

+ type KeyType string

+ type Keyed interface

+ HashKey func() interface{}

+ RangeKey func() interface{}

+ type Keys [2]interface

+ func (k Keys) HashKey() interface{}

+ func (k Keys) RangeKey() interface{}

+ type ListTables struct

+ func (lt *ListTables) All() ([]string, error)

+ func (lt *ListTables) AllWithContext(ctx aws.Context) ([]string, error)

+ func (lt *ListTables) Iter() Iter

+ type Marshaler interface

+ MarshalDynamo func() (*dynamodb.AttributeValue, error)

+ type Operator string

+ type Order bool

+ const Ascending

+ const Descending

+ type PagingIter interface

+ LastEvaluatedKey func() PagingKey

+ type PagingKey map[string]*dynamodb.AttributeValue

+ type Put struct

+ func (p *Put) ConsumedCapacity(cc *ConsumedCapacity) *Put

+ func (p *Put) If(expr string, args ...interface{}) *Put

+ func (p *Put) OldValue(out interface{}) error

+ func (p *Put) OldValueWithContext(ctx aws.Context, out interface{}) error

+ func (p *Put) Run() error

+ func (p *Put) RunWithContext(ctx aws.Context) error

+ type Query struct

+ func (q *Query) All(out interface{}) error

+ func (q *Query) AllWithContext(ctx aws.Context, out interface{}) error

+ func (q *Query) AllWithLastEvaluatedKey(out interface{}) (PagingKey, error)

+ func (q *Query) AllWithLastEvaluatedKeyContext(ctx aws.Context, out interface{}) (PagingKey, error)

+ func (q *Query) Consistent(on bool) *Query

+ func (q *Query) ConsumedCapacity(cc *ConsumedCapacity) *Query

+ func (q *Query) Count() (int64, error)

+ func (q *Query) CountWithContext(ctx aws.Context) (int64, error)

+ func (q *Query) Filter(expr string, args ...interface{}) *Query

+ func (q *Query) Index(name string) *Query

+ func (q *Query) Iter() PagingIter

+ func (q *Query) Limit(limit int64) *Query

+ func (q *Query) One(out interface{}) error

+ func (q *Query) OneWithContext(ctx aws.Context, out interface{}) error

+ func (q *Query) Order(order Order) *Query

+ func (q *Query) Project(paths ...string) *Query

+ func (q *Query) ProjectExpr(expr string, args ...interface{}) *Query

+ func (q *Query) Range(name string, op Operator, values ...interface{}) *Query

+ func (q *Query) SearchLimit(limit int64) *Query

+ func (q *Query) StartFrom(key PagingKey) *Query

+ type Scan struct

+ func (s *Scan) All(out interface{}) error

+ func (s *Scan) AllWithContext(ctx aws.Context, out interface{}) error

+ func (s *Scan) AllWithLastEvaluatedKey(out interface{}) (PagingKey, error)

+ func (s *Scan) AllWithLastEvaluatedKeyContext(ctx aws.Context, out interface{}) (PagingKey, error)

+ func (s *Scan) Consistent(on bool) *Scan

+ func (s *Scan) ConsumedCapacity(cc *ConsumedCapacity) *Scan

+ func (s *Scan) Filter(expr string, args ...interface{}) *Scan

+ func (s *Scan) Index(name string) *Scan

+ func (s *Scan) Iter() PagingIter

+ func (s *Scan) Limit(limit int64) *Scan

+ func (s *Scan) Project(paths ...string) *Scan

+ func (s *Scan) SearchLimit(limit int64) *Scan

+ func (s *Scan) StartFrom(key PagingKey) *Scan

+ type Status string

+ type StreamView string

+ var KeysOnlyView StreamView = dynamodb.StreamViewTypeKeysOnly

+ var NewAndOldImagesView StreamView = dynamodb.StreamViewTypeNewAndOldImages

+ var NewImageView StreamView = dynamodb.StreamViewTypeNewImage

+ var OldImageView StreamView = dynamodb.StreamViewTypeOldImage

+ type Table struct

+ func (table Table) Batch(hashAndRangeKeyName ...string) Batch

+ func (table Table) Delete(name string, value interface{}) *Delete

+ func (table Table) DeleteTable() *DeleteTable

+ func (table Table) Describe() *DescribeTable

+ func (table Table) Get(name string, value interface{}) *Query

+ func (table Table) Name() string

+ func (table Table) Put(item interface{}) *Put

+ func (table Table) Scan() *Scan

+ func (table Table) Update(hashKey string, value interface{}) *Update

+ func (table Table) UpdateTable() *UpdateTable

+ type Throughput struct

+ DecsToday int64

+ LastDec time.Time

+ LastInc time.Time

+ Read int64

+ Write int64

+ type Unmarshaler interface

+ UnmarshalDynamo func(av *dynamodb.AttributeValue) error

+ type Update struct

+ func (u *Update) Add(path string, value interface{}) *Update

+ func (u *Update) AddFloatsToSet(path string, values ...float64) *Update

+ func (u *Update) AddIntsToSet(path string, values ...int) *Update

+ func (u *Update) AddStringsToSet(path string, values ...string) *Update

+ func (u *Update) Append(path string, value interface{}) *Update

+ func (u *Update) ConsumedCapacity(cc *ConsumedCapacity) *Update

+ func (u *Update) DeleteFloatsFromSet(path string, values ...float64) *Update

+ func (u *Update) DeleteIntsFromSet(path string, values ...int) *Update

+ func (u *Update) DeleteStringsFromSet(path string, values ...string) *Update

+ func (u *Update) If(expr string, args ...interface{}) *Update

+ func (u *Update) OldValue(out interface{}) error

+ func (u *Update) OldValueWithContext(ctx aws.Context, out interface{}) error

+ func (u *Update) Prepend(path string, value interface{}) *Update

+ func (u *Update) Range(name string, value interface{}) *Update

+ func (u *Update) Remove(paths ...string) *Update

+ func (u *Update) RemoveExpr(expr string, args ...interface{}) *Update

+ func (u *Update) Run() error

+ func (u *Update) RunWithContext(ctx aws.Context) error

+ func (u *Update) Set(path string, value interface{}) *Update

+ func (u *Update) SetExpr(expr string, args ...interface{}) *Update

+ func (u *Update) SetIfNotExists(path string, value interface{}) *Update

+ func (u *Update) SetSet(path string, value interface{}) *Update

+ func (u *Update) Value(out interface{}) error

+ func (u *Update) ValueWithContext(ctx aws.Context, out interface{}) error

+ type UpdateTable struct

+ func (ut *UpdateTable) CreateIndex(index Index) *UpdateTable

+ func (ut *UpdateTable) DeleteIndex(name string) *UpdateTable

+ func (ut *UpdateTable) DisableStream() *UpdateTable

+ func (ut *UpdateTable) Provision(read, write int64) *UpdateTable

+ func (ut *UpdateTable) ProvisionIndex(name string, read, write int64) *UpdateTable

+ func (ut *UpdateTable) Run() (Description, error)

+ func (ut *UpdateTable) RunWithContext(ctx aws.Context) (Description, error)

+ func (ut *UpdateTable) Stream(view StreamView) *UpdateTable

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