storage

Documentation

Index

• Variables
• type Cursor
• type Engine
  • func New(path string) (*Engine, error)
  • func (e *Engine) Begin() (*Transaction, error)
  • func (e *Engine) Close() error
  • func (e *Engine) GetEntities(typeID domain.Word, key []domain.Word) Cursor
• type Transaction
  • func (tx *Transaction) Commit() error
  • func (tx *Transaction) DeleteEntity(typeID domain.Word, key []domain.Word) error
  • func (tx *Transaction) GetEntities(typeID domain.Word, key []domain.Word) Cursor
  • func (tx *Transaction) PutEntity(typeID domain.Word, row []domain.Word) error
  • func (tx *Transaction) Rollback() error

Variables

var ErrReadOnly = errors.New("read only store")

var ErrUnknownTable = errors.New("unknown table")

Types

type Cursor

type Cursor interface {
	Next() bool
	This() []domain.Word
	Err() error
}

type Engine

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

func New

func New(path string) (*Engine, error)

func (*Engine) Begin

func (e *Engine) Begin() (*Transaction, error)

func (*Engine) Close

func (e *Engine) Close() error

func (*Engine) GetEntities

func (e *Engine) GetEntities(typeID domain.Word, key []domain.Word) Cursor

type Transaction

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

func (*Transaction) Commit

func (tx *Transaction) Commit() error

func (*Transaction) DeleteEntity

func (tx *Transaction) DeleteEntity(typeID domain.Word, key []domain.Word) error

func (*Transaction) GetEntities

func (tx *Transaction) GetEntities(typeID domain.Word, key []domain.Word) Cursor

func (*Transaction) PutEntity

func (tx *Transaction) PutEntity(typeID domain.Word, row []domain.Word) error

func (*Transaction) Rollback

func (tx *Transaction) Rollback() error