gonorm

Documentation

Overview

Use AWS Dynamodb as storage

Index

• Constants
• func GetUUID() (string, error)
• type DynDB
  • func NewDynDB(table string) (*DynDB, error)
  • func (todo *DynDB) DoWriteTransaction(t WriteTransaction) error
  • func (todo *DynDB) GetJson(key string, valueOut interface{}) error
  • func (todo *DynDB) GetStringList(key string, valueOut *[]string) error
  • func (todo *DynDB) HasKey(key string) (bool, error)
• type KeyValueDB
• type RAMDB
  • func NewRAMDB() *RAMDB
  • func (todo *RAMDB) DoWriteTransaction(t WriteTransaction) error
  • func (todo *RAMDB) GetJson(key string, valueOut interface{}) error
  • func (todo *RAMDB) GetStringList(key string, valueOut *[]string) error
  • func (todo *RAMDB) HasKey(key string) (bool, error)
  • func (todo *RAMDB) SetJson(key string, value interface{}) error
• type WriteTransaction

Constants

const AppendToStrListExpr = "SET strList = list_append(strList, :AppendItems)"

const ConditionKeyDoesntExist = "attribute_not_exists(#key)"

const ConditionKeyExists = "attribute_exists(#key)"

const RenameNewItems = ":AppendItems"

const RenameTableKey = "#key"

const RequestTokenSize = 36

const StrListCreatedMarker = "<CREATED>"

const TableJsonField = "rawJson"

const TableKey = "key"

const TableStrListField = "strList"

Functions

func GetUUID

func GetUUID() (string, error)

Types

type DynDB

type DynDB struct {
	AwsConfig *aws.Config
	DB        *dyndb.Client
	Table     string
}

func NewDynDB

func NewDynDB(table string) (*DynDB, error)

func (*DynDB) DoWriteTransaction

func (todo *DynDB) DoWriteTransaction(t WriteTransaction) error

func (*DynDB) GetJson

func (todo *DynDB) GetJson(key string, valueOut interface{}) error

func (*DynDB) GetStringList

func (todo *DynDB) GetStringList(key string, valueOut *[]string) error

func (*DynDB) HasKey

func (todo *DynDB) HasKey(key string) (bool, error)

type KeyValueDB

type KeyValueDB interface {
	HasKey(key string) (bool, error)
	GetJson(key string, valueOut interface{}) error
	GetStringList(key string, valueOut *[]string) error
	DoWriteTransaction(transaction WriteTransaction) error
}

type RAMDB

type RAMDB struct {
	Jsons            sync.Map
	StrLists         sync.Map
	TransactionLocks sync.Map
}

func NewRAMDB

func NewRAMDB() *RAMDB

func (*RAMDB) DoWriteTransaction

func (todo *RAMDB) DoWriteTransaction(t WriteTransaction) error

func (*RAMDB) GetJson

func (todo *RAMDB) GetJson(key string, valueOut interface{}) error

func (*RAMDB) GetStringList

func (todo *RAMDB) GetStringList(key string, valueOut *[]string) error

func (*RAMDB) HasKey

func (todo *RAMDB) HasKey(key string) (bool, error)

func (*RAMDB) SetJson

func (todo *RAMDB) SetJson(key string, value interface{}) error

type WriteTransaction

type WriteTransaction struct {
	// Create json items that must not already exist
	Creates map[string]interface{}

	Overwrites map[string]interface{}

	// Sets fields of json items
	SetFields map[string]map[string]interface{}

	// Append strings to lists of strings
	StrListAppends map[string][]string

	// Create empty lists of strings
	StrListCreates []string
}