executor

Documentation

Index

• Variables
• type Db
  • func GetDb() *Db
  • func (db *Db) Close() error
  • func (db *Db) NewTxn() (*Txn, error)
• type Txn
  • func (txn *Txn) Commit() *rpc.ResultSet
  • func (txn *Txn) Execute(stmt interface{}) *rpc.ResultSet
  • func (txn *Txn) Rollback()
  • func (txn *Txn) Valid() bool

Variables

var InternalErrorMessage = &rpc.ResultSet{
	Message:  "Internal error, all changes within this transaction have been discarded",
	FailFlag: true,
}

Types

type Db

type Db struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func GetDb

func GetDb() *Db

func (*Db) Close

func (db *Db) Close() error

func (*Db) NewTxn

func (db *Db) NewTxn() (*Txn, error)

type Txn

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

func (*Txn) Commit

func (txn *Txn) Commit() *rpc.ResultSet

func (*Txn) Execute

func (txn *Txn) Execute(stmt interface{}) *rpc.ResultSet

func (*Txn) Rollback

func (txn *Txn) Rollback()

func (*Txn) Valid

func (txn *Txn) Valid() bool