Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MaxDynamoRetries = 3 MaxBatchGetSize = 100 MaxBatchWriteSize = 25 )
Functions ¶
func MarshallIds ¶
func MarshallIds(idKey string, ids []*string) []map[string]*dynamodb.AttributeValue
func TableExists ¶
Types ¶
type Client ¶
type Client interface {
PutItemInTable(cc call.Call, tableName string, item interface{}, retriesLeft int) (err error)
UpdateItemInTable(cc call.Call, tableName, keyName, keyValue, updateExpression, conditionalExpression string, attributeNames map[string]*string, key, attributeValues map[string]*dynamodb.AttributeValue, retriesLeft int) (err error)
GetItemFromTable(cc call.Call, tableName, keyName, keyValue string, key map[string]*dynamodb.AttributeValue, resultInterface interface{}, retriesLeft int) (err error)
}
type Service ¶
type Service struct {
Client
Svc dynamodbiface.DynamoDBAPI
}
func InitDynamo ¶
func (*Service) GetItemFromTable ¶
func (s *Service) GetItemFromTable( cc call.Call, tableName, keyName, keyValue string, key map[string]*dynamodb.AttributeValue, resultInterface interface{}, retriesLeft int, ) (err error)
GetItemFromTable handles adding an item to dynamo
func (*Service) PutItemInTable ¶
func (s *Service) PutItemInTable(cc call.Call, tableName string, item interface{}, retriesLeft int) (err error)
PutItemInTable handles adding an item to dynamo
func (*Service) UpdateItemInTable ¶
func (s *Service) UpdateItemInTable( cc call.Call, tableName, keyName, keyValue, updateExpression, conditionalExpression string, attributeNames map[string]*string, key, attributeValues map[string]*dynamodb.AttributeValue, retriesLeft int, ) (err error)
UpdateItemInTable handles adding an item to dynamo
Source Files
Click to show internal directories.
Click to hide internal directories.