dynamodb

package

Go to main page

Versions in this module

v1

v1.3.0

Mar 20, 2018

Changes in this version

type Table

+ func NewTableWithDesign(svc *DynamoDB, design *TableDesign) (*Table, error)

+ func NewTableWithoutDesign(svc *DynamoDB, name string) *Table

+ func (t *Table) GetDesign() *TableDesign

+ func (t *Table) RefreshDesign() (*TableDesign, error)

+ func (t *Table) SetDesign(design *TableDesign)

v1.2.4

Mar 1, 2018

v1.2.3

Feb 7, 2018

Changes in this version

type ConditionList

+ func (c *ConditionList) SetDesc(b bool)

v1.2.2

Nov 16, 2017

v1.2.1

Nov 16, 2017

v1.2.0

Nov 14, 2017

v1.1.2

Sep 25, 2017

v1.1.1

Aug 9, 2017

v1.1.0

Aug 7, 2017

v1.0.4

Jul 5, 2017

v1.0.3

Dec 15, 2016

v1.0.2

Nov 18, 2016

v1.0.1

Nov 10, 2016

v1.0.0

Oct 26, 2016

Changes in this version

+ func UnmarshalAttributeValue(item map[string]*SDK.AttributeValue) map[string]interface

+ type Condition struct

+ Condition string

+ Key string

+ OR bool

+ SubValue interface{}

+ Value interface{}

+ type ConditionList struct

+ func NewConditionList(keyAttributes map[string]string) *ConditionList

+ func (c *ConditionList) AndBETWEEN(key string, from, to interface{})

+ func (c *ConditionList) AndEQ(key string, val interface{})

+ func (c *ConditionList) AndGE(key string, val interface{})

+ func (c *ConditionList) AndGT(key string, val interface{})

+ func (c *ConditionList) AndLE(key string, val interface{})

+ func (c *ConditionList) AndLT(key string, val interface{})

+ func (c *ConditionList) FilterBETWEEN(key string, from, to interface{})

+ func (c *ConditionList) FilterEQ(key string, val interface{})

+ func (c *ConditionList) FilterGE(key string, val interface{})

+ func (c *ConditionList) FilterGT(key string, val interface{})

+ func (c *ConditionList) FilterLE(key string, val interface{})

+ func (c *ConditionList) FilterLT(key string, val interface{})

+ func (c *ConditionList) FormatCondition() *string

+ func (c *ConditionList) FormatFilter() *string

+ func (c *ConditionList) FormatNames() map[string]*string

+ func (c *ConditionList) FormatValues() map[string]*SDK.AttributeValue

+ func (c *ConditionList) HasCondition() bool

+ func (c *ConditionList) HasFilter() bool

+ func (c *ConditionList) HasIndex() bool

+ func (c *ConditionList) HasLimit() bool

+ func (c *ConditionList) SetConsistent(b bool)

+ func (c *ConditionList) SetIndex(v string)

+ func (c *ConditionList) SetLimit(i int64)

+ func (c *ConditionList) SetStartKey(startKey map[string]*SDK.AttributeValue)

+ type DynamoDB struct

+ func New(conf config.Config) (*DynamoDB, error)

+ func (svc *DynamoDB) CreateTable(design *TableDesign) error

+ func (svc *DynamoDB) DoQuery(in *SDK.QueryInput) (*QueryResult, error)

+ func (svc *DynamoDB) Errorf(format string, v ...interface{})

+ func (svc *DynamoDB) ForceDeleteTable(name string) error

+ func (svc *DynamoDB) GetTable(name string) (*Table, error)

+ func (svc *DynamoDB) Infof(format string, v ...interface{})

+ func (svc *DynamoDB) ListTables() ([]string, error)

+ func (svc *DynamoDB) PutAll() error

+ func (svc *DynamoDB) SetLogger(logger log.Logger)

+ type PutItem struct

+ func NewPutItem() *PutItem

+ func (item *PutItem) AddAttribute(name string, value interface{})

+ func (item *PutItem) AddConditionEQ(name string, value interface{})

+ func (item *PutItem) AddConditionExist(name string)

+ func (item *PutItem) AddConditionGE(name string, value interface{})

+ func (item *PutItem) AddConditionGT(name string, value interface{})

+ func (item *PutItem) AddConditionLE(name string, value interface{})

+ func (item *PutItem) AddConditionLT(name string, value interface{})

+ func (item *PutItem) AddConditionNE(name string, value interface{})

+ func (item *PutItem) AddConditionNotExist(name string)

+ func (item *PutItem) CountDown(name string, num int)

+ func (item *PutItem) CountUp(name string, num int)

