Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HandleReadFunc ¶
type HandleReadFunc func(engine *drivers.MysqlEngine) (interface{}, error)
type HandleWriteFunc ¶
type HandleWriteFunc func(engine *drivers.MysqlEngine) error
type MysqlStreamImpl ¶
type MysqlStreamImpl struct {
// contains filtered or unexported fields
}
func (*MysqlStreamImpl) Read ¶
func (srv *MysqlStreamImpl) Read(fn HandleReadFunc) (ret interface{}, err error)
func (*MysqlStreamImpl) Write ¶
func (srv *MysqlStreamImpl) Write(fn HandleWriteFunc) (err error)
type StreamRepo ¶
type StreamRepo interface {
Read(HandleReadFunc) (interface{}, error)
Write(HandleWriteFunc) error
}
func BuildMysqlStreamRepo ¶
func BuildMysqlStreamRepo(ctx *context.BaseContext, database string, conf config.MysqlMachineConfig) (StreamRepo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.