copydb

Documentation

Index

• Constants
• type Config
  • func (c *Config) InitializeAndValidateConfig() error
• type CopydbFerry
  • func NewFerry(config *Config) *CopydbFerry
  • func (this *CopydbFerry) CreateDatabasesAndTables() error
  • func (this *CopydbFerry) Initialize() error
  • func (this *CopydbFerry) Run()
  • func (this *CopydbFerry) ShutdownControlServer() error
  • func (this *CopydbFerry) Start() error
• type FilterAndRewriteConfigs
  • func (f FilterAndRewriteConfigs) Validate() error
• type StaticTableFilter
  • func NewStaticTableFilter(dbs, tables FilterAndRewriteConfigs) *StaticTableFilter
  • func (s *StaticTableFilter) ApplicableDatabases(dbs []string) ([]string, error)
  • func (s *StaticTableFilter) ApplicableTables(tables []*schema.Table) ([]*schema.Table, error)

Constants

const (
	VerifierTypeChecksumTable  = "ChecksumTable"
	VerifierTypeIterative      = "Iterative"
	VerifierTypeNoVerification = "NoVerification"
)

Types

type Config

type Config struct {
	*ghostferry.Config

	Databases    FilterAndRewriteConfigs
	Tables       FilterAndRewriteConfigs
	VerifierType string
}

func (*Config) InitializeAndValidateConfig

func (c *Config) InitializeAndValidateConfig() error

type CopydbFerry

type CopydbFerry struct {
	Ferry *ghostferry.Ferry
	// contains filtered or unexported fields
}

func NewFerry

func NewFerry(config *Config) *CopydbFerry

func (*CopydbFerry) CreateDatabasesAndTables

func (this *CopydbFerry) CreateDatabasesAndTables() error

func (*CopydbFerry) Initialize

func (this *CopydbFerry) Initialize() error

func (*CopydbFerry) Run

func (this *CopydbFerry) Run()

func (*CopydbFerry) ShutdownControlServer

func (this *CopydbFerry) ShutdownControlServer() error

func (*CopydbFerry) Start

func (this *CopydbFerry) Start() error

type FilterAndRewriteConfigs

type FilterAndRewriteConfigs struct {
	Whitelist []string
	Blacklist []string
	Rewrites  map[string]string
}

With nothing specified, it assumes that everything is applicable.

func (FilterAndRewriteConfigs) Validate

func (f FilterAndRewriteConfigs) Validate() error

type StaticTableFilter

type StaticTableFilter struct {
	Dbs            []string
	DbsIsBlacklist bool

	Tables            []string
	TablesIsBlacklist bool
}

func NewStaticTableFilter

func NewStaticTableFilter(dbs, tables FilterAndRewriteConfigs) *StaticTableFilter

func (*StaticTableFilter) ApplicableDatabases

func (s *StaticTableFilter) ApplicableDatabases(dbs []string) ([]string, error)

func (*StaticTableFilter) ApplicableTables

func (s *StaticTableFilter) ApplicableTables(tables []*schema.Table) ([]*schema.Table, error)