Versions in this module Expand all Collapse all v1 v1.0.4 Dec 21, 2021 v1.0.3 Dec 17, 2021 v1.0.2 Dec 17, 2021 v1.0.1 Dec 17, 2021 Changes in this version + func AssertNil(err error) + func Dumper(log *xlog.Log, args *config.Config, listener MyDumperListener) + func EscapeBytes(bytes []byte) []byte + func Loader(log *xlog.Log, args *config.Config) + func ParseDumperConfigStruct(dumpNode *DumpNode) (*config.Config, error) + func ReadFile(file string) ([]byte, error) + func WriteFile(file string, data string) error + type Connection struct + ID int + func (conn *Connection) Execute(query string) error + func (conn *Connection) Fetch(query string) (*sqltypes.Result, error) + func (conn *Connection) StreamFetch(query string) (driver.Rows, error) + type DumpNode struct + ChunkSize int + ChunksizeInMB int + DataBase string + DatabaseInvertRegexp bool + DatabaseRegexp string + Host string + OutDir string + Password string + Port int + SessionVars string + Table string + User string + type Files struct + type MyDumperListener interface + Done func(time string, dataBase string, table string, args *config.Config, ...) + DoneNode func(time string, dataBase string, table string, args *config.Config, ...) + PendingNode func(time string, dataBase string, table string, allrows uint64, allbytes uint64, ...) + Start func(time string, dataBase string, table string, rags *config.Config) + StartNode func(time string, dataBase string, table string, args *config.Config, ...) + type Pool struct + func NewPool(log *xlog.Log, cap int, address string, user string, password string, ...) (*Pool, error) + func (p *Pool) Close() + func (p *Pool) Get() *Connection + func (p *Pool) Put(conn *Connection)