+ func (item *PutItem) GetAttribute(name string) interface{}

type QueryResult

+ func (r QueryResult) Unmarshal(v interface{}) error

+ type Table struct

+ func NewTable(svc *DynamoDB, name string) (*Table, error)

+ func (t *Table) AddItem(item *PutItem)

+ func (t *Table) Count(cond *ConditionList) (*QueryResult, error)

+ func (t *Table) Delete(hashValue interface{}, rangeValue ...interface{}) error

+ func (t *Table) Design() (*TableDesign, error)

+ func (t *Table) ForceDeleteAll() error

+ func (t *Table) GetOne(hashValue interface{}, rangeValue ...interface{}) (map[string]interface{}, error)

+ func (t *Table) NewConditionList() *ConditionList

+ func (t *Table) Put() error

+ func (t *Table) Query(cond *ConditionList) (*QueryResult, error)

+ func (t *Table) Scan() (*QueryResult, error)

+ func (t *Table) ScanWithCondition(cond *ConditionList) (*QueryResult, error)

+ func (t *Table) UpdateReadThroughput(r int64) error

+ func (t *Table) UpdateThroughput(r int64, w int64) error

+ func (t *Table) UpdateWriteThroughput(w int64) error

+ type TableDesign struct

+ Attributes map[string]*SDK.AttributeDefinition

+ GSI []*SDK.GlobalSecondaryIndex

+ HashKey *SDK.KeySchemaElement

+ LSI []*SDK.LocalSecondaryIndex

+ RangeKey *SDK.KeySchemaElement

+ func NewTableDesignWithHashKeyN(tableName, keyName string) *TableDesign

+ func NewTableDesignWithHashKeyS(tableName, keyName string) *TableDesign

+ func (d *TableDesign) AddGSIN(name, hashKey string) error

+ func (d *TableDesign) AddGSINN(name, hashKey, rangeKey string) error

+ func (d *TableDesign) AddGSINS(name, hashKey, rangeKey string) error

+ func (d *TableDesign) AddGSIS(name, hashKey string) error

+ func (d *TableDesign) AddGSISN(name, hashKey, rangeKey string) error

+ func (d *TableDesign) AddGSISS(name, hashKey, rangeKey string) error

+ func (d *TableDesign) AddLSIN(name, keyName string)

+ func (d *TableDesign) AddLSIS(name, keyName string)

+ func (d *TableDesign) AddRangeKeyN(keyName string)

+ func (d *TableDesign) AddRangeKeyS(keyName string)

+ func (d *TableDesign) AttributeList() []*SDK.AttributeDefinition

+ func (d *TableDesign) CreateTableInput() *SDK.CreateTableInput

+ func (d *TableDesign) GetHashKeyName() string

+ func (d *TableDesign) GetItemCount() int64

+ func (d *TableDesign) GetKeyAttributes() map[string]string

+ func (d *TableDesign) GetName() string

+ func (d *TableDesign) GetNumberOfDecreasesToday() int64

+ func (d *TableDesign) GetRangeKeyName() string

+ func (d *TableDesign) GetReadCapacity() int64

+ func (d *TableDesign) GetStatus() string

+ func (d *TableDesign) GetWriteCapacity() int64

+ func (d *TableDesign) HasGSI() bool

+ func (d *TableDesign) HasLSI() bool

+ func (d *TableDesign) HasRangeKey() bool

+ func (d *TableDesign) IsActive() bool

+ func (d *TableDesign) ListGSI() []*SDK.GlobalSecondaryIndex

+ func (d *TableDesign) ListLSI() []*SDK.LocalSecondaryIndex

+ func (d *TableDesign) SetThroughput(r, w int64)

v0

v0.9.2

Nov 27, 2016

Changes in this version

type AmazonDynamoDB

+ func (d *AmazonDynamoDB) DeleteTableWithPrefix(name string) error

+ func (d *AmazonDynamoDB) DescribeTableWithPrefix(name string) (*TableDescription, error)

+ type CreateTableInput struct

+ Attributes map[string]*SDK.AttributeDefinition

+ GSI []*SDK.GlobalSecondaryIndex

+ HashKey *SDK.KeySchemaElement

+ LSI []*SDK.LocalSecondaryIndex

+ Name string

+ RangeKey *SDK.KeySchemaElement

+ ReadCapacity int64

+ WriteCapacity int64

+ func NewCreateTableWithHashKeyN(tableName, keyName string) *CreateTableInput

+ func NewCreateTableWithHashKeyS(tableName, keyName string) *CreateTableInput

+ func (ct *CreateTableInput) AddGSIN(name, hashKey string)

