txn

Documentation

Index

• Variables
• type TX
  • func New(ctx context.Context, rw bool) (*TX, error)
  • func (t *TX) AddDB(ctx context.Context, ns, db string) (val *sql.DefineDatabaseStatement, err error)
  • func (t *TX) AddNS(ctx context.Context, ns string) (val *sql.DefineNamespaceStatement, err error)
  • func (t *TX) AddTB(ctx context.Context, ns, db, tb string) (val *sql.DefineTableStatement, err error)
  • func (t *TX) AllDB(ctx context.Context, ns string) (out []*sql.DefineDatabaseStatement, err error)
  • func (t *TX) AllDT(ctx context.Context, ns, db string) (out []*sql.DefineTokenStatement, err error)
  • func (t *TX) AllDU(ctx context.Context, ns, db string) (out []*sql.DefineLoginStatement, err error)
  • func (t *TX) AllEV(ctx context.Context, ns, db, tb string) (out []*sql.DefineEventStatement, err error)
  • func (t *TX) AllFD(ctx context.Context, ns, db, tb string) (out []*sql.DefineFieldStatement, err error)
  • func (t *TX) AllFT(ctx context.Context, ns, db, tb string) (out []*sql.DefineTableStatement, err error)
  • func (t *TX) AllIX(ctx context.Context, ns, db, tb string) (out []*sql.DefineIndexStatement, err error)
  • func (t *TX) AllLV(ctx context.Context, ns, db, tb string) (out []*sql.LiveStatement, err error)
  • func (t *TX) AllNS(ctx context.Context) (out []*sql.DefineNamespaceStatement, err error)
  • func (t *TX) AllNT(ctx context.Context, ns string) (out []*sql.DefineTokenStatement, err error)
  • func (t *TX) AllNU(ctx context.Context, ns string) (out []*sql.DefineLoginStatement, err error)
  • func (t *TX) AllSC(ctx context.Context, ns, db string) (out []*sql.DefineScopeStatement, err error)
  • func (t *TX) AllST(ctx context.Context, ns, db, sc string) (out []*sql.DefineTokenStatement, err error)
  • func (t *TX) AllTB(ctx context.Context, ns, db string) (out []*sql.DefineTableStatement, err error)
  • func (t *TX) DelDB(ns, db string)
  • func (t *TX) DelEV(ns, db, tb, ev string)
  • func (t *TX) DelFD(ns, db, tb, fd string)
  • func (t *TX) DelFT(ns, db, tb, ft string)
  • func (t *TX) DelIX(ns, db, tb, ix string)
  • func (t *TX) DelLV(ns, db, tb, lv string)
  • func (t *TX) DelNS(ns string)
  • func (t *TX) DelTB(ns, db, tb string)
  • func (t *TX) GetDB(ctx context.Context, ns, db string) (val *sql.DefineDatabaseStatement, err error)
  • func (t *TX) GetDT(ctx context.Context, ns, db, tk string) (val *sql.DefineTokenStatement, err error)
  • func (t *TX) GetDU(ctx context.Context, ns, db, us string) (val *sql.DefineLoginStatement, err error)
  • func (t *TX) GetNS(ctx context.Context, ns string) (val *sql.DefineNamespaceStatement, err error)
  • func (t *TX) GetNT(ctx context.Context, ns, tk string) (val *sql.DefineTokenStatement, err error)
  • func (t *TX) GetNU(ctx context.Context, ns, us string) (val *sql.DefineLoginStatement, err error)
  • func (t *TX) GetSC(ctx context.Context, ns, db, sc string) (val *sql.DefineScopeStatement, err error)
  • func (t *TX) GetST(ctx context.Context, ns, db, sc, tk string) (val *sql.DefineTokenStatement, err error)
  • func (t *TX) GetTB(ctx context.Context, ns, db, tb string) (val *sql.DefineTableStatement, err error)

Variables

var (
	ErrorNSNotFound = errors.New("The namespace does not exist")
	ErrorNTNotFound = errors.New("The namespace token does not exist")
	ErrorNUNotFound = errors.New("The namespace user does not exist")
	ErrorDBNotFound = errors.New("The database does not exist")
	ErrorDTNotFound = errors.New("The database token does not exist")
	ErrorDUNotFound = errors.New("The database user does not exist")
	ErrorSCNotFound = errors.New("The scope does not exist")
	ErrorSTNotFound = errors.New("The scope token does not exist")
	ErrorTBNotFound = errors.New("The table does not exist")
	ErrorEVNotFound = errors.New("The event does not exist")
	ErrorFDNotFound = errors.New("The field does not exist")
	ErrorIXNotFound = errors.New("The index does not exist")
	ErrorFTNotFound = errors.New("The table does not exist")
	ErrorLVNotFound = errors.New("The query does not exist")
)

