Documentation
¶
Index ¶
- Constants
- func CompareRows(ctx context.Context, conns []dbconn.Conn, table TableShard, rowBatchSize int, ...) error
- func Verify(ctx context.Context, conns []dbconn.Conn, reporter Reporter, ...) error
- type CombinedReporter
- type ExtraneousRow
- type ExtraneousTable
- type FixReporter
- type LogReporter
- type MismatchingRow
- type MismatchingTableDefinition
- type MissingRow
- type MissingTable
- type ReportableObject
- type Reporter
- type SnapshotOpt
- type StatusReport
- type TableMetadata
- type TableShard
- type VerifyOpt
- type WorkFunc
Constants ¶
View Source
const DefaultConcurrency = 8
View Source
const DefaultRowBatchSize = 1000
View Source
const DefaultTableSplits = 8
View Source
const DefaultWriteBatchSize = 10000
Variables ¶
This section is empty.
Functions ¶
func CompareRows ¶
Types ¶
type CombinedReporter ¶
type CombinedReporter struct {
Reporters []Reporter
}
func (CombinedReporter) Close ¶
func (c CombinedReporter) Close()
func (CombinedReporter) Report ¶
func (c CombinedReporter) Report(obj ReportableObject)
type ExtraneousRow ¶
type ExtraneousTable ¶
type ExtraneousTable struct {
ConnID dbconn.ID
TableMetadata
}
type FixReporter ¶
func (FixReporter) Close ¶
func (l FixReporter) Close()
func (FixReporter) Report ¶
func (l FixReporter) Report(obj ReportableObject)
type LogReporter ¶
LogReporter reports to `log`.
func (LogReporter) Close ¶
func (l LogReporter) Close()
func (LogReporter) Report ¶
func (l LogReporter) Report(obj ReportableObject)
type MismatchingRow ¶
type MismatchingTableDefinition ¶
type MismatchingTableDefinition struct {
ConnID dbconn.ID
TableMetadata
Info string
}
type MissingRow ¶
type MissingTable ¶
type MissingTable struct {
ConnID dbconn.ID
TableMetadata
}
type ReportableObject ¶
type ReportableObject interface{}
type Reporter ¶
type Reporter interface {
Report(obj ReportableObject)
Close()
}
type SnapshotOpt ¶
type SnapshotOpt func(opts *snapshotOpts)
func WithWriteBatchSize ¶
func WithWriteBatchSize(c int) SnapshotOpt
type StatusReport ¶
type StatusReport struct {
Info string
}
type TableMetadata ¶
func (TableMetadata) Compare ¶
func (tm TableMetadata) Compare(o TableMetadata) int
func (TableMetadata) Less ¶
func (tm TableMetadata) Less(o TableMetadata) bool
type TableShard ¶
type VerifyOpt ¶
type VerifyOpt func(*verifyOpts)
func WithConcurrency ¶
func WithContinuous ¶
func WithRowBatchSize ¶
func WithTableSplits ¶
func WithWorkFunc ¶
Click to show internal directories.
Click to hide internal directories.