+ func (ct *CreateTableInput) AddGSINN(name, hashKey, rangeKey string)

+ func (ct *CreateTableInput) AddGSINS(name, hashKey, rangeKey string)

+ func (ct *CreateTableInput) AddGSIS(name, hashKey string)

+ func (ct *CreateTableInput) AddGSISN(name, hashKey, rangeKey string)

+ func (ct *CreateTableInput) AddGSISS(name, hashKey, rangeKey string)

+ func (ct *CreateTableInput) AddLSIN(name, keyName string)

+ func (ct *CreateTableInput) AddLSIS(name, keyName string)

+ func (ct *CreateTableInput) AddRangeKeyN(keyName string)

+ func (ct *CreateTableInput) AddRangeKeyS(keyName string)

+ func (ct *CreateTableInput) AttributeList() []*SDK.AttributeDefinition

+ func (ct *CreateTableInput) HasGSI() bool

+ func (ct *CreateTableInput) HasLSI() bool

+ func (ct *CreateTableInput) HasRangeKey() bool

+ func (ct *CreateTableInput) ListGSI() []*SDK.GlobalSecondaryIndex

+ func (ct *CreateTableInput) ListLSI() []*SDK.LocalSecondaryIndex

+ func (ct *CreateTableInput) SetThroughput(r, w int64)

+ type DynamoError struct

+ func NewError(msg string) *DynamoError

+ func NewErrorList(msgList []string) *DynamoError

+ func (e *DynamoError) AddMessage(msg string)

+ func (e *DynamoError) HasError() bool

+ func (e DynamoError) Error() string

type DynamoItem

+ func (item *DynamoItem) GetAttribute(name string) Any

type DynamoTable

+ func (t *DynamoTable) NewQuery() *Query

+ type Query struct

+ func (q *Query) AndBETWEEN(key string, from, to interface{})

+ func (q *Query) AndEQ(key string, val interface{})

+ func (q *Query) AndGE(key string, val interface{})

+ func (q *Query) AndGT(key string, val interface{})

+ func (q *Query) AndLE(key string, val interface{})

+ func (q *Query) AndLT(key string, val interface{})

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

+ func (q *Query) HasCondition() bool

+ func (q *Query) HasIndex() bool

+ func (q *Query) HasLimit() bool

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

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

+ func (q *Query) Query() (*QueryResult, error)

+ type QueryResult struct

+ Count int64

+ Items []map[string]*SDK.AttributeValue

+ LastEvaluatedKey map[string]*SDK.AttributeValue

+ ScannedCount int64

+ func (r QueryResult) ToSliceMap() []map[string]interface{}

+ type TableDescription struct

+ func (d TableDescription) GetItemCount() int64

+ func (d TableDescription) GetKeyAttributes() map[string]string

+ func (d TableDescription) GetNumberOfDecreasesToday() int64

+ func (d TableDescription) GetReadCapacityUnits() int64

+ func (d TableDescription) GetTableName() string

+ func (d TableDescription) GetTableStatus() string

+ func (d TableDescription) GetWriteCapacityUnits() int64

+ func (d TableDescription) IsActive() bool

v0.7.0

Jul 10, 2015

v0.6.6

Jul 10, 2015

Changes in this version

+ const ComparisonOperatorEQ

+ const ComparisonOperatorGE

+ const ComparisonOperatorGT

+ const ComparisonOperatorLE

+ const ComparisonOperatorLT

+ const ComparisonOperatorNE

+ const KeyTypeHash

+ const KeyTypeRange

+ const ProjectionTypeAll

+ const ProjectionTypeKeysOnly

+ func Boolean(v bool) *bool

+ func Long(v int64) *int64

+ func Marshal(item map[string]interface{}) map[string]*SDK.AttributeValue

+ func MarshalStringSlice(item Any) []*string

+ func NewAttributeDefinition(attrName, attrType string) *SDK.AttributeDefinition

+ func NewAttributeDefinitions(attr ...*SDK.AttributeDefinition) []*SDK.AttributeDefinition

+ func NewBoolAttribute(attrName string) *SDK.AttributeDefinition

+ func NewByteAttribute(attrName string) *SDK.AttributeDefinition

+ func NewCondition(value Any, operator string) SDK.Condition

+ func NewExpected() *SDK.ExpectedAttributeValue

+ func NewExpectedCondition(value Any, operator string) *SDK.ExpectedAttributeValue

+ func NewGSI(name string, schema []*SDK.KeySchemaElement, tp *SDK.ProvisionedThroughput, ...) *SDK.GlobalSecondaryIndex

+ func NewHashKeyElement(keyName string) *SDK.KeySchemaElement

