dynamodb

Documentation

Index

• type DynamoDb
  • func NewDynamoDb() (*DynamoDb, error)
  • func NewDynamoDbWithEndpoint(endpoint string) (*DynamoDb, error)
  • func (d *DynamoDb) BatchWrite(requestItems map[string][]types.WriteRequest) error
  • func (d *DynamoDb) Describe(tableName string) (*dynamodb.DescribeTableOutput, error)
  • func (d *DynamoDb) Scan(scanInput *dynamodb.ScanInput) chan []map[string]types.AttributeValue

Types

type DynamoDb

type DynamoDb struct {
	// contains filtered or unexported fields
}

func NewDynamoDb

func NewDynamoDb() (*DynamoDb, error)

func NewDynamoDbWithEndpoint

func NewDynamoDbWithEndpoint(endpoint string) (*DynamoDb, error)

func (*DynamoDb) BatchWrite

func (d *DynamoDb) BatchWrite(requestItems map[string][]types.WriteRequest) error

func (*DynamoDb) Describe

func (d *DynamoDb) Describe(tableName string) (*dynamodb.DescribeTableOutput, error)

func (*DynamoDb) Scan

func (d *DynamoDb) Scan(scanInput *dynamodb.ScanInput) chan []map[string]types.AttributeValue