Documentation
¶
Index ¶
- func AssertNil(err error)
- func Dumper(log *xlog.Log, args *Args)
- func EscapeBytes(bytes []byte) []byte
- func Loader(log *xlog.Log, args *Args)
- func ReadFile(file string) ([]byte, error)
- func Streamer(log *xlog.Log, args *Args)
- func WriteFile(file string, data string) error
- type Args
- type Connection
- type Files
- type Pool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EscapeBytes ¶
EscapeBytes used to escape the literal byte.
Types ¶
type Args ¶
type Args struct {
User string
Password string
Address string
ToUser string
ToPassword string
ToAddress string
ToDatabase string
ToEngine string
Database string
Table string
Outdir string
SessionVars string
Threads int
ChunksizeInMB int
StmtSize int
Allbytes uint64
Allrows uint64
OverwriteTables bool
// Interval in millisecond.
IntervalMs int
}
Args tuple.
type Connection ¶
type Connection struct {
ID int
// contains filtered or unexported fields
}
Connection tuple.
func (*Connection) Execute ¶
func (conn *Connection) Execute(query string) error
Execute used to executes the query.
func (*Connection) Fetch ¶
func (conn *Connection) Fetch(query string) (*sqltypes.Result, error)
Fetch used to fetch the results.
func (*Connection) StreamFetch ¶
func (conn *Connection) StreamFetch(query string) (driver.Rows, error)
StreamFetch used to the results with streaming.
Source Files
Click to show internal directories.
Click to hide internal directories.