Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrUnimplemented = errors.New("unimplemented") ErrInvalidAction = errors.New("attempted to execute with an invalid action") ErrResourceForbidden = errors.New("resource forbidden") )
View Source
var ErrUnexpectedMessageFormat = errors.New("unexpected message format")
Functions ¶
func RegisterAction ¶
func RegisterAction(a action.A, e NewExecutor) error
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func NewDatabase ¶
func NewDatabase(mysqlDb *MysqlDatabase, filepath string) (*Database, error)
func (*Database) Begin ¶
func (c *Database) Begin() (Transaction, error)
func (*Database) MysqlConn ¶
func (c *Database) MysqlConn() MymysqlConn
func (*Database) MysqlDatabase ¶
func (c *Database) MysqlDatabase() *MysqlDatabase
func (*Database) PrepareActions ¶
type DatabaseConn ¶
type DatabaseConn interface { MysqlConn() MymysqlConn Filepath() string Begin() (Transaction, error) }
type ExecutorRegistry ¶
type ExecutorRegistry struct {
// contains filtered or unexported fields
}
func NewExecutorRegistry ¶
func NewExecutorRegistry() *ExecutorRegistry
func (*ExecutorRegistry) Lookup ¶
func (r *ExecutorRegistry) Lookup(a action.A) NewExecutor
func (*ExecutorRegistry) Register ¶
func (r *ExecutorRegistry) Register(a action.A, e NewExecutor) error
func (*ExecutorRegistry) RegisteredActions ¶
func (r *ExecutorRegistry) RegisteredActions() []action.A
type MymysqlConn ¶
type MymysqlConn interface { Connect() error Prepare(string) (mysql.Stmt, error) Begin() (mysql.Transaction, error) }
A Subset of the mysql.Conn interface to specify exactly what functionality we use
type MysqlDatabase ¶
func NewMysqlDatabase ¶
func NewMysqlDatabase(basename string, c mysql.Conn) (*MysqlDatabase, error)
func NewUniqMysqlDatabase ¶
func NewUniqMysqlDatabase(basename string, c mysql.Conn) (*MysqlDatabase, error)
func (*MysqlDatabase) Create ¶
func (t *MysqlDatabase) Create() error
func (*MysqlDatabase) Drop ¶
func (t *MysqlDatabase) Drop() error
func (*MysqlDatabase) Exists ¶
func (t *MysqlDatabase) Exists() (bool, error)
func (*MysqlDatabase) GenerateSchema ¶
func (t *MysqlDatabase) GenerateSchema() error
func (*MysqlDatabase) SetSchema ¶
func (t *MysqlDatabase) SetSchema(schema string) error
type NewExecutor ¶
type NewExecutor func(DatabaseConn) (Executor, error)
type RollbackError ¶
type RollbackError struct {
// contains filtered or unexported fields
}
func (RollbackError) Error ¶
func (e RollbackError) Error() string
type Transaction ¶
type UpdateResult ¶
func (*UpdateResult) MatchedRows ¶
func (r *UpdateResult) MatchedRows() uint64
Source Files ¶
Click to show internal directories.
Click to hide internal directories.