Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + const DefaultBatchSize + const DefaultConcurrency + func InitTableState(state *TableState, table *core.Table, conn *sql.DB) (err error) + type MysqlScanInput struct + Config *MysqlScanInputConfig + func NewMysqlScanInput() *MysqlScanInput + func (in *MysqlScanInput) Ack(msg *core.Message, err error) + func (in *MysqlScanInput) Configure(config core.StringMap) (err error) + func (in *MysqlScanInput) GetState() ([]byte, bool) + func (in *MysqlScanInput) SetState(state []byte) (err error) + func (in *MysqlScanInput) Start() (err error) + func (in *MysqlScanInput) Stop() + type MysqlScanInputConfig struct + BatchSize int + Concurrency int + Host string + Password string + Port uint16 + TableNameRegex string + User string + type TableScanner struct + func NewTableScanner(id int, input *MysqlScanInput, tables chan *core.Table) *TableScanner + type TableState struct + ColumnStates []interface{} + ColumnStatesValue atomic.Value + DBName string + Done bool + EstimatedCount int64 + FinishedCount int64 + TableName string
Go to main page