dynamodbx

README

dynamodbx

A Golang driver extension of AWS DynamoDB

Documentation

Index

• Constants
• Variables
• func ToDynamoDBType(t reflect.Type) (string, error)
• func ToIndexName(key []*dynamodb.KeySchemaElement) string
• func ToTableName(s string) string
• type BaseModel
  • func NewBaseModel(region string, data interface{}) (*BaseModel, error)
  • func (b *BaseModel) Get(id interface{}, secondary ...interface{}) (interface{}, error)
  • func (b *BaseModel) GetIndexes() ([]*dynamodb.GlobalSecondaryIndexDescription, error)
  • func (b *BaseModel) Insert(v interface{}) error
  • func (b *BaseModel) Put(v interface{}) error
  • func (b *BaseModel) Update(key map[string]*dynamodb.AttributeValue, updator string, ...) (int64, error)

Constants

const (
	TAG               = "dynamodbav"
	TAG_INDEX         = "index"
	TAG_SECONDARY     = "secondary"
	TAG_SECONDARY_FOR = "secondaryfor"
)

Variables

var (
	ErrItemNotFound         = errors.New("Item not found")
	ErrConditionalCheckFail = errors.New("ConditionalCheckFailedException: The conditional request failed")
)

Functions

func ToDynamoDBType

func ToDynamoDBType(t reflect.Type) (string, error)

func ToIndexName

func ToIndexName(key []*dynamodb.KeySchemaElement) string

func ToTableName

func ToTableName(s string) string

Types

type BaseModel

type BaseModel struct {
	TableName string
	Type      reflect.Type

	Client *dynamodb.DynamoDB
	// contains filtered or unexported fields
}

func NewBaseModel

func NewBaseModel(region string, data interface{}) (*BaseModel, error)

func (*BaseModel) Get

func (b *BaseModel) Get(id interface{}, secondary ...interface{}) (interface{}, error)

func (*BaseModel) GetIndexes

func (b *BaseModel) GetIndexes() ([]*dynamodb.GlobalSecondaryIndexDescription, error)

func (*BaseModel) Insert

func (b *BaseModel) Insert(v interface{}) error

func (*BaseModel) Put

func (b *BaseModel) Put(v interface{}) error

func (*BaseModel) Update

func (b *BaseModel) Update(key map[string]*dynamodb.AttributeValue, updator string, args map[string]*dynamodb.AttributeValue) (int64, error)