rowverify

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL