adapter

Documentation

Index

• type Database
  • func (db *Database) CreateOrUpdate(entity interface{}, tableName string) (response *dynamodb.PutItemOutput, err error)
  • func (db *Database) Delete(condition map[string]interface{}, tableName string) (response *dynamodb.DeleteItemOutput, err error)
  • func (db *Database) FindAll(condition expression.Expression, tableName string) (response *dynamodb.ScanOutput, err error)
  • func (db *Database) FindOne(condition map[string]interface{}, tableName string) (response *dynamodb.GetItemOutput, err error)
  • func (db *Database) Health() bool
• type Interface
  • func NewAdapter(con *dynamodb.DynamoDB) Interface

Types

type Database

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

func (*Database) CreateOrUpdate

func (db *Database) CreateOrUpdate(entity interface{}, tableName string) (response *dynamodb.PutItemOutput, err error)

func (*Database) Delete

func (db *Database) Delete(condition map[string]interface{}, tableName string) (response *dynamodb.DeleteItemOutput, err error)

func (*Database) FindAll

func (db *Database) FindAll(condition expression.Expression, tableName string) (response *dynamodb.ScanOutput, err error)

func (*Database) FindOne

func (db *Database) FindOne(condition map[string]interface{}, tableName string) (response *dynamodb.GetItemOutput, err error)

func (*Database) Health

func (db *Database) Health() bool

type Interface

type Interface interface {
	Health() bool
	FindAll(condition expression.Expression, tableName string) (response *dynamodb.ScanOutput, err error)
	FindOne(condition map[string]interface{}, tableName string) (response *dynamodb.GetItemOutput, err error)
	CreateOrUpdate(entity interface{}, tableName string) (response *dynamodb.PutItemOutput, err error)
	Delete(condition map[string]interface{}, tableName string) (response *dynamodb.DeleteItemOutput, err error)
}

func NewAdapter

func NewAdapter(con *dynamodb.DynamoDB) Interface