Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + type Replicator struct + func New(cfg *config.Config) *Replicator + func (r *Replicator) Finish() + func (r *Replicator) GenerateChDDL() error + func (r *Replicator) GetTablesToSync() ([]config.PgTableName, error) + func (r *Replicator) HandleMessage(lsn dbtypes.LSN, msg message.Message) error + func (r *Replicator) Init() error + func (r *Replicator) PreparePgTables() error + func (r *Replicator) PrintTablesLSN() + func (r *Replicator) Run() error + func (r *Replicator) State() StateValue + func (r *Replicator) SyncTables(syncTables []config.PgTableName, async bool) error + type StateValue uint32 + const StateInit + const StatePaused + const StatePausing + const StateShuttingDown + const StateWorking
Go to main page