dynago

package module

Go to main page

Versions in this module

v1

v1.4.3

Mar 2, 2016

v1.4.2

Feb 10, 2016

Changes in this version

type Params

+ func P(key string, value interface{}) Params

v1.4.1

Feb 4, 2016

Changes in this version

+ type BatchConsumedCapacity []ConsumedCapacity

+ func (b BatchConsumedCapacity) GetTable(tableName string) *ConsumedCapacity

type BatchGet

+ func (b BatchGet) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *BatchGet

type BatchGetResult

+ ConsumedCapacity BatchConsumedCapacity

type BatchWrite

+ func (b BatchWrite) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *BatchWrite

type BatchWriteResult

+ ConsumedCapacity BatchConsumedCapacity

+ type Capacity struct

+ CapacityUnits float64

+ type ConsumedCapacity struct

+ CapacityUnits float64

+ GlobalSecondaryIndexes map[string]*Capacity

+ LocalSecondaryIndexes map[string]*Capacity

+ Table *Capacity

+ TableName string

type DeleteItem

+ func (d DeleteItem) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *DeleteItem

type GetItem

+ func (p GetItem) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *GetItem

type MockExecutorCall

+ ReturnConsumedCapacity CapacityDetail

type PutItem

+ func (p PutItem) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *PutItem

type PutItemResult

+ ConsumedCapacity *ConsumedCapacity

type Query

+ func (q Query) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *Query

type QueryResult

+ ConsumedCapacity *ConsumedCapacity

type Scan

+ func (s Scan) ReturnConsumedCapacity(consumedCapacity CapacityDetail) *Scan

type ScanResult

+ ConsumedCapacity *ConsumedCapacity

v1.3.1

Aug 19, 2015

Changes in this version

type BatchGet

+ func (b BatchGet) ConsistentRead(table string, consistent bool) *BatchGet

type Query

+ func (q Query) ScanIndexForward(forward bool) *Query

v1.2.2

Aug 4, 2015

v1.2.1

Jul 28, 2015

Changes in this version

type AwsExecutor

+ func (e *AwsExecutor) BatchGetItem(b *BatchGet) (result *BatchGetResult, err error)

+ type BatchGet struct

+ func (b *BatchGet) Execute() (result *BatchGetResult, err error)

+ func (b BatchGet) Get(table string, keys ...Document) *BatchGet

+ func (b BatchGet) ProjectionExpression(table string, expression string, params ...Params) *BatchGet

+ type BatchGetResult struct

+ Responses map[string][]Document

+ UnprocessedKeys BatchGetTableMap

+ type BatchGetTableEntry struct

+ ConsistentRead bool

+ Keys []Document

+ ProjectionExpression string

+ type BatchGetTableMap map[string]*BatchGetTableEntry

type Client

+ func (c *Client) BatchGet() *BatchGet

type Executor

+ BatchGetItem func(*BatchGet) (*BatchGetResult, error)

type MockExecutor

+ BatchGetItemCall *MockExecutorCall

+ BatchGetItemCalled bool

+ BatchGetItemResult *BatchGetResult

+ func (e *MockExecutor) BatchGetItem(batchGet *BatchGet) (*BatchGetResult, error)

type MockExecutorCall

+ BatchGets BatchGetTableMap

v1.1.2

Jul 24, 2015

Changes in this version

type MockExecutorCall

+ Select Select

type Query

+ func (q Query) Select(value Select) *Query

type Scan

+ func (s Scan) Select(value Select) *Scan

v1.1.1

Jul 24, 2015

v1.1.0

Jul 24, 2015

Changes in this version

+ const ErrorExpiredIterator

+ const ErrorTrimmedData

v1.0.0

Jul 22, 2015

Changes in this version

+ const ErrorAuth

+ const ErrorCollectionSizeExceeded

+ const ErrorConditionFailed

+ const ErrorInternalFailure

+ const ErrorInvalidParameter

+ const ErrorNotFound

+ const ErrorResourceInUse

+ const ErrorServiceUnavailable

+ const ErrorThrottling

