dumper

Documentation

Index

• type Config
  • func NewDefaultConfig() *Config
• 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 Dumper
  • func NewDumper(cfg *Config) (*Dumper, error)
  • func (d *Dumper) Run(ctx context.Context) error
• type Files
• type Loader
  • func NewLoader(cfg *Config) (*Loader, error)
  • func (l *Loader) Run(ctx context.Context) error
• type Pool
  • func NewPool(log *zap.Logger, 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)

Types

type Config

type Config struct {
	User                 string
	Password             string
	Address              string
	ToUser               string
	ToPassword           string
	ToAddress            string
	ToDatabase           string
	ToEngine             string
	Database             string
	DatabaseRegexp       string
	DatabaseInvertRegexp bool
	Table                string
	Outdir               string
	SessionVars          string
	Threads              int
	ChunksizeInMB        int
	StmtSize             int
	Allbytes             uint64
	Allrows              uint64
	OverwriteTables      bool
	Wheres               map[string]string
	Selects              map[string]map[string]string
	Filters              map[string]map[string]string

	// Interval in millisecond.
	IntervalMs int
	Debug      bool
}

Config describes the settings to dump from a database.

func NewDefaultConfig

func NewDefaultConfig() *Config

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 Dumper

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

func NewDumper

func NewDumper(cfg *Config) (*Dumper, error)

func (*Dumper) Run

func (d *Dumper) Run(ctx context.Context) error

type Files

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

Files tuple.

type Loader

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

func NewLoader

func NewLoader(cfg *Config) (*Loader, error)

func (*Loader) Run

func (l *Loader) Run(ctx context.Context) error

Loader used to start the loader worker.

type Pool

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

Pool tuple.

func NewPool

func NewPool(log *zap.Logger, cap int, address string, user string, password string, vars string, database 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.