dynamodb

Documentation

Overview

Package dynamodb contains third party interactions with aws-sdk-go/dynamodb

Index

• Constants
• func NewGetItemInput(table, keyName, keyValue string) (*dynamodb.GetItemInput, error)
• func NewPutItemInput(input interface{}, table string) (*dynamodb.PutItemInput, error)
• func NewScanInput(table, keyName string, keyValue interface{}) (*dynamodb.ScanInput, error)
• func UnmarshalGetItemOutput(input *dynamodb.GetItemOutput, out interface{}) error
• func UnmarshalScanOutput(input *dynamodb.ScanOutput, out interface{}) error
• func UnmarshalStreamImage(input events.DynamoDBEventRecord, output interface{}) error
• type DynamoDB
  • func New(svc *pkgAws.Session, endpoint string) (*DynamoDB, error)
  • func (svc *DynamoDB) DynamoGetItem(table, keyName, keyValue string) (*GetItemOutput, error)
  • func (svc *DynamoDB) DynamoPutItem(input interface{}, table string) error
  • func (svc *DynamoDB) DynamoScan(table, keyName string, keyValue interface{}) (*ScanOutput, error)
• type GetItemOutput
• type ScanOutput

Constants

const (

	// ErrNoPointerParameter is used when a parameter was expected to be a pointer but it wasn't
	ErrNoPointerParameter = "NoPointerParameter"

	// ErrEmptyParameter is used when a required parameter is empty
	ErrEmptyParameter = "EmptyParameter"
)

const (

	// Input represents the parameter named input
	Input = "input"
	// Output represents the parameter named output
	Output = "output"
	// Table represents the parameter named table
	Table = "table"
	// NewImage represents the parameter named input.Change.NewImage
	NewImage = "input.Change.NewImage"
	// KeyName represents the parameter named keyName
	KeyName = "keyName"
	// KeyValue represents the parameter named keyValue
	KeyValue = "keyValue"
)

Functions

func NewGetItemInput

func NewGetItemInput(table, keyName, keyValue string) (*dynamodb.GetItemInput, error)

NewGetItemInput returns a new *GetItemInput

func NewPutItemInput

func NewPutItemInput(input interface{}, table string) (*dynamodb.PutItemInput, error)

NewPutItemInput returns a new *dynamodb.PutItemInput

func NewScanInput

func NewScanInput(table, keyName string, keyValue interface{}) (*dynamodb.ScanInput, error)

NewScanInput setup ScanInput expression and returns a *ScanInput

func UnmarshalGetItemOutput

func UnmarshalGetItemOutput(input *dynamodb.GetItemOutput, out interface{}) error

UnmarshalGetItemOutput unmarshals a *dynamodb.GetItemOutput into a passed interface reference

func UnmarshalScanOutput

func UnmarshalScanOutput(input *dynamodb.ScanOutput, out interface{}) error

UnmarshalScanOutput unmarshals a *dynamodb.ScanOutput into a passed interface reference

func UnmarshalStreamImage

func UnmarshalStreamImage(input events.DynamoDBEventRecord, output interface{}) error

UnmarshalStreamImage unmarshals a events.DynamoDBEventRecord in a pointer to an interface

Types

type DynamoDB

type DynamoDB struct {
	*dynamodb.DynamoDB
}

DynamoDB embeds *dynamodb.DynamoDB

func New

func New(svc *pkgAws.Session, endpoint string) (*DynamoDB, error)

New returns a new *DynamoDB

func (*DynamoDB) DynamoGetItem

func (svc *DynamoDB) DynamoGetItem(table, keyName, keyValue string) (*GetItemOutput, error)

DynamoGetItem gets an item from DynamoDB given a key and its value. A *GetItemOutput will be returned

func (*DynamoDB) DynamoPutItem

func (svc *DynamoDB) DynamoPutItem(input interface{}, table string) error

DynamoPutItem puts a given input in a dynamodb table

func (*DynamoDB) DynamoScan

func (svc *DynamoDB) DynamoScan(table, keyName string, keyValue interface{}) (*ScanOutput, error)

DynamoScan gets items from DynamoDB given a key and its value. A *ScanOutput will be returned

type GetItemOutput

type GetItemOutput interface{}

GetItemOutput embeds *dynamodb.GetItemOutput

type ScanOutput

type ScanOutput interface{}

ScanOutput embeds *dynamodb.ScanOutput