+ const ErrorThroughputExceeded

+ const ErrorUnknown

+ var DebugFunc func(format string, v ...interface{})

+ type AwsExecutor struct

+ Requester AwsRequester

+ func (e *AwsExecutor) BatchWriteItem(b *BatchWrite) (result *BatchWriteResult, err error)

+ func (e *AwsExecutor) DeleteItem(d *DeleteItem) (res *DeleteItemResult, err error)

+ func (e *AwsExecutor) GetItem(g *GetItem) (result *GetItemResult, err error)

+ func (e *AwsExecutor) MakeRequestUnmarshal(method string, document interface{}, dest interface{}) (err error)

+ func (e *AwsExecutor) PutItem(p *PutItem) (res *PutItemResult, err error)

+ func (e *AwsExecutor) Query(q *Query) (result *QueryResult, err error)

+ func (e *AwsExecutor) Scan(s *Scan) (result *ScanResult, err error)

+ func (e *AwsExecutor) SchemaExecutor() SchemaExecutor

+ func (e *AwsExecutor) UpdateItem(u *UpdateItem) (result *UpdateItemResult, err error)

+ type AwsRequester interface

+ MakeRequest func(target string, body []byte) ([]byte, error)

+ type BatchWrite struct

+ func (b *BatchWrite) Execute() (*BatchWriteResult, error)

+ func (b BatchWrite) Delete(table string, keys ...Document) *BatchWrite

+ func (b BatchWrite) Put(table string, items ...Document) *BatchWrite

+ type BatchWriteResult struct

+ UnprocessedItems BatchWriteTableMap

+ type BatchWriteTableEntry struct

+ DeleteRequest *batchDelete

+ PutRequest *batchPut

+ func (e *BatchWriteTableEntry) SetDelete(key Document)

+ func (e *BatchWriteTableEntry) SetPut(item Document)

+ type BatchWriteTableMap map[string][]*BatchWriteTableEntry

+ func (m BatchWriteTableMap) GetDeleteKeys(table string) (deletes []Document)

+ func (m BatchWriteTableMap) GetPuts(table string) (puts []Document)

+ type BinarySet [][]byte

+ type CapacityDetail string

+ const CapacityIndexes

+ const CapacityNone

+ const CapacityTotal

+ type Client struct

+ func NewAwsClient(region string, accessKey string, secretKey string) *Client

+ func NewClient(executor Executor) *Client

+ func (c *Client) BatchWrite() *BatchWrite

+ func (c *Client) CreateTable(req *schema.CreateRequest) (*schema.CreateResult, error)

+ func (c *Client) DeleteItem(table string, key Document) *DeleteItem

+ func (c *Client) DeleteTable(table string) (*schema.DeleteResult, error)

+ func (c *Client) DescribeTable(table string) (*schema.DescribeResponse, error)

+ func (c *Client) GetItem(table string, key Document) *GetItem

+ func (c *Client) ListTables() *ListTables

+ func (c *Client) PutItem(table string, item Document) *PutItem

+ func (c *Client) Query(table string) *Query

+ func (c *Client) Scan(table string) *Scan

+ func (c *Client) UpdateItem(table string, key Document) *UpdateItem

+ type DebugFlags uint

+ const DebugAuth

+ const DebugRequests

+ const DebugResponses

+ var Debug DebugFlags

+ func (v DebugFlags) HasFlag(flag DebugFlags) bool

+ type DeleteItem struct

+ func (d *DeleteItem) Execute() (res *DeleteItemResult, err error)

+ func (d DeleteItem) ConditionExpression(expression string, params ...Params) *DeleteItem

+ func (d DeleteItem) ReturnValues(returnValues ReturnValues) *DeleteItem

+ type DeleteItemResult struct

+ Attributes Document

+ type Document map[string]interface

+ func (d *Document) UnmarshalJSON(buf []byte) error

+ func (d Document) AsParams() (params []Param)

+ func (d Document) GetBool(key string) bool

+ func (d Document) GetList(key string) List

+ func (d Document) GetNumber(key string) Number

