verify

Documentation

Index

• Constants
• func ShardTable(ctx context.Context, truthConn dbconn.Conn, tbl tableverify.Result, ...) ([]rowverify.TableShard, error)
• func Verify(ctx context.Context, conns dbconn.OrderedConns, logger zerolog.Logger, ...) error
• type VerifyOpt
  • func WithConcurrency(c int) VerifyOpt
  • func WithContinuous(c bool, pauseLength time.Duration) VerifyOpt
  • func WithDBFilter(filter utils.FilterConfig) VerifyOpt
  • func WithLive(live bool, settings rowverify.LiveReverificationSettings) VerifyOpt
  • func WithRowBatchSize(c int) VerifyOpt
  • func WithRows(b bool) VerifyOpt
  • func WithRowsPerSecond(c int) VerifyOpt
  • func WithTableSplits(c int) VerifyOpt
  • func WithTestOnly(b bool) VerifyOpt

Constants

const DefaultConcurrency = 8

const DefaultRowBatchSize = 1000

const DefaultTableSplits = 8

Functions

func ShardTable

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

func WithTestOnly(b bool) VerifyOpt