Versions in this module Expand all Collapse all v1 v1.2.0 Feb 6, 2026 Changes in this version + type Config struct + AllowExistingTargetTable bool + Databases FilterAndRewriteConfigs + ReplicatedMasterPositionQuery string + RunFerryFromReplica bool + SourceReplicationMaster *ghostferry.DatabaseConfig + Tables FilterAndRewriteConfigs + TablesToBeCreatedFirst []string + WaitForReplicationTimeout string + func (c *Config) InitializeAndValidateConfig() error + type CopydbFerry struct + Ferry *ghostferry.Ferry + func NewFerry(config *Config) *CopydbFerry + func (this *CopydbFerry) CreateDatabasesAndTables() error + func (this *CopydbFerry) Initialize() error + func (this *CopydbFerry) Run() + func (this *CopydbFerry) Start() error + type FilterAndRewriteConfigs struct + Blacklist []string + Rewrites map[string]string + Whitelist []string + func (f FilterAndRewriteConfigs) Validate() error + type StaticTableFilter struct + Dbs []string + DbsIsBlacklist bool + Tables []string + TablesIsBlacklist bool + func NewStaticTableFilter(dbs, tables FilterAndRewriteConfigs) *StaticTableFilter + func (s *StaticTableFilter) ApplicableDatabases(dbs []string) ([]string, error) + func (s *StaticTableFilter) ApplicableTables(tables []*ghostferry.TableSchema) ([]*ghostferry.TableSchema, error)
Go to main page