common

Documentation

Index

• func AssertNil(err error)
• func Dumper(log *xlog.Log, args *config.Config)
• func EscapeBytes(bytes []byte) []byte
• func Loader(log *xlog.Log, args *config.Config)
• func ReadFile(file string) ([]byte, error)
• func WriteFile(file string, data string) error
• type Connection
  • 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 Files
• type Pool
  • 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)

Functions

func AssertNil

func AssertNil(err error)

AssertNil used to assert the error.

func Dumper

func Dumper(log *xlog.Log, args *config.Config)

Dumper used to start the dumper worker.

func EscapeBytes

func EscapeBytes(bytes []byte) []byte

EscapeBytes used to escape the literal byte.

func Loader

func Loader(log *xlog.Log, args *config.Config)

Loader used to start the loader worker.

func ReadFile

func ReadFile(file string) ([]byte, error)

ReadFile used to read datas from file.

func WriteFile

func WriteFile(file string, data string) error

WriteFile used to write datas to file.

Types

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.

type Files

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

Files tuple.

type Pool

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

Pool tuple.

func NewPool

func NewPool(log *xlog.Log, cap int, address string, user string, password string, vars string) (*Pool, error)

NewPool creates the new pool.

func (*Pool) Close

func (p *Pool) Close()

Close used to close the pool and the connections.

func (*Pool) Get

func (p *Pool) Get() *Connection

Get used to get one connection from the pool.

func (*Pool) Put

func (p *Pool) Put(conn *Connection)

Put used to put one connection to the pool.