Types

type TX

type TX struct {
	kvs.TX
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, rw bool) (*TX, error)

func (*TX) AddDB

func (t *TX) AddDB(ctx context.Context, ns, db string) (val *sql.DefineDatabaseStatement, err error)

func (*TX) AddNS

func (t *TX) AddNS(ctx context.Context, ns string) (val *sql.DefineNamespaceStatement, err error)

func (*TX) AddTB

func (t *TX) AddTB(ctx context.Context, ns, db, tb string) (val *sql.DefineTableStatement, err error)

func (*TX) AllDB

func (t *TX) AllDB(ctx context.Context, ns string) (out []*sql.DefineDatabaseStatement, err error)

func (*TX) AllDT

func (t *TX) AllDT(ctx context.Context, ns, db string) (out []*sql.DefineTokenStatement, err error)

func (*TX) AllDU

func (t *TX) AllDU(ctx context.Context, ns, db string) (out []*sql.DefineLoginStatement, err error)

func (*TX) AllEV

func (t *TX) AllEV(ctx context.Context, ns, db, tb string) (out []*sql.DefineEventStatement, err error)

func (*TX) AllFD

func (t *TX) AllFD(ctx context.Context, ns, db, tb string) (out []*sql.DefineFieldStatement, err error)

func (*TX) AllFT

func (t *TX) AllFT(ctx context.Context, ns, db, tb string) (out []*sql.DefineTableStatement, err error)

func (*TX) AllIX

func (t *TX) AllIX(ctx context.Context, ns, db, tb string) (out []*sql.DefineIndexStatement, err error)

func (*TX) AllLV

func (t *TX) AllLV(ctx context.Context, ns, db, tb string) (out []*sql.LiveStatement, err error)

func (*TX) AllNS

func (t *TX) AllNS(ctx context.Context) (out []*sql.DefineNamespaceStatement, err error)

func (*TX) AllNT

func (t *TX) AllNT(ctx context.Context, ns string) (out []*sql.DefineTokenStatement, err error)

func (*TX) AllNU

func (t *TX) AllNU(ctx context.Context, ns string) (out []*sql.DefineLoginStatement, err error)

func (*TX) AllSC

func (t *TX) AllSC(ctx context.Context, ns, db string) (out []*sql.DefineScopeStatement, err error)

func (*TX) AllST

func (t *TX) AllST(ctx context.Context, ns, db, sc string) (out []*sql.DefineTokenStatement, err error)

func (*TX) AllTB

func (t *TX) AllTB(ctx context.Context, ns, db string) (out []*sql.DefineTableStatement, err error)

func (*TX) DelDB

func (t *TX) DelDB(ns, db string)

func (*TX) DelEV

func (t *TX) DelEV(ns, db, tb, ev string)

func (*TX) DelFD

func (t *TX) DelFD(ns, db, tb, fd string)

func (*TX) DelFT

func (t *TX) DelFT(ns, db, tb, ft string)

func (*TX) DelIX

func (t *TX) DelIX(ns, db, tb, ix string)

func (*TX) DelLV

func (t *TX) DelLV(ns, db, tb, lv string)

func (*TX) DelNS

func (t *TX) DelNS(ns string)

func (*TX) DelTB

func (t *TX) DelTB(ns, db, tb string)

func (*TX) GetDB

func (t *TX) GetDB(ctx context.Context, ns, db string) (val *sql.DefineDatabaseStatement, err error)

func (*TX) GetDT

func (t *TX) GetDT(ctx context.Context, ns, db, tk string) (val *sql.DefineTokenStatement, err error)

func (*TX) GetDU

func (t *TX) GetDU(ctx context.Context, ns, db, us string) (val *sql.DefineLoginStatement, err error)

func (*TX) GetNS

func (t *TX) GetNS(ctx context.Context, ns string) (val *sql.DefineNamespaceStatement, err error)

func (*TX) GetNT

func (t *TX) GetNT(ctx context.Context, ns, tk string) (val *sql.DefineTokenStatement, err error)

func (*TX) GetNU

func (t *TX) GetNU(ctx context.Context, ns, us string) (val *sql.DefineLoginStatement, err error)

func (*TX) GetSC

func (t *TX) GetSC(ctx context.Context, ns, db, sc string) (val *sql.DefineScopeStatement, err error)

func (*TX) GetST

func (t *TX) GetST(ctx context.Context, ns, db, sc, tk string) (val *sql.DefineTokenStatement, err error)

func (*TX) GetTB

func (t *TX) GetTB(ctx context.Context, ns, db, tb string) (val *sql.DefineTableStatement, err error)