dynamodb

Documentation

Index

• func ConvertEventsAttributeValue(v events.DynamoDBAttributeValue) *dynamodb.AttributeValue
• func ConvertEventsAttributeValueMap(m map[string]events.DynamoDBAttributeValue) map[string]*dynamodb.AttributeValue
• func New(cfg iaws.Config) *dynamodb.DynamoDB
• type API
  • func (a *API) BatchPutItem(ctx aws.Context, table string, items []map[string]*dynamodb.AttributeValue) (resp *dynamodb.BatchWriteItemOutput, err error)
  • func (a *API) DeleteItem(ctx aws.Context, table string, key map[string]*dynamodb.AttributeValue) (resp *dynamodb.DeleteItemOutput, err error)
  • func (a *API) GetItem(ctx aws.Context, table string, attributes map[string]interface{}, ...) (resp *dynamodb.GetItemOutput, err error)
  • func (a *API) IsEnabled() bool
  • func (a *API) PutItem(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue) (resp *dynamodb.PutItemOutput, err error)
  • func (a *API) PutItemWithCondition(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue, ...) (resp *dynamodb.PutItemOutput, err error)
  • func (a *API) Query(ctx aws.Context, table, partitionKey, sortKey, keyConditionExpression string, ...) (resp *dynamodb.QueryOutput, err error)
  • func (a *API) Setup(cfg iaws.Config)
  • func (a *API) UpdateItem(ctx aws.Context, input *dynamodb.UpdateItemInput) (resp *dynamodb.UpdateItemOutput, err error)

Functions

func ConvertEventsAttributeValue

func ConvertEventsAttributeValue(v events.DynamoDBAttributeValue) *dynamodb.AttributeValue

ConvertEventsAttributeValue converts events.DynamoDBAttributeValue to dynamodb.AttributeValue.

func ConvertEventsAttributeValueMap

func ConvertEventsAttributeValueMap(m map[string]events.DynamoDBAttributeValue) map[string]*dynamodb.AttributeValue

ConvertEventsAttributeValueMap converts a map of events.DynamoDBAttributeValue to a map of dynamodb.AttributeValue.

func New

func New(cfg iaws.Config) *dynamodb.DynamoDB

New returns a configured DynamoDB client.

Types

type API

type API struct {
	Client dynamodbiface.DynamoDBAPI
}

API wraps the DynamoDB API interface.

func (*API) BatchPutItem

func (a *API) BatchPutItem(ctx aws.Context, table string, items []map[string]*dynamodb.AttributeValue) (resp *dynamodb.BatchWriteItemOutput, err error)

BatchPutItem is a convenience wrapper for putting multiple items into a DynamoDB table.

func (*API) DeleteItem

func (a *API) DeleteItem(ctx aws.Context, table string, key map[string]*dynamodb.AttributeValue) (resp *dynamodb.DeleteItemOutput, err error)

func (*API) GetItem

func (a *API) GetItem(ctx aws.Context, table string, attributes map[string]interface{}, consistentRead bool) (resp *dynamodb.GetItemOutput, err error)

GetItem is a convenience wrapper for getting items into a DynamoDB table.

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled returns true if the client is enabled and ready for use.

func (*API) PutItem

func (a *API) PutItem(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue) (resp *dynamodb.PutItemOutput, err error)

PutItem is a convenience wrapper for putting items into a DynamoDB table.

func (*API) PutItemWithCondition

func (a *API) PutItemWithCondition(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue, conditionExpression string, expressionAttributeNames map[string]*string, expressionAttributeValues map[string]*dynamodb.AttributeValue) (resp *dynamodb.PutItemOutput, err error)

func (*API) Query

func (a *API) Query(ctx aws.Context, table, partitionKey, sortKey, keyConditionExpression string, limit int64, scanIndexForward bool) (resp *dynamodb.QueryOutput, err error)

Query is a convenience wrapper for querying a DynamoDB table. The paritition and sort keys are always referenced in the key condition expression as ":PK" and ":SK". Refer to the DynamoDB documentation for the Query operation's request syntax and key condition expression patterns:

- https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_Query.html#API_Query_RequestSyntax

- https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Query.html#Query.KeyConditionExpressions

func (*API) Setup

func (a *API) Setup(cfg iaws.Config)

Setup creates a new DynamoDB client.

func (*API) UpdateItem

func (a *API) UpdateItem(ctx aws.Context, input *dynamodb.UpdateItemInput) (resp *dynamodb.UpdateItemOutput, err error)

UpdateItem