Versions in this module Expand all Collapse all v1 v1.2.0 Oct 11, 2020 Changes in this version type Config + WaitBetweenJobs time.Duration v1.1.0 Oct 10, 2020 Changes in this version + type PrimaryKey struct + func (pk *PrimaryKey) Scan(value interface{}) error + func (pk *PrimaryKey) Value() (driver.Value, error) + func (pk PrimaryKey) String() string + type PrimaryKeySet []PrimaryKey + func (pks PrimaryKeySet) Equals(other PrimaryKeySet) bool + type PrimaryKeySetSlice []PrimaryKeySet + func (rows PrimaryKeySetSlice) Transposed() []interface{} + type ValidationStatus int v1.0.0 Oct 8, 2020 Changes in this version + type Config struct + DeleteChunkSize uint32 + FilteredSourceTables map[string]struct{ ... } + FullCopyThreshold float64 + MinDeleteChunkSize uint32 + ResyncOnSchemaChange bool + SourceConnection string + SourceTables []string + StateTableName string + SyncDeletes bool + SyncUpdates bool + TargetConnection string + ThrottlePercentage float64 + UpdateChunkSize uint32 + func LoadConfig(fileName string) (Config, error) + type Job struct + func NewJob(config Config) (*Job, error) + func (job *Job) Run() error