dynamodb

Documentation

Index

• func New() *dynamodb.DynamoDB
• type API
  • 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) Query(ctx aws.Context, table, partitionKey, sortKey, keyConditionExpression string, ...) (resp *dynamodb.QueryOutput, err error)
  • func (a *API) Setup()

Functions

func New

func New() *dynamodb.DynamoDB

New creates and returns a new session connection to DynamoDB

Types

type API

type API struct {
	Client dynamodbiface.DynamoDBAPI
}

API wraps a DynamoDB client interface

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled checks whether a new client has been set

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 executing the PutItem API on DynamoDB.table

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

func (*API) Setup

func (a *API) Setup()

Setup creates a DynamoDB client and sets the DynamoDB.stream