+ func (d Document) GetString(key string) string

+ func (d Document) GetStringSet(key string) StringSet

+ func (d Document) GetTime(key string) (t *time.Time)

+ func (d Document) MarshalJSON() ([]byte, error)

+ func HashKey(name string, value interface{}) Document

+ func HashRangeKey(hashName string, hashVal interface{}, rangeName string, rangeVal interface{}) Document

+ type Error struct

+ AmazonRawType string

+ Exception string

+ Message string

+ Request *http.Request

+ RequestBody []byte

+ Response *http.Response

+ ResponseBody []byte

+ Type codes.ErrorCode

+ func (e *Error) Error() string

+ type Executor interface

+ BatchWriteItem func(*BatchWrite) (*BatchWriteResult, error)

+ DeleteItem func(*DeleteItem) (*DeleteItemResult, error)

+ GetItem func(*GetItem) (*GetItemResult, error)

+ PutItem func(*PutItem) (*PutItemResult, error)

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

+ Scan func(*Scan) (*ScanResult, error)

+ SchemaExecutor func() SchemaExecutor

+ UpdateItem func(*UpdateItem) (*UpdateItemResult, error)

+ func NewAwsExecutor(endpoint, region, accessKey, secretKey string) Executor

+ type GetItem struct

+ func (p *GetItem) Execute() (result *GetItemResult, err error)

+ func (p GetItem) ConsistentRead(strong bool) *GetItem

+ func (p GetItem) Param(key string, value interface{}) *GetItem

+ func (p GetItem) Params(params ...Params) *GetItem

+ func (p GetItem) ProjectionExpression(expression string) *GetItem

+ type GetItemResult struct

+ ConsumedCapacity interface{}

+ Item Document

+ type List []interface

+ func (l List) AsDocumentList() ([]Document, error)

+ type ListTables struct

+ func (l *ListTables) Execute() (result *ListTablesResult, err error)

+ func (l ListTables) Limit(limit uint) *ListTables

+ type ListTablesResult struct

+ TableNames []string

+ func (r ListTablesResult) Next() *ListTables

+ type MockExecutor struct

+ BatchWriteItemCall *MockExecutorCall

+ BatchWriteItemCalled bool

+ BatchWriteItemError error

+ Calls []MockExecutorCall

+ DeleteItemCall *MockExecutorCall

+ DeleteItemCalled bool

+ DeleteItemError error

+ DeleteItemResult *DeleteItemResult

+ GetItemCall *MockExecutorCall

+ GetItemCalled bool

+ GetItemError error

+ GetItemResult *GetItemResult

+ PutItemCall *MockExecutorCall

+ PutItemCalled bool

+ PutItemError error

+ PutItemResult *PutItemResult

+ QueryCall *MockExecutorCall

+ QueryCalled bool

+ QueryError error

+ QueryResult *QueryResult

+ ScanCall *MockExecutorCall

+ ScanCalled bool

+ ScanError error

+ ScanResult *ScanResult

+ UpdateItemCall *MockExecutorCall

+ UpdateItemCalled bool

+ UpdateItemError error

+ UpdateItemResult *UpdateItemResult

+ func (e *MockExecutor) BatchWriteItem(batchWrite *BatchWrite) (*BatchWriteResult, error)

+ func (e *MockExecutor) DeleteItem(deleteItem *DeleteItem) (*DeleteItemResult, error)

+ func (e *MockExecutor) GetItem(getItem *GetItem) (*GetItemResult, error)

+ func (e *MockExecutor) PutItem(putItem *PutItem) (*PutItemResult, error)

+ func (e *MockExecutor) Query(query *Query) (*QueryResult, error)

+ func (e *MockExecutor) Scan(scan *Scan) (*ScanResult, error)

+ func (e *MockExecutor) SchemaExecutor() SchemaExecutor

+ func (e *MockExecutor) UpdateItem(update *UpdateItem) (*UpdateItemResult, error)

+ type MockExecutorCall struct

+ Ascending bool

+ BatchWrites BatchWriteTableMap

