verify

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: May 3, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultConcurrency = 8
View Source
const DefaultRowBatchSize = 1000
View Source
const DefaultTableSplits = 8

Variables

This section is empty.

Functions

func ShardTable added in v0.1.1

func ShardTable(
	ctx context.Context,
	truthConn dbconn.Conn,
	tbl tableverify.Result,
	reporter inconsistency.Reporter,
	numSplits int,
) ([]rowverify.TableShard, error)

func Verify

func Verify(
	ctx context.Context,
	conns dbconn.OrderedConns,
	logger zerolog.Logger,
	reporter inconsistency.Reporter,
	inOpts ...VerifyOpt,
) error

Verify verifies the given connections have matching tables and contents.

Types

type VerifyOpt

type VerifyOpt func(*verifyOpts)

func WithConcurrency

func WithConcurrency(c int) VerifyOpt

func WithContinuous

func WithContinuous(c bool, pauseLength time.Duration) VerifyOpt

func WithDBFilter

func WithDBFilter(filter utils.FilterConfig) VerifyOpt

func WithLive

func WithLive(live bool, settings rowverify.LiveReverificationSettings) VerifyOpt

func WithRowBatchSize

func WithRowBatchSize(c int) VerifyOpt

func WithRows

func WithRows(b bool) VerifyOpt

func WithRowsPerSecond

func WithRowsPerSecond(c int) VerifyOpt

func WithTableSplits

func WithTableSplits(c int) VerifyOpt

func WithTestOnly added in v0.1.1

func WithTestOnly(b bool) VerifyOpt

Directories

Path Synopsis
Package dbverify is responsible for verifying two different databases match.
Package dbverify is responsible for verifying two different databases match.

Jump to

Keyboard shortcuts

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