dumper

Documentation

Index

• Constants
• 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)

Constants

const VITESS_GHOST_TABLE_REGEX = "_vt_EVAC_.*|_vt_DROP_.*|_vt_PURGE_.*|_vt_HOLD_.*|_[0-9a-zA-Z]{8}_[0-9a-zA-Z]{4}_[0-9a-zA-Z]{4}_.*"

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
	Shard                     string
	Table                     string
	Outdir                    string
	SessionVars               []string
	Threads                   int
	ChunksizeInMB             int
	StmtSize                  int
	Allbytes                  uint64
	Allrows                   uint64
	OverwriteTables           bool
	SchemaOnly                bool
	DataOnly                  bool
	ShowDetails               bool
	StartingTable             string
	EndingTable               string
	AllowDifferentDestination bool
	MaxQuerySize              int
	Wheres                    map[string]string
	Selects                   map[string]map[string]string
	Filters                   map[string]map[string]string

	// Interval in millisecond.
	IntervalMs int
	Debug      bool
	Printer    *printer.Printer
}

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

Run 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.