model

Documentation

Index

• Constants
• type Index
  • func (i *Index) GetItemID(key Key) (ItemID, error)
  • func (i *Index) PutItemID(key Key, id ItemID) error
• type Item
  • func (i *Item) Map() map[string]*dynamodb.AttributeValue
• type ItemID
  • func NewItemID() ItemID
• type Key
  • func (k *Key) String() string
• type Partition
• type Table
  • func NewTable(partitionKeyField, sortKeyField string) *Table
  • func (t *Table) DeleteItemByID(itemID ItemID) error
  • func (t *Table) DeleteItemByInput(input interface{}) error
  • func (t *Table) DeleteItemByKey(key Key) error
  • func (t *Table) GetItemByID(itemID ItemID) (Item, error)
  • func (t *Table) GetItemByInput(input interface{}) (Item, error)
  • func (t *Table) GetItemByKey(key Key) (Item, error)
  • func (t *Table) KeyFromInput(input interface{}) Key
  • func (t *Table) Lock()
  • func (t *Table) PutItemByInput(input interface{}) error
  • func (t *Table) PutItemByKey(key Key, item Item) error
  • func (t *Table) Unlock()

Constants

const EmptySortKeyField string = ""

const NilSortKey string = ""

const PrimaryIndex string = ""

Types

type Index

type Index struct {
	Partitions        map[string]Partition
	PartitionKeyField string
	SortKeyField      string
}

func (*Index) GetItemID

func (i *Index) GetItemID(key Key) (ItemID, error)

func (*Index) PutItemID

func (i *Index) PutItemID(key Key, id ItemID) error

type Item

type Item map[string]*dynamodb.AttributeValue

func (*Item) Map

func (i *Item) Map() map[string]*dynamodb.AttributeValue

type ItemID

type ItemID string

func NewItemID

func NewItemID() ItemID

type Key

type Key struct {
	Partition string
	Sort      string
	Index     string
}

func (*Key) String

func (k *Key) String() string

type Partition

type Partition map[string]ItemID

type Table

type Table struct {
	Mutex            *sync.Mutex       // Table level lock
	Items            map[ItemID]Item   // The items in the table
	PrimaryIndex     *Index            // The primary/default index for the table
	SecondaryIndices map[string]*Index // All secondary indexes for the table
}

func NewTable

func NewTable(partitionKeyField, sortKeyField string) *Table

func (*Table) DeleteItemByID

func (t *Table) DeleteItemByID(itemID ItemID) error

func (*Table) DeleteItemByInput

func (t *Table) DeleteItemByInput(input interface{}) error

func (*Table) DeleteItemByKey

func (t *Table) DeleteItemByKey(key Key) error

func (*Table) GetItemByID

func (t *Table) GetItemByID(itemID ItemID) (Item, error)

func (*Table) GetItemByInput

func (t *Table) GetItemByInput(input interface{}) (Item, error)

func (*Table) GetItemByKey

func (t *Table) GetItemByKey(key Key) (Item, error)

func (*Table) KeyFromInput

func (t *Table) KeyFromInput(input interface{}) Key

func (*Table) Lock

func (t *Table) Lock()

func (*Table) PutItemByInput

func (t *Table) PutItemByInput(input interface{}) error

func (*Table) PutItemByKey

func (t *Table) PutItemByKey(key Key, item Item) error

func (*Table) Unlock

func (t *Table) Unlock()