+ ConditionExpression string

+ ConsistentRead bool

+ ExclusiveStartKey Document

+ ExpressionAttributeNames map[string]string

+ ExpressionAttributeValues Document

+ FilterExpression string

+ IndexName string

+ Item Document

+ Key Document

+ KeyConditionExpression string

+ Limit uint

+ Method string

+ ProjectionExpression string

+ ReturnValues ReturnValues

+ Segment *int

+ Table string

+ TotalSegments *int

+ UpdateExpression string

+ type Number string

+ func (n Number) FloatVal() (float64, error)

+ func (n Number) Int64Val() (int64, error)

+ func (n Number) IntVal() (int, error)

+ func (n Number) Uint64Val() (uint64, error)

+ type NumberSet []string

+ type Param struct

+ Key string

+ Value interface{}

+ func (p Param) AsParams() []Param

+ type Params interface

+ AsParams func() []Param

+ type PutItem struct

+ func (p *PutItem) Execute() (res *PutItemResult, err error)

+ func (p PutItem) ConditionExpression(expression string, params ...Params) *PutItem

+ func (p PutItem) Param(key string, value interface{}) *PutItem

+ func (p PutItem) Params(params ...Params) *PutItem

+ func (p PutItem) ReturnValues(returnValues ReturnValues) *PutItem

+ type PutItemResult struct

+ Attributes Document

+ type Query struct

+ func (q *Query) Execute() (result *QueryResult, err error)

+ func (q Query) ConsistentRead(strong bool) *Query

+ func (q Query) Desc() *Query

+ func (q Query) ExclusiveStartKey(key Document) *Query

+ func (q Query) FilterExpression(expression string, params ...Params) *Query

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

+ func (q Query) KeyConditionExpression(expression string, params ...Params) *Query

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

+ func (q Query) Param(key string, value interface{}) *Query

+ func (q Query) Params(params ...Params) *Query

+ func (q Query) ProjectionExpression(expression string, params ...Params) *Query

+ type QueryResult struct

+ Count int

+ Items []Document

+ LastEvaluatedKey Document

+ ScannedCount int

+ func (qr *QueryResult) Next() (query *Query)

+ type ReturnValues string

+ const ReturnAllNew

+ const ReturnAllOld

+ const ReturnNone

+ const ReturnUpdatedNew

+ const ReturnUpdatedOld

+ type Scan struct

+ func (s *Scan) Execute() (*ScanResult, error)

+ func (s Scan) ExclusiveStartKey(key Document) *Scan

+ func (s Scan) FilterExpression(expression string, params ...Params) *Scan

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

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

+ func (s Scan) ProjectionExpression(expression string, params ...Params) *Scan

+ func (s Scan) Segment(segment, total int) *Scan

+ type ScanResult struct

+ Items []Document

+ LastEvaluatedKey Document

+ func (r *ScanResult) Next() *Scan

+ type SchemaExecutor interface

+ CreateTable func(*schema.CreateRequest) (*schema.CreateResult, error)

+ DeleteTable func(*schema.DeleteRequest) (*schema.DeleteResult, error)

+ DescribeTable func(*schema.DescribeRequest) (*schema.DescribeResponse, error)

+ ListTables func(*ListTables) (*schema.ListResponse, error)

+ type Select string

+ const SelectAllAttributes

+ const SelectAllProjected

+ const SelectCount

+ const SelectSpecificAttributes

+ type StringSet []string

+ type UpdateItem struct

+ func (u *UpdateItem) Execute() (res *UpdateItemResult, err error)

+ func (u UpdateItem) ConditionExpression(expression string, params ...Params) *UpdateItem

+ func (u UpdateItem) Param(key string, value interface{}) *UpdateItem

+ func (u UpdateItem) Params(params ...Params) *UpdateItem

+ func (u UpdateItem) ReturnValues(returnValues ReturnValues) *UpdateItem

+ func (u UpdateItem) UpdateExpression(expression string, params ...Params) *UpdateItem

+ type UpdateItemResult struct

+ Attributes Document

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