export

type BWList interface {
	Apply(schema string, table string) bool
}

type BWListConf struct {
	Mode BWListMode

	Rules *MySQLReplicationConf
}

type BWListMode byte

type Config struct {
	Database string
	Host     string
	User     string
	Port     int
	Password string
	Threads  int

	FileSize      uint64
	StatementSize uint64
	OutputDirPath string
	ServerInfo    ServerInfo
	SortByPk      bool
	Tables        DatabaseTables
	StatusAddr    string
	Snapshot      string
	Consistency   string
	NoViews       bool

	BlackWhiteList  BWListConf
	Rows            uint64
	Where           string
	EscapeBackslash bool
}

type ConsistencyController interface {
	Setup() error
	TearDown() error
}

type ConsistencyFlushTableWithReadLock struct {
	// contains filtered or unexported fields
}

type ConsistencyLockDumpingTables struct {
	// contains filtered or unexported fields
}

type ConsistencyNone struct{}

type ConsistencySnapshot struct {
	// contains filtered or unexported fields
}

type DatabaseTables map[databaseName][]*TableInfo

type InterceptStringWriter struct {
	io.StringWriter
	SomethingIsWritten bool
}

type LazyStringWriter struct {
	sync.Once
	io.StringWriter
	// contains filtered or unexported fields
}

type Logger interface {
	Debug(format string, args ...interface{})
	Info(format string, args ...interface{})
	Warn(format string, args ...interface{})
	Error(format string, args ...interface{})
}

type MetaIR interface {
	SpecialComments() StringIter
	TargetName() string
	MetaSQL() string
}

type MySQLReplicationBWList struct {
	*filter.Filter
}

type MySQLReplicationConf struct {
	Rules         *filter.Rules
	CaseSensitive bool
}

type NopeBWList struct{}

type RowReceiver interface {
	BindAddress([]interface{})
	ReportSize() uint64
}

type RowReceiverArr []RowReceiverStringer

type RowReceiverStringer interface {
	RowReceiver
	Stringer
}

type SQLRowIter interface {
	Next(RowReceiver) error
	HasNext() bool
	HasNextSQLRowIter() bool
	NextSQLRowIter() SQLRowIter
	// release SQLRowIter
	Close() error
}

type SQLTypeBytes struct {
	// contains filtered or unexported fields
}

type SQLTypeNumber struct {
	SQLTypeString
}

type SQLTypeString struct {
	sql.NullString
}

type ServerInfo struct {
	ServerType    ServerType
	ServerVersion *semver.Version
}

type ServerType int8

type SimpleWriter struct {
	// contains filtered or unexported fields
}

type StringIter interface {
	Next() string
	HasNext() bool
}

type Stringer interface {
	ToString() string
}

type TableDataIR interface {
	DatabaseName() string
	TableName() string
	ChunkIndex() int
	ColumnCount() uint
	ColumnTypes() []string
	SelectedField() string

	SpecialComments() StringIter
	Rows() SQLRowIter
}

type TableInfo struct {
	Name string
	Type TableType
}

type TableType int8

type Writer interface {
	WriteDatabaseMeta(ctx context.Context, db, createSQL string) error
	WriteTableMeta(ctx context.Context, db, table, createSQL string) error
	WriteTableData(ctx context.Context, ir TableDataIR) error
}