rowverify

Documentation

Index

• func VerifyRowsOnShard(ctx context.Context, conns dbconn.OrderedConns, table TableShard, ...) error
• type LiveReverificationSettings
• type RowEventListener
• type TableShard

Functions

func VerifyRowsOnShard

func VerifyRowsOnShard(
	ctx context.Context,
	conns dbconn.OrderedConns,
	table TableShard,
	rowBatchSize int,
	reporter inconsistency.Reporter,
	logger zerolog.Logger,
	liveReverifySettings *LiveReverificationSettings,
	rateLimiter *rate.Limiter,
) error

Types

type LiveReverificationSettings

type LiveReverificationSettings struct {
	MaxBatchSize  int
	FlushInterval time.Duration
	RetrySettings retry.Settings
	RunsPerSecond int
}

type RowEventListener

type RowEventListener interface {
	OnExtraneousRow(row inconsistency.ExtraneousRow)
	OnMissingRow(row inconsistency.MissingRow)
	OnMismatchingRow(row inconsistency.MismatchingRow)
	OnColumnMismatchNoOtherIssues(row inconsistency.MismatchingColumn, reportLog bool)
	OnMatch()
	OnRowScan()
}

type TableShard

type TableShard struct {
	dbtable.VerifiedTable

	StartPKVals []tree.Datum
	EndPKVals   []tree.Datum

	ShardNum    int
	TotalShards int
}