dbx

Documentation

Index

• Variables
• func DeleteAll(ctx context.Context, db *DB) (int64, error)
• type DB
  • func Open(driver, source string) (db *DB, err error)
  • func (obj *DB) Close() (err error)
  • func (obj *DB) NewRx() *Rx
  • func (obj *DB) Open(ctx context.Context) (*Tx, error)
• type DBMethods
• type Error
  • func (e *Error) Error() string
• type ErrorCode
• type Methods
• type Node
• type Node_ApiSecret_Field
  • func Node_ApiSecret(v []byte) Node_ApiSecret_Field
• type Node_Id_Field
  • func Node_Id(v []byte) Node_Id_Field
• type Node_Name_Field
  • func Node_Name(v string) Node_Name_Field
• type Node_PublicAddress_Field
  • func Node_PublicAddress(v string) Node_PublicAddress_Field
• type Node_Update_Fields
• type Rx
  • func (rx *Rx) All_Node(ctx context.Context) (rows []*Node, err error)
  • func (rx *Rx) Commit() (err error)
  • func (rx *Rx) Create_Node(ctx context.Context, node_id Node_Id_Field, node_name Node_Name_Field, ...) (node *Node, err error)
  • func (rx *Rx) Delete_Node_By_Id(ctx context.Context, node_id Node_Id_Field) (deleted bool, err error)
  • func (rx *Rx) Get_Node_By_Id(ctx context.Context, node_id Node_Id_Field) (node *Node, err error)
  • func (rx *Rx) Rebind(s string) string
  • func (rx *Rx) Rollback() (err error)
  • func (rx *Rx) UnsafeTx(ctx context.Context) (unsafe_tx tagsql.Tx, err error)
  • func (rx *Rx) UpdateNoReturn_Node_By_Id(ctx context.Context, node_id Node_Id_Field, update Node_Update_Fields) (err error)
  • func (rx *Rx) Update_Node_By_Id(ctx context.Context, node_id Node_Id_Field, update Node_Update_Fields) (node *Node, err error)
• type Tx
• type TxMethods

Variables

var (
	WrapErr = func(err *Error) error { return err }
	Logger  func(format string, args ...interface{})
)

var SQLite3JournalMode = "WAL"

SQLite3JournalMode controls the journal_mode pragma for all new connections. Since it is read without a mutex, it must be changed to the value you want before any Open calls.

Functions

func DeleteAll

func DeleteAll(ctx context.Context, db *DB) (int64, error)

Types

type DB

type DB struct {
	tagsql.DB

	Hooks struct {
		Now func() time.Time
	}
	// contains filtered or unexported fields
}

func Open

func Open(driver, source string) (db *DB, err error)

func (*DB) Close

func (obj *DB) Close() (err error)

func (*DB) NewRx

func (obj *DB) NewRx() *Rx

func (*DB) Open

func (obj *DB) Open(ctx context.Context) (*Tx, error)

type DBMethods

type DBMethods interface {
	Methods

	Schema() string
	Rebind(sql string) string
}

type Error

type Error struct {
	Err         error
	Code        ErrorCode
	Driver      string
	Constraint  string
	QuerySuffix string
}

func (*Error) Error

func (e *Error) Error() string

type ErrorCode

type ErrorCode int

const (
	ErrorCode_Unknown ErrorCode = iota
	ErrorCode_UnsupportedDriver
	ErrorCode_NoRows
	ErrorCode_TxDone
	ErrorCode_TooManyRows
	ErrorCode_ConstraintViolation
	ErrorCode_EmptyUpdate
)

type Methods

type Methods interface {
	All_Node(ctx context.Context) (
		rows []*Node, err error)

	Create_Node(ctx context.Context,
		node_id Node_Id_Field,
		node_name Node_Name_Field,
		node_public_address Node_PublicAddress_Field,
		node_api_secret Node_ApiSecret_Field) (
		node *Node, err error)

	Delete_Node_By_Id(ctx context.Context,
		node_id Node_Id_Field) (
		deleted bool, err error)

	Get_Node_By_Id(ctx context.Context,
		node_id Node_Id_Field) (
		node *Node, err error)

	UpdateNoReturn_Node_By_Id(ctx context.Context,
		node_id Node_Id_Field,
		update Node_Update_Fields) (
		err error)

	Update_Node_By_Id(ctx context.Context,
		node_id Node_Id_Field,
		update Node_Update_Fields) (
		node *Node, err error)
}

type Node

type Node struct {
	Id            []byte
	Name          string
	PublicAddress string
	ApiSecret     []byte
}

type Node_ApiSecret_Field

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

func Node_ApiSecret

func Node_ApiSecret(v []byte) Node_ApiSecret_Field

type Node_Id_Field

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

func Node_Id

func Node_Id(v []byte) Node_Id_Field

type Node_Name_Field

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

func Node_Name

func Node_Name(v string) Node_Name_Field

type Node_PublicAddress_Field

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

func Node_PublicAddress

func Node_PublicAddress(v string) Node_PublicAddress_Field

type Node_Update_Fields

type Node_Update_Fields struct {
	Name Node_Name_Field
}

type Rx

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

func (*Rx) All_Node

func (rx *Rx) All_Node(ctx context.Context) (
	rows []*Node, err error)

func (*Rx) Commit

func (rx *Rx) Commit() (err error)

func (*Rx) Create_Node

func (rx *Rx) Create_Node(ctx context.Context,
	node_id Node_Id_Field,
	node_name Node_Name_Field,
	node_public_address Node_PublicAddress_Field,
	node_api_secret Node_ApiSecret_Field) (
	node *Node, err error)

func (*Rx) Delete_Node_By_Id

func (rx *Rx) Delete_Node_By_Id(ctx context.Context,
	node_id Node_Id_Field) (
	deleted bool, err error)

func (*Rx) Get_Node_By_Id

func (rx *Rx) Get_Node_By_Id(ctx context.Context,
	node_id Node_Id_Field) (
	node *Node, err error)

func (*Rx) Rebind

func (rx *Rx) Rebind(s string) string

func (*Rx) Rollback

func (rx *Rx) Rollback() (err error)

func (*Rx) UnsafeTx

func (rx *Rx) UnsafeTx(ctx context.Context) (unsafe_tx tagsql.Tx, err error)

func (*Rx) UpdateNoReturn_Node_By_Id

func (rx *Rx) UpdateNoReturn_Node_By_Id(ctx context.Context,
	node_id Node_Id_Field,
	update Node_Update_Fields) (
	err error)

func (*Rx) Update_Node_By_Id

func (rx *Rx) Update_Node_By_Id(ctx context.Context,
	node_id Node_Id_Field,
	update Node_Update_Fields) (
	node *Node, err error)

type Tx

type Tx struct {
	Tx tagsql.Tx
	// contains filtered or unexported fields
}

type TxMethods

type TxMethods interface {
	Methods

	Rebind(s string) string
	Commit() error
	Rollback() error
}