+ func NewKeyElement(keyName, keyType string) *SDK.KeySchemaElement

+ func NewKeySchema(elements ...*SDK.KeySchemaElement) []*SDK.KeySchemaElement

+ func NewLSI(name string, schema []*SDK.KeySchemaElement, projection ...string) *SDK.LocalSecondaryIndex

+ func NewNumberAttribute(attrName string) *SDK.AttributeDefinition

+ func NewProvisionedThroughput(read, write int64) *SDK.ProvisionedThroughput

+ func NewRangeKeyElement(keyName string) *SDK.KeySchemaElement

+ func NewStringAttribute(attrName string) *SDK.AttributeDefinition

+ func String(v string) *string

+ func Unmarshal(item map[string]*SDK.AttributeValue) map[string]interface

+ type AmazonDynamoDB struct

+ TablePrefix string

+ func NewClient() *AmazonDynamoDB

+ func NewClientWithKeys(k auth.Keys) *AmazonDynamoDB

+ func (d *AmazonDynamoDB) CreateTable(in *SDK.CreateTableInput) error

+ func (d *AmazonDynamoDB) DeleteTable(name string) error

+ func (d *AmazonDynamoDB) DescribeTable(name string) (*SDK.TableDescription, error)

+ func (d *AmazonDynamoDB) GetTable(table string) (*DynamoTable, error)

+ func (d *AmazonDynamoDB) ListTables() ([]*string, error)

+ func (d *AmazonDynamoDB) PutAll() error

+ type Any interface

+ type DynamoIndex struct

+ IndexType string

+ KeySchema []*SDK.KeySchemaElement

+ Name string

+ func NewDynamoIndex(name, typ string, schema []*SDK.KeySchemaElement) *DynamoIndex

+ func (idx *DynamoIndex) GetHashKeyName() string

+ func (idx *DynamoIndex) GetRangeKeyName() string

+ type DynamoItem struct

+ func NewItem() *DynamoItem

+ func (item *DynamoItem) AddAttribute(name string, value Any)

+ func (item *DynamoItem) AddCondition(name string, condition *SDK.ExpectedAttributeValue)

+ func (item *DynamoItem) AddConditionEQ(name string, value Any)

+ func (item *DynamoItem) AddConditionExist(name string)

+ func (item *DynamoItem) AddConditionGE(name string, value Any)

+ func (item *DynamoItem) AddConditionGT(name string, value Any)

+ func (item *DynamoItem) AddConditionLE(name string, value Any)

+ func (item *DynamoItem) AddConditionLT(name string, value Any)

+ func (item *DynamoItem) AddConditionNE(name string, value Any)

+ func (item *DynamoItem) AddConditionNotExist(name string)

+ func (item *DynamoItem) CountDown(name string, num int)

+ func (item *DynamoItem) CountUp(name string, num int)

+ type DynamoTable struct

+ func (t *DynamoTable) AddItem(item *DynamoItem)

+ func (t *DynamoTable) Delete(values ...Any) error

+ func (t *DynamoTable) DeleteAll() error

+ func (t *DynamoTable) Desc() (*SDK.TableDescription, error)

+ func (t *DynamoTable) Get(values ...Any) ([]map[string]interface{}, error)

+ func (t *DynamoTable) GetByIndex(idx string, values ...Any) ([]map[string]interface{}, error)

+ func (t *DynamoTable) GetHashKeyName() string

+ func (t *DynamoTable) GetOne(values ...Any) (map[string]interface{}, error)

+ func (t *DynamoTable) GetRangeKeyName() string

+ func (t *DynamoTable) Put() error

+ func (t *DynamoTable) Query(in *SDK.QueryInput) ([]map[string]interface{}, error)

+ func (t *DynamoTable) Scan() ([]map[string]interface{}, error)

+ func (t *DynamoTable) UpdateReadThroughput(v int64) error

+ func (t *DynamoTable) UpdateThroughput(r int64, w int64) error

+ func (t *DynamoTable) UpdateWriteThroughput(v int64) error

+ type QueryCondition struct

+ func NewQueryCondition() *QueryCondition

+ func (c *QueryCondition) Add(name string, condition SDK.Condition)

+ func (c *QueryCondition) AddEQ(name string, value Any)

+ func (c *QueryCondition) AddGE(name string, value Any)

+ func (c *QueryCondition) AddGT(name string, value Any)

+ func (c *QueryCondition) AddLE(name string, value Any)

+ func (c *QueryCondition) AddLT(name string, value Any)

+ func (c *QueryCondition) AddNE(name string, value Any)

+ func (c *QueryCondition) UseIndex(name string)

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